Documentation
¶
Index ¶
- func NewAmqpMessageBus(host string, port int) (messagebus.Messagebus, error)
- type AmqpMessagebus
- func (m *AmqpMessagebus) Close() error
- func (m *AmqpMessagebus) ReceiveMessage(message chan<- string, queue string) (messagebus.Subscription, error)
- func (m *AmqpMessagebus) SendMessage(message []byte, queue string) error
- func (m *AmqpMessagebus) SendMessageWithHeaders(message []byte, queue string, headers map[string]string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAmqpMessageBus ¶
func NewAmqpMessageBus(host string, port int) (messagebus.Messagebus, error)
Types ¶
type AmqpMessagebus ¶
type AmqpMessagebus struct {
// contains filtered or unexported fields
}
func (*AmqpMessagebus) Close ¶
func (m *AmqpMessagebus) Close() error
func (*AmqpMessagebus) ReceiveMessage ¶
func (m *AmqpMessagebus) ReceiveMessage(message chan<- string, queue string) (messagebus.Subscription, error)
func (*AmqpMessagebus) SendMessage ¶
func (m *AmqpMessagebus) SendMessage(message []byte, queue string) error
func (*AmqpMessagebus) SendMessageWithHeaders ¶
Source Files
Click to show internal directories.
Click to hide internal directories.