Documentation
¶
Index ¶
- type ConsumerTransport
- type RabbitmqConsumerTransport
- func (self *RabbitmqConsumerTransport) CreateDispatcherMessage(encodedMsg []byte) (dispatcher_message.Message, error)
- func (self *RabbitmqConsumerTransport) Destroy()
- func (self *RabbitmqConsumerTransport) GetError() error
- func (self *RabbitmqConsumerTransport) Listen(messageChannel chan dispatcher_message.Message)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerTransport ¶
type ConsumerTransport interface {
Listen(messageChannel chan dispatcher_message.Message)
Destroy()
CreateDispatcherMessage(encodedMsg []byte) (dispatcher_message.Message, error)
}
func NewConsumerTransport ¶
func NewConsumerTransport() ConsumerTransport
type RabbitmqConsumerTransport ¶
type RabbitmqConsumerTransport struct {
// contains filtered or unexported fields
}
func NewRabbitmqConsumerTransport ¶
func NewRabbitmqConsumerTransport() RabbitmqConsumerTransport
func (*RabbitmqConsumerTransport) CreateDispatcherMessage ¶
func (self *RabbitmqConsumerTransport) CreateDispatcherMessage(encodedMsg []byte) (dispatcher_message.Message, error)
func (*RabbitmqConsumerTransport) Destroy ¶
func (self *RabbitmqConsumerTransport) Destroy()
func (*RabbitmqConsumerTransport) GetError ¶
func (self *RabbitmqConsumerTransport) GetError() error
func (*RabbitmqConsumerTransport) Listen ¶
func (self *RabbitmqConsumerTransport) Listen(messageChannel chan dispatcher_message.Message)
Source Files
Click to show internal directories.
Click to hide internal directories.