CloudQueue<'T>
Namespace: MBrace.Core
Distributed Queue abstraction
Instance members
| Instance member | Description |
DequeueAsync(timeout)
Signature: (timeout:int option) -> Async<'T>
Modifiers: abstract |
Asynchronously dequeues a message from the queue. |
DequeueBatchAsync(maxItems)
Signature: maxItems:int -> Async<'T []>
Modifiers: abstract |
Asynchronously dequeues a batch of messages from the queue. Will dequeue up to the given maximum number of items, depending on current availability. |
EnqueueAsync(message)
Signature: message:'T -> Async<unit>
Modifiers: abstract |
Asynchronously enqueues a message to the start of the queue. |
EnqueueBatchAsync(messages)
Signature: messages:seq<'T> -> Async<unit>
Modifiers: abstract |
Enqueues a batch of messages to the start of the queue. |
GetCountAsync()
Signature: unit -> Async<int64>
Modifiers: abstract |
Asynchronously gets the current message count of the queue |
Id
Signature: string
Modifiers: abstract |
Queue identifier CompiledName: |
TryDequeueAsync()
Signature: unit -> Async<'T option>
Modifiers: abstract |
Asynchronously attempts to dequeue a message from the queue. Returns None instantly if no message is currently available. |
