Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrChanClosed = fmt.Errorf("channel closed")
Functions ¶
This section is empty.
Types ¶
type RabbitMQ ¶
type RabbitMQ struct { Channel *amqp.Channel PublishTo string PublishKey string Logger logging.Logger ConsumeFrom string ConsumeKey string // contains filtered or unexported fields }
func (*RabbitMQ) ProcessEvents ¶
ProcessEvents reads and handles events from RabbitMQ.Channel. This method is blocking and returns only if transport initialization failed, or after RabbitMQ.Channel closed. Returned value is always non nil error.
Click to show internal directories.
Click to hide internal directories.