mqserver

Documentation

Index

• type MQServer
  • func NewMQServer(inboundMQAddr string, inboundChName string, outboundMQAddr string, ...) (*MQServer, error)
  • func (s *MQServer) Request(version string, msgType string, msg messages.Message) error
  • func (s *MQServer) Start() error
  • func (s *MQServer) Stop()
• type MessageQueue

Types

type MQServer

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

MQServer provides a wrapper over the message queue.

func NewMQServer

func NewMQServer(
	inboundMQAddr string,
	inboundChName string,
	outboundMQAddr string,
	outboundChName string,
	handlers map[string]map[string]func(msg messages.Message),
) (*MQServer, error)

NewMQServer creates a new message queue server. inboundMQAddr is the address of the inbound MQ this server listens from. inboundChName is the channel name of inbound MQ. outboundMQAddr is the address of the outbound MQ this server pushes to. outboundChName is the channel name of the outbound MQ. handlers are handlers for different messages depending on the message version & message type.

func (*MQServer) Request

func (s *MQServer) Request(version string, msgType string, msg messages.Message) error

Request sends a message to the message queue.

func (*MQServer) Start

func (s *MQServer) Start() error

Start starts the message handling routine.

func (*MQServer) Stop

func (s *MQServer) Stop()

Stop shuts down the server.

type MessageQueue

type MessageQueue interface {
	// Request sends a message to the message queue.
	Request(version string, msgType string, msg messages.Message) error

	// Start starts the message handling routine.
	Start() error

	// Stop shuts down the message handling routine.
	Stop()
}