Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AmqpClient ¶
type AmqpClient struct { Connection *amqp.Connection ServiceName string }
func (*AmqpClient) AddPublisher ¶
func (a *AmqpClient) AddPublisher(publisher Publisher)
func (*AmqpClient) AddSubscriber ¶
func (a *AmqpClient) AddSubscriber(subscriber *subscriber.SubscriberConfig)
type Publisher ¶
type Publisher interface {
Build(client *AmqpClient)
}
Click to show internal directories.
Click to hide internal directories.