MBrace.Core


CloudQueue<'T>

Namespace: MBrace.Core

Distributed Queue abstraction

Instance members

Instance memberDescription
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: get_Id

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.

Fork me on GitHub