messaging

Documentation

Index

• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) AwaitReceivers(address string, n int)
• type Connection
• type ConnectionFactory
• type MockConnectionFactory
  • func NewMockConnectionFactory(t *testing.T, url string) *MockConnectionFactory
  • func (f *MockConnectionFactory) Connect() (Connection, error)
  • func (f *MockConnectionFactory) Url() string
• type Receiver
• type Sender

Types

type Broker

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

func NewBroker

func NewBroker() *Broker

func (*Broker) AwaitReceivers

func (b *Broker) AwaitReceivers(address string, n int)

type Connection

type Connection interface {
	Sender(address string) (Sender, error)
	Receiver(address string, credit uint32) (Receiver, error)
	Close()
}

type ConnectionFactory

type ConnectionFactory interface {
	Connect() (Connection, error)
	Url() string
}

type MockConnectionFactory

type MockConnectionFactory struct {
	URL    string
	Broker *Broker
}

func NewMockConnectionFactory

func NewMockConnectionFactory(t *testing.T, url string) *MockConnectionFactory

NewMockConnectionFactory creates an in-memory message brokering stub. Messages will be sent multicast and are buffered for all unclosed receivers.

func (*MockConnectionFactory) Connect

func (f *MockConnectionFactory) Connect() (Connection, error)

func (*MockConnectionFactory) Url

func (f *MockConnectionFactory) Url() string

type Receiver

type Receiver interface {
	Receive() (*amqp.Message, error)
	Accept(*amqp.Message) error
	Close() error
}

type Sender

type Sender interface {
	Send(msg *amqp.Message) error
	Close() error
}