Class AbstractConnectionFactory

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, ExpressionCapable, ConnectionFactory, NamedComponent, ManageableLifecycle
Direct Known Subclasses:
AbstractClientConnectionFactory, AbstractServerConnectionFactory

public abstract class AbstractConnectionFactory extends IntegrationObjectSupport implements ConnectionFactory, ApplicationEventPublisherAware
Base class for all connection factories.
Since:
2.0
Author:
Gary Russell, Artem Bilan
  • Field Details

    • DEFAULT_REPLY_TIMEOUT

      protected static final int DEFAULT_REPLY_TIMEOUT
      See Also:
    • lifecycleMonitor

      protected final Object lifecycleMonitor
  • Constructor Details

    • AbstractConnectionFactory

      public AbstractConnectionFactory(int port)
    • AbstractConnectionFactory

      public AbstractConnectionFactory(String host, int port)
  • Method Details

    • setApplicationEventPublisher

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

      @Nullable public ApplicationEventPublisher getApplicationEventPublisher()
    • setSocketAttributes

      protected void setSocketAttributes(Socket socket) throws SocketException
      Sets socket attributes on the socket.
      Parameters:
      socket - The socket.
      Throws:
      SocketException - Any SocketException.
    • getSoTimeout

      public int getSoTimeout()
      Returns:
      the soTimeout
    • setSoTimeout

      public void setSoTimeout(int soTimeout)
      Parameters:
      soTimeout - the soTimeout to set
    • getSoReceiveBufferSize

      public int getSoReceiveBufferSize()
      Returns:
      the soReceiveBufferSize
    • setSoReceiveBufferSize

      public void setSoReceiveBufferSize(int soReceiveBufferSize)
      Parameters:
      soReceiveBufferSize - the soReceiveBufferSize to set
    • getSoSendBufferSize

      public int getSoSendBufferSize()
      Returns:
      the soSendBufferSize
    • setSoSendBufferSize

      public void setSoSendBufferSize(int soSendBufferSize)
      Parameters:
      soSendBufferSize - the soSendBufferSize to set
    • isSoTcpNoDelay

      public boolean isSoTcpNoDelay()
      Returns:
      the soTcpNoDelay
    • setSoTcpNoDelay

      public void setSoTcpNoDelay(boolean soTcpNoDelay)
      Parameters:
      soTcpNoDelay - the soTcpNoDelay to set
    • getSoLinger

      public int getSoLinger()
      Returns:
      the soLinger
    • setSoLinger

      public void setSoLinger(int soLinger)
      Parameters:
      soLinger - the soLinger to set
    • isSoKeepAlive

      public boolean isSoKeepAlive()
      Returns:
      the soKeepAlive
    • setSoKeepAlive

      public void setSoKeepAlive(boolean soKeepAlive)
      Parameters:
      soKeepAlive - the soKeepAlive to set
    • getSoTrafficClass

      public int getSoTrafficClass()
      Returns:
      the soTrafficClass
    • setSoTrafficClass

      public void setSoTrafficClass(int soTrafficClass)
      Parameters:
      soTrafficClass - the soTrafficClass to set
    • setHost

      public void setHost(String host)
      Set the host; requires the factory to be stopped.
      Parameters:
      host - the host.
      Since:
      5.0
    • getHost

      public String getHost()
      Returns:
      the host
    • setPort

      public void setPort(int port)
      Set the port; requires the factory to be stopped.
      Parameters:
      port - the port.
      Since:
      5.0
    • getPort

      public int getPort()
      Returns:
      the port
    • getListener

      @Nullable public TcpListener getListener()
      Returns:
      the listener
    • getSender

      @Nullable public TcpSender getSender()
      Returns:
      the first sender, if present.
    • getSenders

      public List<TcpSender> getSenders()
      Return the list of senders.
      Returns:
      the senders.
      Since:
      5.4
    • getSerializer

      public Serializer<?> getSerializer()
      Returns:
      the serializer
    • getDeserializer

      public Deserializer<?> getDeserializer()
      Returns:
      the deserializer
    • getMapper

      public TcpMessageMapper getMapper()
      Returns:
      the mapper
    • registerListener

      public void registerListener(TcpListener listenerToRegister)
      Registers a TcpListener to receive messages after the payload has been converted from the input data.
      Parameters:
      listenerToRegister - the TcpListener.
    • registerSender

      public void registerSender(TcpSender senderToRegister)
      Registers a TcpSender; for server sockets, used to provide connection information so a sender can be used to reply to incoming messages.
      Parameters:
      senderToRegister - The sender
    • unregisterSender

      public boolean unregisterSender(TcpSender sender)
      Unregister a TcpSender.
      Parameters:
      sender - the sender.
      Returns:
      true if the sender was registered.
    • setTaskExecutor

      public void setTaskExecutor(Executor taskExecutor)
      Parameters:
      taskExecutor - the taskExecutor to set
    • setDeserializer

      public void setDeserializer(Deserializer<?> deserializer)
      Parameters:
      deserializer - the deserializer to set
    • setSerializer

      public void setSerializer(Serializer<?> serializer)
      Parameters:
      serializer - the serializer to set
    • setMapper

      public void setMapper(TcpMessageMapper mapper)
      Parameters:
      mapper - the mapper to set; defaults to a TcpMessageMapper
    • isSingleUse

      public boolean isSingleUse()
      Returns:
      the singleUse
    • setSingleUse

      public void setSingleUse(boolean singleUse)
      If true, sockets created by this factory will be used once.
      Parameters:
      singleUse - The singleUse to set.
    • setLeaveOpen

      public void setLeaveOpen(boolean leaveOpen)
      If true, sockets created by this factory will be reused. Inverse of setSingleUse(boolean).
      Parameters:
      leaveOpen - The keepOpen to set.
      Since:
      5.0
    • setInterceptorFactoryChain

      public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
    • setLookupHost

      public void setLookupHost(boolean lookupHost)
      If true, DNS reverse lookup is done on the remote ip address. Default false: not all environments (e.g. Docker containers) perform reliable DNS resolution.
      Parameters:
      lookupHost - the lookupHost to set
    • isLookupHost

      public boolean isLookupHost()
      Returns:
      the lookupHost
    • setNioHarvestInterval

      public void setNioHarvestInterval(int nioHarvestInterval)
      How often we clean up closed NIO connections if soTimeout is 0. Ignored when soTimeout > 0 because the clean up process is run as part of the timeout handling. Default 2000 milliseconds.
      Parameters:
      nioHarvestInterval - The interval in milliseconds.
    • setSslHandshakeTimeout

      public void setSslHandshakeTimeout(int sslHandshakeTimeout)
      Set the handshake timeout used when waiting for SSL handshake data; only applies to SSL connections, when using NIO.
      Parameters:
      sslHandshakeTimeout - the timeout.
      Since:
      4.3.6
    • getSslHandshakeTimeout

      @Nullable protected Integer getSslHandshakeTimeout()
      Returns:
      the handshake timeout.
      Since:
      4.3.6
      See Also:
    • getDelayedReads

      protected BlockingQueue<org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory.PendingIO> getDelayedReads()
    • getReadDelay

      protected long getReadDelay()
    • setReadDelay

      public void setReadDelay(long readDelay)
      The delay (in milliseconds) before retrying a read after the previous attempt failed due to insufficient threads. Default 100.
      Parameters:
      readDelay - the readDelay to set.
    • getLifecycleMonitor

      protected Object getLifecycleMonitor()
    • onInit

      protected void onInit()
      Description copied from class: IntegrationObjectSupport
      Subclasses may implement this for initialization logic.
      Overrides:
      onInit in class IntegrationObjectSupport
    • start

      public void start()
      Specified by:
      start in interface Lifecycle
      Specified by:
      start in interface ManageableLifecycle
    • getTaskExecutor

      protected Executor getTaskExecutor()
      Creates a taskExecutor (if one was not provided).
      Returns:
      The executor.
    • stop

      public void stop()
      Stops the server.
      Specified by:
      stop in interface Lifecycle
      Specified by:
      stop in interface ManageableLifecycle
    • wrapConnection

      protected TcpConnectionSupport wrapConnection(TcpConnectionSupport connectionArg)
    • processNioSelections

      protected void processNioSelections(int selectionCount, Selector selector, @Nullable ServerSocketChannel server, Map<SocketChannel,TcpNioConnection> connectionMap)
      Times out any expired connections then, if selectionCount > 0, processes the selected keys. Removes closed connections from the connections field, and from the connections parameter.
      Parameters:
      selectionCount - Number of IO Events, if 0 we were probably woken up by a close.
      selector - The selector.
      server - The server socket channel.
      connectionMap - Map of connections.
    • delayRead

      protected void delayRead(Selector selector, long now, SelectionKey key)
    • doAccept

      protected void doAccept(Selector selector, ServerSocketChannel server, long now)
      Parameters:
      selector - The selector.
      server - The server socket channel.
      now - The current time.
    • addConnection

      protected void addConnection(TcpConnectionSupport connection)
    • harvestClosedConnections

      protected void harvestClosedConnections()
      Cleans up this.connections by removing any closed connections.
    • isRunning

      public boolean isRunning()
      Specified by:
      isRunning in interface Lifecycle
      Specified by:
      isRunning in interface ManageableLifecycle
    • isActive

      protected boolean isActive()
      Returns:
      the active
    • setActive

      protected void setActive(boolean active)
      Parameters:
      active - the active to set
    • checkActive

      protected void checkActive()
    • getTcpSocketSupport

      protected TcpSocketSupport getTcpSocketSupport()
    • setTcpSocketSupport

      public void setTcpSocketSupport(TcpSocketSupport tcpSocketSupport)
    • getOpenConnectionIds

      public List<String> getOpenConnectionIds()
      Returns a list of (currently) open TcpConnection connection ids; allows, for example, broadcast operations to all open connections.
      Returns:
      the list of connection ids.
    • closeConnection

      public boolean closeConnection(String connectionId)
      Close a connection with the specified connection id.
      Parameters:
      connectionId - the connection id.
      Returns:
      true if the connection was closed.
    • toString

      public String toString()
      Overrides:
      toString in class IntegrationObjectSupport