Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ConsumerCanceledByContextError = fmt.Errorf("consumer canceled by context")
View Source
var ConsumerMessageNotInitialized = fmt.Errorf("consumer received empty message")
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct { Connection *amqp.Connection Channel *amqp.Channel // contains filtered or unexported fields }
func NewConnection ¶
func NewConnection(cfg Config) *Connection
func (*Connection) Close ¶
func (l *Connection) Close() error
func (*Connection) Connect ¶
func (l *Connection) Connect() error
func (*Connection) CreateConsumer ¶
func (l *Connection) CreateConsumer(channelName string, consumerName string, handler ConsumerHandler, args amqp.Table) (*Consumer, error)
type ConsumerHandler ¶
type Credentials ¶
type Credentials struct { Protocol string Username string Password string Addr string VHost string Exchange *Exchange }
func (*Credentials) GetURL ¶
func (c *Credentials) GetURL() string
type EventHandler ¶
type IntrvClient ¶
type IntrvClient struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(connection *Connection) *IntrvClient
func (*IntrvClient) HandleChannel ¶
func (*IntrvClient) SetDebug ¶
func (c *IntrvClient) SetDebug(debug bool)
func (*IntrvClient) SetHandler ¶
func (c *IntrvClient) SetHandler(eventName string, handler EventHandler)
type Publisher ¶
type Publisher struct { Connection *Connection Exchange *Exchange }
func NewPublisher ¶
func (*Publisher) Disconnect ¶
Click to show internal directories.
Click to hide internal directories.