Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HandlerFunc ¶
HandlerFunc - the handler function to deal with this topic
type Rabbit ¶
type Rabbit struct { Connection *amqp.Connection Channel *amqp.Channel }
Rabbit - create rabbit object
func (*Rabbit) SubscribeToTopics ¶
func (rbt *Rabbit) SubscribeToTopics(subsc []TopicSubscription)
SubscribeToTopics - subscribe this rabbit to an exchange with a routing key
type RabbitConnection ¶
RabbitConnection - a configuration object for the connection to rabbit
type RabbitEmitMessage ¶
type RabbitMessageBody ¶
type TopicSubscription ¶
type TopicSubscription struct { RoutingKey string Handler HandlerFunc }
TopicSubscription - subscription object
Click to show internal directories.
Click to hide internal directories.