amqpwrap

May 8, 2023

Changes in this version

+ var ErrConnResetNeeded = errors.New("connection must be reset, link/connection state may be inconsistent")

type AMQPReceiverWrapper

+ ContextWithTimeoutFn ContextWithTimeoutFn

+ Inner goamqpReceiver

+ type AMQPSenderWrapper struct

+ ContextWithTimeoutFn ContextWithTimeoutFn

+ Inner AMQPSenderCloser

+ func (sw *AMQPSenderWrapper) Close(ctx context.Context) error

+ func (sw *AMQPSenderWrapper) LinkName() string

+ func (sw *AMQPSenderWrapper) MaxMessageSize() uint64

+ func (sw *AMQPSenderWrapper) Send(ctx context.Context, msg *amqp.Message, o *amqp.SendOptions) error

type AMQPSessionWrapper

+ ContextWithTimeoutFn ContextWithTimeoutFn

+ type ContextWithTimeoutFn func(parent context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

Feb 7, 2023

Changes in this version

type AMQPClient

+ Name func() string

type AMQPClientWrapper

+ ID string

+ func (w *AMQPClientWrapper) Name() string

+ type Closeable interface

+ Close func(ctx context.Context) error

+ type RPCLink interface

+ Close func(ctx context.Context) error

+ RPC func(ctx context.Context, msg *amqp.Message) (*RPCResponse, error)

+ type RPCResponse struct

+ Code int

+ Description string

+ Message *amqp.Message

Aug 9, 2022

Changes in this version

type AMQPReceiver

+ Credits func() uint32

+ type AMQPReceiverWrapper struct

+ func (rw *AMQPReceiverWrapper) AcceptMessage(ctx context.Context, msg *amqp.Message) error

+ func (rw *AMQPReceiverWrapper) Close(ctx context.Context) error

+ func (rw *AMQPReceiverWrapper) Credits() uint32

+ func (rw *AMQPReceiverWrapper) IssueCredit(credit uint32) error

+ func (rw *AMQPReceiverWrapper) LinkName() string

+ func (rw *AMQPReceiverWrapper) LinkSourceFilterValue(name string) interface{}

+ func (rw *AMQPReceiverWrapper) ModifyMessage(ctx context.Context, msg *amqp.Message, options *amqp.ModifyMessageOptions) error

+ func (rw *AMQPReceiverWrapper) Prefetched() *amqp.Message

+ func (rw *AMQPReceiverWrapper) Receive(ctx context.Context) (*amqp.Message, error)

+ func (rw *AMQPReceiverWrapper) RejectMessage(ctx context.Context, msg *amqp.Message, e *amqp.Error) error

+ func (rw *AMQPReceiverWrapper) ReleaseMessage(ctx context.Context, msg *amqp.Message) error

Jun 7, 2022

Changes in this version

type AMQPSender

+ LinkName func() string

May 12, 2022

Changes in this version

type AMQPSessionWrapper

+ Inner *amqp.Session

Apr 6, 2022

Changes in this version

+ type AMQPClient interface

+ Close func() error

+ NewSession func(opts ...amqp.SessionOption) (AMQPSession, error)

+ type AMQPClientWrapper struct

+ Inner *amqp.Client

+ func (w *AMQPClientWrapper) Close() error

+ func (w *AMQPClientWrapper) NewSession(opts ...amqp.SessionOption) (AMQPSession, error)

+ type AMQPReceiver interface

+ AcceptMessage func(ctx context.Context, msg *amqp.Message) error

+ DrainCredit func(ctx context.Context) error

+ IssueCredit func(credit uint32) error

+ LinkName func() string

+ LinkSourceFilterValue func(name string) interface{}

+ ModifyMessage func(ctx context.Context, msg *amqp.Message, deliveryFailed, undeliverableHere bool, ...) error

+ Prefetched func(ctx context.Context) (*amqp.Message, error)

+ Receive func(ctx context.Context) (*amqp.Message, error)

+ RejectMessage func(ctx context.Context, msg *amqp.Message, e *amqp.Error) error

+ ReleaseMessage func(ctx context.Context, msg *amqp.Message) error

+ type AMQPReceiverCloser interface

+ Close func(ctx context.Context) error

+ type AMQPSender interface

+ MaxMessageSize func() uint64

+ Send func(ctx context.Context, msg *amqp.Message) error

+ type AMQPSenderCloser interface

+ Close func(ctx context.Context) error

+ type AMQPSession interface

+ Close func(ctx context.Context) error

+ NewReceiver func(opts ...amqp.LinkOption) (AMQPReceiverCloser, error)

+ NewSender func(opts ...amqp.LinkOption) (AMQPSenderCloser, error)

+ type AMQPSessionWrapper struct

+ func (w *AMQPSessionWrapper) Close(ctx context.Context) error

+ func (w *AMQPSessionWrapper) NewReceiver(opts ...amqp.LinkOption) (AMQPReceiverCloser, error)

+ func (w *AMQPSessionWrapper) NewSender(opts ...amqp.LinkOption) (AMQPSenderCloser, error)