public class UnicastReceivingChannelAdapter extends AbstractInternetProtocolReceivingChannelAdapter
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, loggerDEFAULT_PHASE| コンストラクターと説明 |
|---|
UnicastReceivingChannelAdapter(int port) 指定されたポートでリッスンする UnicastReceivingChannelAdapter を構築します。 |
UnicastReceivingChannelAdapter(int port, boolean lengthCheck) 指定されたポートでパケットをリッスンする UnicastReceivingChannelAdapter を構築します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected boolean | asyncSendMessage(DatagramPacketSE packet) |
protected void | doSend(DatagramPacketSE packet) |
protected void | doStop() デフォルトでは何もしません。 |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
int | getPort() |
DatagramSocketSE | getSocket() |
protected DatagramSocketSE | getTheSocket() |
boolean | isLongLived() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
protected DatagramPacketSE | receive() |
void | run() |
protected void | sendAck(Message<byte[]> message) |
void | setLengthCheck(boolean lengthCheck) |
void | setLookupHost(boolean lookupHost) |
void | setSocket(DatagramSocketSE socket) |
protected void | setSocketAttributes(DatagramSocketSE socket) タイムアウトと受信バッファサイズを設定します。ソケットカスタマイザを呼び出します。 |
void | setSocketCustomizer(SocketCustomizer socketCustomizer) 作成後にソケットをさらに構成するようにカスタマイザーを設定します。 |
void | setSoSendBufferSize(int soSendBufferSize) |
checkTaskExecutor, doStart, getApplicationEventPublisher, getLocalAddress, getReceiveBufferSize, getSoReceiveBufferSize, getSoTimeout, getTaskExecutor, isActive, isListening, setApplicationEventPublisher, setListening, setLocalAddress, setPoolSize, setReceiveBufferSize, setSoReceiveBufferSize, setSoTimeout, setTaskExecutorafterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetBeanName, getComponentNamepublic UnicastReceivingChannelAdapter(int port)
port - ポート。public UnicastReceivingChannelAdapter(int port,
boolean lengthCheck)port - ポート。lengthCheck - true の場合、lengthCheck オプションが有効になります。public void setLengthCheck(boolean lengthCheck)
lengthCheck - true の場合、受信パケットには 4 バイトのバイナリ長ヘッダーが含まれることが期待されます。public void setSocketCustomizer(SocketCustomizer socketCustomizer)
socketCustomizer - カスタマイザー。public boolean isLongLived()
public int getPort()
AbstractInternetProtocolReceivingChannelAdapter の getPort protected void onInit()
IntegrationObjectSupportMessageProducerSupport の onInit public void run()
protected void sendAck(Message<byte[]> message)
protected boolean asyncSendMessage(DatagramPacketSE packet)
protected void doSend(DatagramPacketSE packet)
protected DatagramPacketSE receive() throws IOExceptionSE
public void setSocket(DatagramSocketSE socket)
socket - 設定するソケット @Nullable protected DatagramSocketSE getTheSocket()
public DatagramSocketSE getSocket()
protected void setSocketAttributes(DatagramSocketSE socket) throws SocketExceptionSE
socket - ソケット。SocketExceptionSE - ソケット例外。protected void doStop()
MessageProducerSupportAbstractInternetProtocolReceivingChannelAdapter の doStop public void setSoSendBufferSize(int soSendBufferSize)
soSendBufferSize - 送信バッファサイズ。Socket.setSendBufferSize(int)SE, DatagramSocket.setSendBufferSize(int)SEpublic void setLookupHost(boolean lookupHost)
public StringSE getComponentType()
IntegrationObjectSupportNamedComponent の getComponentType IntegrationObjectSupport の getComponentType