Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumeParams ¶
type MessageBroker ¶
type MessageBroker interface { Consume(*ConsumeParams) <-chan amqp.Delivery Publish(*PublishParams) error }
type PublishParams ¶
type Rabbit ¶
type Rabbit struct {
User, Password, Host, VHost, Port, ConnectionUrl string
Connection *amqp.Connection
Chan *amqp.Channel
}
func (*Rabbit) BuilderConnectionUrl ¶
func (*Rabbit) Connect ¶
func (rabbit *Rabbit) Connect() *amqp.Connection
func (*Rabbit) Publish ¶
func (rabbit *Rabbit) Publish(p *PublishParams) error
Click to show internal directories.
Click to hide internal directories.