Class AbstractInternetProtocolReceivingChannelAdapter

All Implemented Interfaces:
Runnable, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, IntegrationPattern, CommonSocketOptions, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, SchedulingAwareRunnable
Direct Known Subclasses:
UnicastReceivingChannelAdapter

public abstract class AbstractInternetProtocolReceivingChannelAdapter extends MessageProducerSupport implements ApplicationEventPublisherAware, SchedulingAwareRunnable, CommonSocketOptions
Base class for inbound TCP/UDP Channel Adapters.
Since:
2.0
Author:
Mark Fisher, Gary Russell, Artem Bilan
  • Constructor Details

    • AbstractInternetProtocolReceivingChannelAdapter

      public AbstractInternetProtocolReceivingChannelAdapter(int port)
  • Method Details

    • getPort

      public int getPort()
      Returns:
      The port on which this receiver is listening.
    • setSoTimeout

      public void setSoTimeout(int soTimeout)
      Specified by:
      setSoTimeout in interface CommonSocketOptions
      Parameters:
      soTimeout - The timeout.
      See Also:
    • getSoTimeout

      public int getSoTimeout()
      Returns:
      the soTimeout
    • setSoReceiveBufferSize

      public void setSoReceiveBufferSize(int soReceiveBufferSize)
      Specified by:
      setSoReceiveBufferSize in interface CommonSocketOptions
      Parameters:
      soReceiveBufferSize - The receive buffer size.
      See Also:
    • getSoReceiveBufferSize

      public int getSoReceiveBufferSize()
      Returns:
      the soReceiveBufferSize
    • setReceiveBufferSize

      public void setReceiveBufferSize(int receiveBufferSize)
    • getReceiveBufferSize

      public int getReceiveBufferSize()
      Returns:
      the receiveBufferSize
    • isListening

      public boolean isListening()
    • setListening

      public void setListening(boolean listening)
      Parameters:
      listening - the listening to set
    • getLocalAddress

      public String getLocalAddress()
    • setLocalAddress

      public void setLocalAddress(String localAddress)
      Description copied from interface: CommonSocketOptions
      On a multi-homed system, specifies the ip address of the network interface used to communicate. For inbound adapters and gateways, specifies the interface used to listed for incoming connections. If omitted, the endpoint will listen on all available adapters. For the UDP multicast outbound adapter specifies the interface to which multicast packets will be sent. For UDP unicast and multicast adapters, specifies which interface to which the acknowledgment socket will be bound. Does not apply to TCP outbound adapters and gateways.
      Specified by:
      setLocalAddress in interface CommonSocketOptions
      Parameters:
      localAddress - The local address.
    • setPoolSize

      public void setPoolSize(int poolSize)
    • setTaskExecutor

      public void setTaskExecutor(Executor taskExecutor)
    • getTaskExecutor

      public Executor getTaskExecutor()
      Returns:
      the taskExecutor
    • getApplicationEventPublisher

      protected ApplicationEventPublisher getApplicationEventPublisher()
    • setApplicationEventPublisher

      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
      Specified by:
      setApplicationEventPublisher in interface ApplicationEventPublisherAware
    • doStart

      protected void doStart()
      Description copied from class: MessageProducerSupport
      Take no action by default. Subclasses may override this if they need lifecycle-managed behavior. Protected by 'lifecycleLock'.
      Overrides:
      doStart in class MessageProducerSupport
    • checkTaskExecutor

      protected void checkTaskExecutor(String threadName)
      Creates a default task executor if none was supplied.
      Parameters:
      threadName - The thread name.
    • doStop

      protected void doStop()
      Description copied from class: MessageProducerSupport
      Take no action by default. Subclasses may override this if they need lifecycle-managed behavior.
      Overrides:
      doStop in class MessageProducerSupport