listeners

Jun 21, 2022

Changes in this version

+ type DefaultOutboundChannels struct

+ func (channels *DefaultOutboundChannels) Get(name string) (channel OutboundChannel, has bool)

+ func (channels *DefaultOutboundChannels) Set(name string, channel OutboundChannel)

+ type Listener interface

+ Close func() (err error)

+ Listen func(ctx context.Context, options ListenerOptions) (err error)

+ Name func() (name string)

+ OutboundChannels func() (channels OutboundChannels)

+ type ListenerOptions struct

+ Config configuares.Config

+ Log logs.Logger

+ type Message interface

+ Body func() (body []byte)

+ Header func() (header MessageHeader)

+ SetBody func(body []byte)

+ func NewMessage() Message

+ type MessageHeader interface

+ Get func(key string) (value interface{})

+ Set func(key string, value interface{})

+ type OutboundChannel interface

+ Name func() (name string)

+ Send func(ctx context.Context, msg Message) (err errors.CodeError)

+ type OutboundChannels interface

+ Get func(name string) (channel OutboundChannel, has bool)

+ Set func(name string, channel OutboundChannel)

+ func NewDefaultOutboundChannels() OutboundChannels