The highest tagged major version is
Documentation
¶
Index ¶
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
type Handler ¶
type Handler interface {
Do(ctx context.Context, orig Handler, message *servicebus.Message) Handler
}
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 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 retrying the processing of the message. This happens in memory and does not impact servicebus message max retry limit
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
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