mock

Documentation

Index

• func NewMockConnection() messaging.Connection
• func NewMockConsumer() messaging.Consumer
• func NewMockProducer() messaging.Producer
• type Connection
  • func (c *Connection) Close()
  • func (c *Connection) Consumer(autoAck bool, exchange, queue string) (messaging.Consumer, error)
  • func (c *Connection) IsConnected() bool
  • func (c *Connection) NotifyConnectionClose() <-chan error
  • func (c *Connection) NotifyReestablish() <-chan bool
  • func (c *Connection) Producer(exchange string) (messaging.Producer, error)
  • func (c *Connection) WaitUntilConnectionCloses()
  • func (c *Connection) WaitUntilConnectionReestablished()
• type Consumer
  • func (c *Consumer) BindActions(actions ...string) error
  • func (c *Consumer) Close()
  • func (c *Consumer) Consume()
  • func (c *Consumer) Subscribe(action string, handler messaging.EventHandler, ...) error
  • func (c *Consumer) UnbindActions(actions ...string) error
  • func (c *Consumer) Unsubscribe(action string) error
• type Producer
  • func (p *Producer) Close()
  • func (p *Producer) NotifyClose() <-chan bool
  • func (p *Producer) Publish(action string, data []byte)

Functions

func NewMockConnection

func NewMockConnection() messaging.Connection

func NewMockConsumer

func NewMockConsumer() messaging.Consumer

func NewMockProducer

func NewMockProducer() messaging.Producer

Types

type Connection

type Connection struct {
	mock.Mock
}

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Consumer

func (c *Connection) Consumer(autoAck bool, exchange, queue string) (messaging.Consumer, error)

func (*Connection) IsConnected

func (c *Connection) IsConnected() bool

func (*Connection) NotifyConnectionClose

func (c *Connection) NotifyConnectionClose() <-chan error

func (*Connection) NotifyReestablish

func (c *Connection) NotifyReestablish() <-chan bool

func (*Connection) Producer

func (c *Connection) Producer(exchange string) (messaging.Producer, error)

func (*Connection) WaitUntilConnectionCloses

func (c *Connection) WaitUntilConnectionCloses()

func (*Connection) WaitUntilConnectionReestablished

func (c *Connection) WaitUntilConnectionReestablished()

type Consumer

type Consumer struct {
	mock.Mock
}

func (*Consumer) BindActions

func (c *Consumer) BindActions(actions ...string) error

func (*Consumer) Close

func (c *Consumer) Close()

func (*Consumer) Consume

func (c *Consumer) Consume()

func (*Consumer) Subscribe

func (c *Consumer) Subscribe(action string, handler messaging.EventHandler, options *messaging.SubscribeOptions) error

func (*Consumer) UnbindActions

func (c *Consumer) UnbindActions(actions ...string) error

func (*Consumer) Unsubscribe

func (c *Consumer) Unsubscribe(action string) error

type Producer

type Producer struct {
	mock.Mock
}

func (*Producer) Close

func (p *Producer) Close()

func (*Producer) NotifyClose

func (p *Producer) NotifyClose() <-chan bool

func (*Producer) Publish

func (p *Producer) Publish(action string, data []byte)