Documentation
¶
Index ¶
- func IsDone(handler Handler) bool
- func IsError(h Handler) bool
- type HandleFunc
- type Handler
- type Message
- func (m *Message) Abandon() Handler
- func (m *Message) Complete() Handler
- func (m *Message) Data() string
- func (m *Message) Error(err error) Handler
- func (m *Message) Message() *servicebus.Message
- func (m *Message) RetryLater(retryAfter time.Duration) Handler
- func (m *Message) Type() string
- func (m *Message) Unmarshal(data []byte, v interface{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type HandleFunc ¶
HandleFunc is a func to handle the message received from a subscription
func (HandleFunc) Do ¶
func (h HandleFunc) Do(ctx context.Context, _ Handler, msg *servicebus.Message) Handler
Do wraps a service message and returns a handlers
type Handler ¶
type Handler interface {
Do(ctx context.Context, orig Handler, message *servicebus.Message) Handler
}
Handler is the interface to handle messages
func Abandon ¶
func Abandon() Handler
Abandon stops processing the message and releases the lock on it.
func Complete ¶
func Complete() Handler
Complete will notify Azure Service Bus that the message was successfully handled and should be deleted from the queue
func DeadLetter ¶
DeadLetter will notify Azure Service Bus that the message will be sent to the deadletter queue
func Error ¶
Error is a wrapper around Abandon() that allows to trace the error before abandoning the message
func RetryLater ¶
RetryLater waits for the given duration before abandoning the lock. Consider examining/increasing your LockDuration/MaxDeliveryCount before using. Undefined behavior if RetryLater is passed a duration that puts the message handling past the lock duration (which has a max of 5 minutes)
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message is the wrapping type of service bus message with a type
func New ¶
func New(msg *servicebus.Message) (*Message, error)
New creates a message, validating type first
func (*Message) Abandon ¶
Abandon will notify Azure Service Bus the message failed but should be re-queued for delivery.
func (*Message) Complete ¶
Complete will notify Azure Service Bus that the message was successfully handled and should be deleted from the queue
func (*Message) Data ¶
Data returns the message data as a string. Can be unmarshalled to the original struct
func (*Message) Error ¶
Error is a wrapper around Abandon() that allows to trace the error before abandoning the message
func (*Message) Message ¶
func (m *Message) Message() *servicebus.Message
Message returns the message as received by the SDK
func (*Message) RetryLater ¶
RetryLater waits for the given duration before retrying the processing of the message. This happens in memory and does not impact servicebus message max retry limit
Source Files