Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultPrefetchCount = 1 DefaultPrefetchSize = 0 )
View Source
var ( ErrNoChannelFound error = errors.New("no channel found. Please connect to exchange first") ErrAmqpURICannotBeEmpty error = errors.New("amqpURI cannot be empty") ErrExchangeNameCannotBeEmpty error = errors.New("exchangeName cannot be empty") ErrExchangeTypeCannotBeEmpty error = errors.New("exchangeType cannot be empty") )
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector interface { Connect() (MqContext, error) UseConnection(connection *amqp.Connection) }
type ContextBuilder ¶
type Message ¶
type Message struct { ID string MessageType string Body string ContentType string Created time.Time }
func NewMessage ¶
type MqContext ¶
type MqContext interface { ContextBuilder Connector Publisher Consumer }
func NewContext ¶
func WithContext ¶
Click to show internal directories.
Click to hide internal directories.