Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AmqpConsumer ¶
type AmqpConsumer struct {
// contains filtered or unexported fields
}
AmqpConsumer encapsulates data related to consuming rabbitmq messages.
func NewAmqpConsumer ¶
func NewAmqpConsumer(url string, exchangeName string, routingKey string, queueName string) *AmqpConsumer
NewAmqpConsumer creates a new AmqpConsumer.
func (*AmqpConsumer) CloseChannelAndConnection ¶
func (c *AmqpConsumer) CloseChannelAndConnection()
func (*AmqpConsumer) Connect ¶
func (c *AmqpConsumer) Connect()
type MessageConsumer ¶
type MessageConsumer interface {
Consume() (<-chan amqp.Delivery, error)
Connect()
CloseChannelAndConnection()
}
MessageConsumer encapsulates messages needed to consume rabbitmq messages.
Source Files
Click to show internal directories.
Click to hide internal directories.