Documentation ¶
Index ¶
Constants ¶
View Source
const ( DeliveryModeTransient = 1 DeliveryModePersistent = 2 )
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 WithDLX ¶
func WithDLX() ReceiverOption
func WithIncomingQueue ¶ added in v0.2.4
func WithIncomingQueue(queue string) ReceiverOption
func WithMarshaler ¶ added in v0.2.0
func WithMarshaler(m Marshaler) ReceiverOption
func WithPrefetchCount ¶
func WithPrefetchCount(c int) ReceiverOption
func WithRequeue ¶ added in v0.2.0
func WithRequeue() ReceiverOption
func WithTopologySetup ¶
func WithTopologySetup() ReceiverOption
type Sender ¶
type Sender struct {
// contains filtered or unexported fields
}
type SenderOption ¶
type SenderOption func(opts *senderOptions)
func WithMessageMarshaler ¶
func WithMessageMarshaler(m Marshaler) SenderOption
func WithTransientDeliveryMode ¶
func WithTransientDeliveryMode() SenderOption
Click to show internal directories.
Click to hide internal directories.