Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options func(*RabbitMqHub)
type RabbitMqHub ¶
func NewRabbitMqHub ¶
func NewRabbitMqHub(cfg RabbitMqHub, opts ...Options) *RabbitMqHub
NewRabbitMqHub
func (*RabbitMqHub) ConnectQueue ¶
func (hub *RabbitMqHub) ConnectQueue(q string) (amqp.Queue, error)
ConnectQueue
Click to show internal directories.
Click to hide internal directories.