Documentation
¶
Index ¶
- type Receiver
- type ReceiverOption
- func WithBindingsSetup() ReceiverOption
- func WithIncomingQueue(queue string) ReceiverOption
- func WithMarshaler(m rabbitmq.Marshaler) ReceiverOption
- func WithMaxRetries(n int) ReceiverOption
- func WithMinRetryBackoff(d time.Duration) ReceiverOption
- func WithPrefetchCount(c int) ReceiverOption
- func WithTopologySetup() ReceiverOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Receiver ¶
type Receiver struct {
// contains filtered or unexported fields
}
func NewReceiver ¶
func NewReceiver(client *amqpx.Client, opts ...ReceiverOption) *Receiver
type ReceiverOption ¶
type ReceiverOption func(o *receiverOptions)
func WithBindingsSetup ¶
func WithBindingsSetup() ReceiverOption
func WithIncomingQueue ¶ added in v0.2.4
func WithIncomingQueue(queue string) ReceiverOption
func WithMarshaler ¶
func WithMarshaler(m rabbitmq.Marshaler) ReceiverOption
func WithMaxRetries ¶
func WithMaxRetries(n int) ReceiverOption
func WithMinRetryBackoff ¶
func WithMinRetryBackoff(d time.Duration) ReceiverOption
func WithPrefetchCount ¶
func WithPrefetchCount(c int) ReceiverOption
func WithTopologySetup ¶
func WithTopologySetup() ReceiverOption
Source Files
Click to show internal directories.
Click to hide internal directories.