Documentation ¶
Index ¶
- type Config
- type Consumer
- type MessageHandler
- type Option
- func WithExchange(exchange string) Option
- func WithExchangeType(exchangeType string) Option
- func WithHandler(h MessageHandler) Option
- func WithLogger(logger *logrus.Entry) Option
- func WithQueueName(queueName string) Option
- func WithRoutingKey(routingKey string) Option
- func WithURI(uri string) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
func NewConsumer ¶
type MessageHandler ¶
type MessageHandler interface {
HandleMessage([]byte)
}
type Option ¶
type Option func(*Config)
func WithExchange ¶
func WithExchangeType ¶ added in v1.0.1
func WithHandler ¶
func WithHandler(h MessageHandler) Option
func WithLogger ¶
func WithQueueName ¶
func WithRoutingKey ¶ added in v1.0.1
Click to show internal directories.
Click to hide internal directories.