AsMessageSliceIterator wraps a slice of Message pointers to allow it to be made into a MessageIterator.
IsErrNotFound returns true if the error argument is an ErrNotFound type.
NamespaceWithAzureEnvironment sets the namespace's Environment, Suffix and ResourceURI parameters according to the Azure Environment defined in "github.com/Azure/go-autorest/autorest/azure" package.
NamespaceWithConnectionString configures a namespace with the information provided in a Service Bus connection string.
NamespaceWithEnvironmentBinding configures a namespace using the environment details.
NamespaceWithTLSConfig appends to the TLS config.
NamespaceWithTokenProvider sets the token provider on the namespace.
NamespaceWithUserAgent appends to the root user-agent value.
NamespaceWithWebSocket configures the namespace and all entities to use wss:// rather than amqps://.
NewDeadLetter constructs an instance of DeadLetter which represents a dead letter queue in Azure Service Bus.
NewMessage builds an Message from a slice of data.
NewMessageBatch builds a new message batch with a default standard max message size.
NewMessageBatchIterator wraps a slice of Message pointers to allow it to be made into a MessageIterator.
NewMessageFromString builds an Message from a string message.
NewNamespace creates a new namespace configured through NamespaceOption(s).
NewQueueSession creates a new session sender and receiver to communicate with a Service Bus queue.
NewSessionHandler is a type converter that allows three funcs to be tied together into a type that fulfills the SessionHandler interface.
NewSubscriptionSession creates a new session receiver to receive from a Service Bus subscription.
NewTopicSession creates a new session receiver to receive from a Service Bus topic.
NewTransferDeadLetter constructs an instance of DeadLetter which represents a transfer dead letter queue in Azure Service Bus.
PeekFromSequenceNumber adds a filter to the Peek operation, so that no messages with a Sequence Number less than 'seq' are returned.
PeekWithPageSize adjusts how many messages are fetched at once while peeking from the server.
QueueEntityWithAutoDeleteOnIdle configures the queue to automatically delete after the specified idle interval.
QueueEntityWithAutoForward configures the queue to automatically forward messages to the specified target.
QueueEntityWithDeadLetteringOnMessageExpiration will ensure the queue sends expired messages to the dead letter queue.
QueueEntityWithDuplicateDetection configures the queue to detect duplicates for a given time window.
QueueEntityWithForwardDeadLetteredMessagesTo configures the queue to automatically forward dead letter messages to the specified target.
QueueEntityWithLockDuration configures the queue to have a duration of a peek-lock; that is, the amount of time that the message is locked for other receivers.
QueueEntityWithMaxDeliveryCount configures the queue to have a maximum number of delivery attempts before dead-lettering the message.
QueueEntityWithMaxSizeInMegabytes configures the maximum size of the queue in megabytes (1 * 1024 - 5 * 1024), which is the size of the memory allocated for the queue.
QueueEntityWithMessageTimeToLive configures the queue to set a time to live on messages.
QueueEntityWithPartitioning ensure the created queue will be a partitioned queue.
QueueEntityWithRequiredSessions will ensure the queue requires senders and receivers to have sessionIDs.
QueueWithPrefetchCount configures the queue to attempt to fetch the number of messages specified by the prefetch count at one time.
QueueWithReceiveAndDelete configures a queue to pop and delete messages off of the queue upon receiving the message.
ReceiverWithPrefetchCount configures the receiver to attempt to fetch the number of messages specified by the prefect at one time.
ReceiverWithReceiveMode configures a Receiver to use the specified receive mode.
ReceiverWithSession configures a Receiver to use a session.
SenderWithSession configures the message to send with a specific session and sequence.
SubscriptionWithAutoDeleteOnIdle configures the subscription to automatically delete after the specified idle interval.
SubscriptionWithAutoForward configures the queue to automatically forward messages to the specified entity path
The ability to AutoForward to a target requires the connection have management authorization.
SubscriptionWithBatchedOperations configures the subscription to batch server-side operations.
SubscriptionWithDeadLetteringOnMessageExpiration will ensure the Subscription sends expired messages to the dead letter queue.
SubscriptionWithDefaultRuleDescription configures the subscription to set a default rule.
SubscriptionWithForwardDeadLetteredMessagesTo configures the queue to automatically forward dead letter messages to the specified target entity.
SubscriptionWithLockDuration configures the subscription to have a duration of a peek-lock; that is, the amount of time that the message is locked for other receivers.
SubscriptionWithMessageTimeToLive configures the subscription to set a time to live on messages.
SubscriptionWithPrefetchCount configures the subscription to attempt to fetch the number of messages specified by the prefetch count at one time.
SubscriptionWithReceiveAndDelete configures a subscription to pop and delete messages off of the queue upon receiving the message.
SubscriptionWithRequiredSessions will ensure the subscription requires senders and receivers to have sessionIDs.
TopicWithAutoDeleteOnIdle configures the topic to automatically delete after the specified idle interval.
TopicWithBatchedOperations configures the topic to batch server-side operations.
TopicWithDuplicateDetection configures the topic to detect duplicates for a given time window.
TopicWithExpress configures the topic to hold a message in memory temporarily before writing it to persistent storage.
TopicWithMaxSizeInMegabytes configures the maximum size of the topic in megabytes (1 * 1024 - 5 * 1024), which is the size of the memory allocated for the topic.
TopicWithMessageTimeToLive configures the topic to set a time to live on messages.
TopicWithOrdering configures the topic to support ordering of messages.
TopicWithPartitioning configures the topic to be partitioned across multiple message brokers.
TraceReqAndResponseMiddleware will print the dump of the management request and response.