Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer interface { Consume(key string) (<-chan amqp.Delivery, error) QueueDeclare(key string) error }
func NewConsumer ¶
type Producer ¶
func NewProducer ¶
type Rabbit ¶
type Rabbit struct {
// contains filtered or unexported fields
}
func (*Rabbit) QueueDeclare ¶
QueueDeclare creates a queue by given key. if it doesn't exist
Click to show internal directories.
Click to hide internal directories.