rabbitmq

Documentation

Index

• type Broker
  • func (r *Broker) Start(host, port string) (interface{}, error)
  • func (r *Broker) Stop() (interface{}, error)

Types

type Broker

type Broker struct {
	// contains filtered or unexported fields
}

Broker implements the Broker interface for RabbitMQ.

func (*Broker) Start

func (r *Broker) Start(host, port string) (interface{}, error)

Start will start the message broker and prepare it for testing.

func (*Broker) Stop

func (r *Broker) Stop() (interface{}, error)

Stop will stop the message broker.