Documentation
¶
Index ¶
- type RabbitInterface
- func (_m *RabbitInterface) CreateFanoutExchange(channel *amqp.Channel, name string) error
- func (_m *RabbitInterface) GetChannel(conn *amqp.Connection) *amqp.Channel
- func (_m *RabbitInterface) GetConnection(uri string) *amqp.Connection
- func (_m *RabbitInterface) GetConsumer(channel *amqp.Channel, queue string, consumer string, autoAck bool, ...) (<-chan amqp.Delivery, error)
- func (_m *RabbitInterface) Publish(channel *amqp.Channel, exchange string, key string, mandatory bool, ...) error
- func (_m *RabbitInterface) QueueDeclare(channel *amqp.Channel, name string, durable bool, autoDelete bool, ...) (amqp.Queue, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitInterface ¶
RabbitInterface is an autogenerated mock type for the RabbitInterface type
func (*RabbitInterface) CreateFanoutExchange ¶
func (_m *RabbitInterface) CreateFanoutExchange(channel *amqp.Channel, name string) error
CreateFanoutExchange provides a mock function with given fields: channel, name
func (*RabbitInterface) GetChannel ¶
func (_m *RabbitInterface) GetChannel(conn *amqp.Connection) *amqp.Channel
GetChannel provides a mock function with given fields: conn
func (*RabbitInterface) GetConnection ¶
func (_m *RabbitInterface) GetConnection(uri string) *amqp.Connection
GetConnection provides a mock function with given fields: uri
func (*RabbitInterface) GetConsumer ¶
func (_m *RabbitInterface) GetConsumer(channel *amqp.Channel, queue string, consumer string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
GetConsumer provides a mock function with given fields: channel, queue, consumer, autoAck, exclusive, noLocal, noWait, args
func (*RabbitInterface) Publish ¶
func (_m *RabbitInterface) Publish(channel *amqp.Channel, exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing) error
Publish provides a mock function with given fields: channel, exchange, key, mandatory, immediate, msg
func (*RabbitInterface) QueueDeclare ¶
func (_m *RabbitInterface) QueueDeclare(channel *amqp.Channel, name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table) (amqp.Queue, error)
QueueDeclare provides a mock function with given fields: channel, name, durable, autoDelete, exclusive, noWait, args
Source Files
Click to show internal directories.
Click to hide internal directories.