Documentation ¶
Index ¶
- func DeduplicationFunction(dedup StringFromMessageFunc) broker.Option
- func GroupIDFunction(groupfunc StringFromMessageFunc) broker.Option
- func MaxReceiveMessages(max int64) broker.SubscribeOption
- func NewBroker(opts ...broker.Option) broker.Broker
- func VisibilityTimeout(seconds int64) broker.SubscribeOption
- func WaitTimeSeconds(seconds int64) broker.SubscribeOption
- type StringFromMessageFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DeduplicationFunction ¶
func DeduplicationFunction(dedup StringFromMessageFunc) broker.Option
DeduplicationFunction sets the function used to create the deduplication string for a given message
func GroupIDFunction ¶
func GroupIDFunction(groupfunc StringFromMessageFunc) broker.Option
GroupIDFunction sets the function used to create the group ID string for a given message
func MaxReceiveMessages ¶
func MaxReceiveMessages(max int64) broker.SubscribeOption
MaxReceiveMessages indicates how many messages a receive operation should pull during any single call
func VisibilityTimeout ¶
func VisibilityTimeout(seconds int64) broker.SubscribeOption
VisibilityTimeout controls how long a message is hidden from other queue consumers before being put back. If a consumer does not delete the message, it will be put back even if it was "processed"
func WaitTimeSeconds ¶
func WaitTimeSeconds(seconds int64) broker.SubscribeOption
WaitTimeSeconds controls the length of long polling for available messages
Types ¶
type StringFromMessageFunc ¶
Click to show internal directories.
Click to hide internal directories.