public abstract class AbstractInternetProtocolSendingMessageHandler extends AbstractMessageHandler implements CommonSocketOptions, ManageableLifecycle
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
AbstractInternetProtocolSendingMessageHandler(StringSE host, int port) |
修飾子と型 | メソッドと説明 |
---|---|
protected abstract void | doStart() |
protected abstract void | doStop() |
SocketAddressSE | getDestinationAddress() |
StringSE | getHost() |
int | getPort() |
int | getSoSendBufferSize() |
int | getSoTimeout() |
boolean | isRunning() |
void | setSoReceiveBufferSize(int size) |
void | setSoSendBufferSize(int size) |
void | setSoTimeout(int timeout) |
void | start() |
void | stop() |
handleMessage, handleMessageInternal, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, onInit, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
setLocalAddress
getThisAs
getBeanName, getComponentName
public AbstractInternetProtocolSendingMessageHandler(StringSE host, int port)
public void setSoTimeout(int timeout)
CommonSocketOptions
の setSoTimeout
timeout
- タイムアウト。DatagramSocket.setSoTimeout(int)
SEpublic void setSoReceiveBufferSize(int size)
CommonSocketOptions
の setSoReceiveBufferSize
size
- 受信バッファサイズ。DatagramSocket.setReceiveBufferSize(int)
SEpublic void setSoSendBufferSize(int size)
CommonSocketOptions
の setSoSendBufferSize
size
- 送信バッファサイズ。DatagramSocket.setSendBufferSize(int)
SEpublic StringSE getHost()
public int getPort()
public SocketAddressSE getDestinationAddress()
public int getSoTimeout()
public int getSoSendBufferSize()
public void start()
Lifecycle
の start
ManageableLifecycle
の start
protected abstract void doStart()
public void stop()
Lifecycle
の stop
ManageableLifecycle
の stop
protected abstract void doStop()
public boolean isRunning()
Lifecycle
の isRunning
ManageableLifecycle
の isRunning