OutboundMessageType
- the outbound message typeInboundMessageType
- the inbound message typepublic class BasicMessagePipeline<InboundMessageType,OutboundMessageType> extends Object implements MessagePipeline<InboundMessageType,OutboundMessageType>
MessagePipeline
.Modifier and Type | Field and Description |
---|---|
private MessageDecoder<InboundMessageType> |
decoder
Message decoder.
|
private MessageEncoder<OutboundMessageType> |
encoder
Message encoder.
|
private MessageHandler<InboundMessageType> |
inboundHandler
Inbound message handler.
|
private MessageHandler<OutboundMessageType> |
outboundPayloadHandler
Outbound payload message handler.
|
private MessageHandler<OutboundMessageType> |
outboundTransportHandler
Outbound transport message handler.
|
Constructor and Description |
---|
BasicMessagePipeline(MessageEncoder<OutboundMessageType> newEncoder,
MessageDecoder<InboundMessageType> newDecoder)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
MessageDecoder<InboundMessageType> |
getDecoder()
Get the message decoder instance.
|
MessageEncoder<OutboundMessageType> |
getEncoder()
Get the message encoder instance.
|
MessageHandler<InboundMessageType> |
getInboundMessageHandler()
Get the (optional) inbound message handler instance.
|
MessageHandler<OutboundMessageType> |
getOutboundPayloadMessageHandler()
Get the (optional) outbound payload message handler instance.
|
MessageHandler<OutboundMessageType> |
getOutboundTransportMessageHandler()
Get the (optional) outbound transport message handler instance.
|
protected void |
setDecoder(MessageDecoder<InboundMessageType> newDecoder)
Set the message decoder instance.
|
protected void |
setEncoder(MessageEncoder<OutboundMessageType> newEncoder)
Set the message encoder instance.
|
void |
setInboundHandler(MessageHandler<InboundMessageType> handler)
Set the inbound message handler.
|
void |
setOutboundPayloadHandler(MessageHandler<OutboundMessageType> handler)
Set the outbound payload message handler.
|
void |
setOutboundTransportHandler(MessageHandler<OutboundMessageType> handler)
Set the outbound transport message handler.
|
private MessageEncoder<OutboundMessageType> encoder
private MessageDecoder<InboundMessageType> decoder
private MessageHandler<OutboundMessageType> outboundPayloadHandler
private MessageHandler<OutboundMessageType> outboundTransportHandler
private MessageHandler<InboundMessageType> inboundHandler
public BasicMessagePipeline(@Nonnull MessageEncoder<OutboundMessageType> newEncoder, @Nonnull MessageDecoder<InboundMessageType> newDecoder)
newEncoder
- the message encoder instancenewDecoder
- the message decoder instancepublic MessageEncoder<OutboundMessageType> getEncoder()
getEncoder
in interface MessagePipeline<InboundMessageType,OutboundMessageType>
protected void setEncoder(@Nonnull MessageEncoder<OutboundMessageType> newEncoder)
newEncoder
- the new message encoderpublic MessageDecoder<InboundMessageType> getDecoder()
getDecoder
in interface MessagePipeline<InboundMessageType,OutboundMessageType>
protected void setDecoder(@Nonnull MessageDecoder<InboundMessageType> newDecoder)
newDecoder
- the new message decoderpublic MessageHandler<OutboundMessageType> getOutboundPayloadMessageHandler()
This is the handler intended to be called on the outbound message context, prior to any message encoding.
getOutboundPayloadMessageHandler
in interface MessagePipeline<InboundMessageType,OutboundMessageType>
public void setOutboundPayloadHandler(@Nullable MessageHandler<OutboundMessageType> handler)
handler
- the new handlerpublic MessageHandler<OutboundMessageType> getOutboundTransportMessageHandler()
This is the handler intended to be called after MessageEncoder.prepareContext()
,
but before MessageEncoder.encode()
.
getOutboundTransportMessageHandler
in interface MessagePipeline<InboundMessageType,OutboundMessageType>
public void setOutboundTransportHandler(MessageHandler<OutboundMessageType> handler)
handler
- the new handlerpublic MessageHandler<InboundMessageType> getInboundMessageHandler()
getInboundMessageHandler
in interface MessagePipeline<InboundMessageType,OutboundMessageType>
public void setInboundHandler(MessageHandler<InboundMessageType> handler)
handler
- the new handlerCopyright © 1999–2015. All rights reserved.