Documentation
¶
Overview ¶
Package rabbitmq provides a implementation for RabbitMQ transport.
Index ¶
Constants ¶
View Source
const DefaultAddr = "amqp://guest:guest@localhost:5672/"
DefaultAddr is connection string used to connect to local RabbitMQ instance on default port.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(*Options)
Option is a function on the options for a RabbitMQ transport.
func WithConnection ¶
func WithConnection(c *amqp.Connection) Option
WithConnection is an Option to set underlying RabbitMQ connection.
type Options ¶
type Options struct {
Connection *amqp.Connection
}
Options can be used to create a customized transport.
type Transport ¶
type Transport struct {
sync.Mutex
// exported fields
Addr string
// contains filtered or unexported fields
}
Transport is a vice.Transport for RabbitMQ.
func (*Transport) Done ¶
func (t *Transport) Done() chan struct{}
Done gets a channel which is closed when the transport has successfully stopped.
func (*Transport) Receive ¶
Receive gets a channel on which to receive messages with the specified name.
Source Files
Click to show internal directories.
Click to hide internal directories.