Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TestRabbitConsumer ¶
type TestRabbitConsumer struct {
// contains filtered or unexported fields
}
func NewTestRabbitConsumer ¶
func NewTestRabbitConsumer( hostURL string, routingKey string, exchangeName string, queueName string) *TestRabbitConsumer
Creates a new TestRabbitConsumer.
func (*TestRabbitConsumer) CloseConnectionAndChannel ¶
func (c *TestRabbitConsumer) CloseConnectionAndChannel()
CloseConnection closes the connection.
func (*TestRabbitConsumer) Connect ¶
func (c *TestRabbitConsumer) Connect()
Connect initializes a connection.
func (*TestRabbitConsumer) ConsumeMessages ¶
func (c *TestRabbitConsumer) ConsumeMessages() (<-chan amqp.Delivery, error)
ConsumeMessages consumes messages from rabbitmq, returns the deliveries.
Click to show internal directories.
Click to hide internal directories.