lanternmq

type ChannelID interface{}

type MessageHandler func([]byte, *map[string]interface{}) error

type MessageQueue interface {
	// Connect opens a connection with the underlying queuing service.
	Connect(username string, password string, host string, port string) error
	// CreateChannel opens a channel associated with the connected queuing service.
	CreateChannel() (ChannelID, error)
	// NumConcurrentMsgs defines how many messages can be processed in parallel.
	NumConcurrentMsgs(chID ChannelID, num int) error
	// QueueExists checks whether or not a queue already exists
	QueueExists(chID ChannelID, qName string) (bool, error)
	// DeclareQueue creates a queue with the name 'qName' on the channel with ID 'chID' if one
	// does not exist.
	DeclareQueue(chID ChannelID, qName string) error
	// PublishToQueue sends 'message' to the queue with name 'qName' over the channel with ID
	// 'chID'.
	PublishToQueue(chID ChannelID, qName string, message string) error
	// ConsumeFromQueue returns an instance of Messages, which acts like the receiving channel
	// for any messages that present on queue 'qName' on the channel with ID 'chID'.
	ConsumeFromQueue(chID ChannelID, qName string) (Messages, error)
	// ProcessMessages applies the 'handler' MessageHandler with arguments 'args' to each
	// message that is received through 'msgs'. Sends any errors to the 'errs' channel.
	ProcessMessages(ctx context.Context, msgs Messages, handler MessageHandler, args *map[string]interface{}, errs chan<- error)
	// DeclareExchange creates an exchange with the name 'name' and type 'exchangeType' on the channel with
	// ID 'chID' if one does not exist.
	DeclareExchange(chID ChannelID, name string, exchangeType string) error
	// PublishToExchange sends 'message' to the exchange 'name' on channel with ID 'chID', which will be
	// routed to receivers using 'routingKey'.
	PublishToExchange(chID ChannelID, name string, routingKey string, message string) error
	// DeclareExchangeReceiveQueue creates queue with name 'qName' associated to the exchange with name
	// 'typeName' on the channel with ID 'chID' to receive messages routed with the routing key 'routingKey'.
	DeclareExchangeReceiveQueue(chID ChannelID, typeName string, qName string, routingKey string) error
	// Close closes the MessageQueue and any associated resources including associated channels and the
	// connection to the underlying queuing service.
	Close()
}

type Messages interface{}