Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Listener ¶
type Listener interface {
ListenForMessages()
SetNotifyChannel(chan<- *message.DataMessage)
}
A listener listens for incoming data messages, and sends them to a given channel to be processed by consumers
type RabbitListener ¶
type RabbitListener struct {
QueueName string
NotifyChannel chan<- *message.DataMessage
}
Simple listener that listens for messages on a specified RabbitMq queue
func (*RabbitListener) ListenForMessages ¶
func (listener *RabbitListener) ListenForMessages()
func (*RabbitListener) SetNotifyChannel ¶
func (listener *RabbitListener) SetNotifyChannel(channel chan<- *message.DataMessage)
Source Files
Click to show internal directories.
Click to hide internal directories.