mocks

func (*Channel) Ack ¶

func (_m *Channel) Ack(tag uint64, multiple bool) error

Ack provides a mock function with given fields: tag, multiple

func (*Channel) Close ¶

func (_m *Channel) Close() error

Close provides a mock function with given fields:

func (*Channel) Confirm ¶

func (_m *Channel) Confirm(noWait bool) error

Confirm provides a mock function with given fields: noWait

func (*Channel) Consume ¶

func (_m *Channel) Consume(queue string, consumer string, autoAck bool, exclusive bool, noLocal bool, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

Consume provides a mock function with given fields: queue, consumer, autoAck, exclusive, noLocal, noWait, args

func (*Channel) ExchangeBind ¶

func (_m *Channel) ExchangeBind(destination string, key string, source string, noWait bool, args amqp.Table) error

ExchangeBind provides a mock function with given fields: destination, key, source, noWait, args

func (*Channel) ExchangeDeclare ¶

func (_m *Channel) ExchangeDeclare(name string, kind string, durable bool, autoDelete bool, internal bool, noWait bool, args amqp.Table) error

ExchangeDeclare provides a mock function with given fields: name, kind, durable, autoDelete, internal, noWait, args

func (*Channel) ExchangeUnbind ¶

func (_m *Channel) ExchangeUnbind(destination string, key string, source string, noWait bool, args amqp.Table) error

ExchangeUnbind provides a mock function with given fields: destination, key, source, noWait, args

func (*Channel) Nack ¶

func (_m *Channel) Nack(tag uint64, multiple bool, requeue bool) error

Nack provides a mock function with given fields: tag, multiple, requeue

func (*Channel) NotifyClose ¶

func (_m *Channel) NotifyClose(c chan *amqp.Error) chan *amqp.Error

NotifyClose provides a mock function with given fields: c

func (*Channel) NotifyPublish ¶

func (_m *Channel) NotifyPublish(confirm chan amqp.Confirmation) chan amqp.Confirmation

NotifyPublish provides a mock function with given fields: confirm

func (*Channel) Publish ¶

func (_m *Channel) Publish(exchange string, key string, mandatory bool, immediate bool, msg amqp.Publishing) error

Publish provides a mock function with given fields: exchange, key, mandatory, immediate, msg

func (*Channel) Qos ¶

func (_m *Channel) Qos(prefetchCount int, prefetchSize int, global bool) error

Qos provides a mock function with given fields: prefetchCount, prefetchSize, global

func (*Channel) QueueBind ¶

func (_m *Channel) QueueBind(name string, key string, exchange string, noWait bool, args amqp.Table) error

QueueBind provides a mock function with given fields: name, key, exchange, noWait, args

func (*Channel) QueueDeclare ¶

func (_m *Channel) QueueDeclare(name string, durable bool, autoDelete bool, exclusive bool, noWait bool, args amqp.Table) (amqp.Queue, error)

QueueDeclare provides a mock function with given fields: name, durable, autoDelete, exclusive, noWait, args

func (*Channel) Reject ¶

func (_m *Channel) Reject(tag uint64, requeue bool) error

Reject provides a mock function with given fields: tag, requeue

func (*Connection) Close ¶

func (c *Connection) Close() error

func (*Connection) Open ¶

func (c *Connection) Open() (channel.Channel, error)