message

Documentation

Index

• Variables
• type CommonMessageRouter
  • func NewRouter(manager *connection.Manager, config *queue.RouterConfig, logger zerolog.Logger) *CommonMessageRouter
  • func (cmr *CommonMessageRouter) Close() error
  • func (cmr *CommonMessageRouter) SendAll(msgBatch *p_buff.MessageGroupBatch, attributes ...string) error
  • func (cmr *CommonMessageRouter) SendRawAll(rawData []byte, attributes ...string) error
  • func (cmr *CommonMessageRouter) SubscribeAll(listener message.Listener, attributes ...string) (queue.Monitor, error)
  • func (cmr *CommonMessageRouter) SubscribeAllWithManualAck(listener message.ConformationListener, attributes ...string) (queue.Monitor, error)
  • func (cmr *CommonMessageRouter) SubscribeRawAll(listener message.RawListener, attributes ...string) (queue.Monitor, error)
• type CommonMessageSender
  • func (sender *CommonMessageSender) Send(batch *p_buff.MessageGroupBatch) error
  • func (sender *CommonMessageSender) SendRaw(data []byte) error

Variables

var (
	NullValue = errors.New("null value for sending")
)

Types

type CommonMessageRouter

type CommonMessageRouter struct {
	Logger zerolog.Logger
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(
	manager *connection.Manager,
	config *queue.RouterConfig,
	logger zerolog.Logger,
) *CommonMessageRouter

func (*CommonMessageRouter) Close

func (cmr *CommonMessageRouter) Close() error

func (*CommonMessageRouter) SendAll

func (cmr *CommonMessageRouter) SendAll(msgBatch *p_buff.MessageGroupBatch, attributes ...string) error

func (*CommonMessageRouter) SendRawAll

func (cmr *CommonMessageRouter) SendRawAll(rawData []byte, attributes ...string) error

func (*CommonMessageRouter) SubscribeAll

func (cmr *CommonMessageRouter) SubscribeAll(listener message.Listener, attributes ...string) (queue.Monitor, error)

func (*CommonMessageRouter) SubscribeAllWithManualAck

func (cmr *CommonMessageRouter) SubscribeAllWithManualAck(listener message.ConformationListener, attributes ...string) (queue.Monitor, error)

func (*CommonMessageRouter) SubscribeRawAll

func (cmr *CommonMessageRouter) SubscribeRawAll(listener message.RawListener, attributes ...string) (queue.Monitor, error)

type CommonMessageSender

type CommonMessageSender struct {
	ConnManager *connection.Manager

	Logger zerolog.Logger
	// contains filtered or unexported fields
}

func (*CommonMessageSender) Send

func (sender *CommonMessageSender) Send(batch *p_buff.MessageGroupBatch) error

func (*CommonMessageSender) SendRaw

func (sender *CommonMessageSender) SendRaw(data []byte) error