messaging

Documentation

Index

• type Connection
• type ConnectionFactory
• type Receiver
• type Sender

Types

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 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
}