Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶ added in v0.9.0
type Connection struct { *amqp.Connection // contains filtered or unexported fields }
func (*Connection) Channel ¶ added in v0.9.0
func (c *Connection) Channel() (*Channel, error)
Channel wrap amqp.Connection.Channel, get a auto reconnect channel
type MiddlewareConsume ¶ added in v0.9.0
type MiddlewarePublish ¶ added in v0.9.0
type MiddlewarePublish func(ctx context.Context, msg amqp.Publishing, next func(context.Context, amqp.Publishing) error) error
type Option ¶ added in v0.9.0
type Option func(opt *config)
func WithConsumerMiddleware ¶ added in v0.9.0
func WithConsumerMiddleware(middleware MiddlewareConsume) Option
func WithLogger ¶ added in v0.9.0
func WithPublisherMiddleware ¶ added in v0.9.0
func WithPublisherMiddleware(middleware MiddlewarePublish) Option
func WithQueueNamePrefix ¶ added in v0.9.0
func WithReconnectDelay ¶ added in v0.9.0
Click to show internal directories.
Click to hide internal directories.