inbound

Documentation

Index

• type MessageHandler
  • func NewInboundMessageHandler(p provider) *MessageHandler
  • func (handler *MessageHandler) HandleInboundEnvelope(envelope *transport.Envelope) error
  • func (handler *MessageHandler) HandlerFunc() transport.InboundMessageHandler
  • func (handler *MessageHandler) Initialize(p provider)

Types

type MessageHandler

type MessageHandler struct {
	// contains filtered or unexported fields
}

MessageHandler handles inbound envelopes, processing then dispatching to a protocol service based on the message type.

func NewInboundMessageHandler

func NewInboundMessageHandler(p provider) *MessageHandler

NewInboundMessageHandler creates an inbound message handler, that processes inbound message Envelopes, and dispatches them to the appropriate ProtocolService.

func (*MessageHandler) HandleInboundEnvelope

func (handler *MessageHandler) HandleInboundEnvelope(envelope *transport.Envelope,
) error

HandleInboundEnvelope handles an inbound envelope, dispatching it to the appropriate ProtocolService.

func (*MessageHandler) HandlerFunc

func (handler *MessageHandler) HandlerFunc() transport.InboundMessageHandler

HandlerFunc returns the MessageHandler's transport.InboundMessageHandler function.

func (*MessageHandler) Initialize

func (handler *MessageHandler) Initialize(p provider)

Initialize initializes the MessageHandler. Any call beyond the first is a no-op.