SqsUtils
Namespace: MBrace.AWS.Runtime.Utilities
Nested types and modules
Type | Description |
SqsDequeueMessage |
Type extensions
Type extension | Description |
CreateQueueWithName(queueName)
Signature: queueName:string -> Async<string>
|
CompiledName: |
DeleteBatch(messages)
Signature: messages:seq<SqsDequeueMessage> -> Async<unit>
|
CompiledName: |
DeleteQueueUri(queueUri)
Signature: queueUri:string -> Async<unit>
|
CompiledName: |
DequeueAll(...)
Signature: (queueUri:string * messageAttributes:'a option * visibilityTimeout:int option) -> Async<SqsDequeueMessage []>
Type parameters: 'a |
CompiledName: |
DequeueBatch(...)
Signature: (queueUri:string * messageAttributes:'a option * visibilityTimeout:int option * maxReceiveCount:int option) -> Async<SqsDequeueMessage []>
Type parameters: 'a |
CompiledName: |
Enqueue(queueUri, msgBody, ?attributes)
Signature: (queueUri:string * msgBody:string * attributes:'a option) -> Async<unit>
Type parameters: 'a |
CompiledName: |
EnqueueBatch(queueUri, messages)
Signature: (queueUri:string * messages:seq<string * 'a option>) -> Async<unit>
Type parameters: 'a |
CompiledName: |
EnsureQueueNameExists(queueName)
Signature: queueName:string -> Async<bool * string>
|
CompiledName: |
GetMessageCount(queueUri)
Signature: queueUri:string -> Async<int>
|
CompiledName: |
GetQueueUris(?prefix)
Signature: (prefix:string option) -> Async<List<string>>
|
CompiledName: |
QueueNameExists(queueName)
Signature: queueName:string -> Async<bool>
|
CompiledName: |
TryDequeue(...)
Signature: (queueUri:string * messageAttributes:'a option * visibilityTimeout:int option * timeoutMilliseconds:int option) -> Async<SqsDequeueMessage option>
Type parameters: 'a |
CompiledName: |
TryGetQueueUri(queueName)
Signature: queueName:string -> Async<string option>
|
CompiledName: |
Active patterns
Active pattern | Description |
( |QueueNotFoundException|_| ) e
Signature: e:Exception -> unit option
|
CompiledName: |