Class ChannelInitializerFactory


  • public class ChannelInitializerFactory
    extends Object
    Factory for ChannelInitializer instances.
    Author:
    michal.polkorab
    • Constructor Detail

      • ChannelInitializerFactory

        public ChannelInitializerFactory()
    • Method Detail

      • createPublishingChannelInitializer

        public TcpChannelInitializer createPublishingChannelInitializer()
        Creates a TCP publishing channel initializer.
        Returns:
        PublishingChannelInitializer that initializes new channels
      • createUdpChannelInitializer

        public UdpChannelInitializer createUdpChannelInitializer()
        Creates a UDP channel initializer.
        Returns:
        PublishingChannelInitializer that initializes new channels
      • setSwitchIdleTimeout

        public void setSwitchIdleTimeout​(long timeout)
        Sets the switch idle timeout.
        Parameters:
        timeout - the timeout
      • setDeserializationFactory

        public void setDeserializationFactory​(DeserializationFactory deserializationFactory)
        Sets the DeserializationFactory.
        Parameters:
        deserializationFactory - the DeserializationFactory
      • setSerializationFactory

        public void setSerializationFactory​(SerializationFactory serializationFactory)
        Sets the SerializationFactory.
        Parameters:
        serializationFactory - the SerializationFactory
      • setTlsConfig

        public void setTlsConfig​(TlsConfiguration tlsConfig)
        Sets the TlsConfiguration.
        Parameters:
        tlsConfig - the TlsConfiguration
      • setSwitchConnectionHandler

        public void setSwitchConnectionHandler​(SwitchConnectionHandler switchConnectionHandler)
        Sets the SwitchConnectionHandler.
        Parameters:
        switchConnectionHandler - the SwitchConnectionHandler
      • setUseBarrier

        public void setUseBarrier​(boolean useBarrier)
        Sets whether or not to use a barrier.
      • setChannelOutboundQueueSize

        public void setChannelOutboundQueueSize​(int channelOutboundQueueSize)
        Sets the channelOutboundQueueSize.
        Parameters:
        channelOutboundQueueSize - the channelOutboundQueueSize