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