Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AmqpMessage ¶
AmqpMessage Wrapper for amqp
func (*AmqpMessage) Accept ¶
func (m *AmqpMessage) Accept() error
Accept mark the message as processed successfully (don't re-queue)
func (*AmqpMessage) DeliveryCount ¶
func (m *AmqpMessage) DeliveryCount() int
DeliveryCount get number of times the message has ben delivered
func (*AmqpMessage) EventData ¶
func (m *AmqpMessage) EventData() (common.Event, error)
EventData deserialize json value to type
func (*AmqpMessage) Reject ¶
func (m *AmqpMessage) Reject() error
Reject mark message to be requeued
type Message ¶
type Message interface { ID() string DeliveryCount() int Body() []byte Accept() error Reject() error EventData() (common.Event, error) }
Message interface for any message protocol to use
func NewAmqpMessageWrapper ¶
NewAmqpMessageWrapper get number of times the message has ben delivered
Click to show internal directories.
Click to hide internal directories.