Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
func New ¶
func New(connectionFactory ConnectionFactory, options ...OptionFunc) (*Broker, error)
type ConnectionFactory ¶
type ConnectionFactory func() (*amqp.Connection, error)
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
func (*Message) ContentType ¶
type OptionFunc ¶
OptionFunc is a function that configures the AMQPBroker.
func SetExchange ¶
func SetExchange(exchange, exchangeType string) OptionFunc
Click to show internal directories.
Click to hide internal directories.