Documentation ¶ Index ¶ func NewConsumer[T handler.IMessage](connection connection.IConnection, handler handler.IHandler[T], ...) *consumer[T] func NewHandlerCommand[T handler.IMessage](delivery amqp.Delivery, retryQueue queue.IQueue, errorQueue queue.IQueue, ...) iHandlerCommand Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewConsumer ¶ func NewConsumer[T handler.IMessage](connection connection.IConnection, handler handler.IHandler[T], queue queue.IQueue, retryQueue queue.IQueue, errorQueue queue.IQueue, executeInterval int) *consumer[T] func NewHandlerCommand ¶ func NewHandlerCommand[T handler.IMessage](delivery amqp.Delivery, retryQueue queue.IQueue, errorQueue queue.IQueue, handler handler.IHandler[T], executeInterval int) iHandlerCommand Types ¶ This section is empty. Source Files ¶ View all Source files consumer.go handler_command.go Click to show internal directories. Click to hide internal directories.