Class DemuxingProtocolEncoder.DefaultConstructorMessageEncoderFactory<T>

    • Field Detail

      • encoderClass

        private final java.lang.Class<MessageEncoder<T>> encoderClass
    • Constructor Detail

      • DefaultConstructorMessageEncoderFactory

        private DefaultConstructorMessageEncoderFactory​(java.lang.Class<MessageEncoder<T>> encoderClass)
    • Method Detail

      • getEncoder

        public MessageEncoder<T> getEncoder()
                                     throws java.lang.Exception
        Creates a new message encoder.
        Specified by:
        getEncoder in interface MessageEncoderFactory<T>
        Returns:
        The created encoder
        Throws:
        java.lang.Exception - If we weren't able to create an encoder