Documentation ¶
Index ¶
- func Connect(host string) (*amqp.Connection, *amqp.Channel)
- func Consume(channel *amqp.Channel, channelName string, queueName string, routingKey string) <-chan amqp.Delivery
- func Publish(channel *amqp.Channel, channelName string, routingKey string, body []byte)
- func Queue(channel *amqp.Channel, channelName string, queueName string, routingKey string)
- type Inbound
- type InboundBarcode
- type Outbound
- type RMQInbound
- type RMQOutbound
- type RMQPublish
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Inbound ¶
type Inbound struct { BU string `json:"bu"` Data []InboundBarcode `json:"data"` TraceID *string `json:"trace_uuid"` }
func ParseInbound ¶
type InboundBarcode ¶
type RMQInbound ¶
type RMQInbound struct { Host string `json:"host"` Queue string `json:"queue"` Channel string `json:"channel"` }
func ParseRMQInbound ¶
func ParseRMQInbound(raw []byte) RMQInbound
type RMQOutbound ¶
type RMQOutbound struct { Host string `json:"host"` Publish []RMQPublish `json:"publish"` }
func ParseRMQOutbound ¶
func ParseRMQOutbound(raw []byte) []RMQOutbound
type RMQPublish ¶
Click to show internal directories.
Click to hide internal directories.