Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidJson = errors.New("payload is not a valid json data")
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager interface { AssignConsumerToQueue(queueName string, consumer base_consumer.Consumer, replication int) StartConsuming(queueNames ...string) error ShutDown() }
func NewConsumerManager ¶
func NewConsumerManager(deliveryChannelManager delivery_channel_manager.DeliveryChannelManager) Manager
Click to show internal directories.
Click to hide internal directories.