Azure Storage Queue Plugin
The plugin provides functionality to interact with Storage Queue
Installation
implementation(group: 'org.vividus', name: 'vividus-plugin-azure-storage-queue', version: '0.3.4')
Configuration
Queues configuration
Queues are configured with a set of properties with the following format:
azure.storage.queue.{queue-name}.{property-name}=property value
Where:
-
queue-name
- The name of the queue which will be used as a step parameter -
property-name
- The name of the queue property. One of:-
name
- The name of the queue -
sas-token
- The SAS token -
queue
- The queue endpoint
-
Steps
Peek messages
Peeks messages from the queue
When I peek up to `$count` messages from queue `$queueName` and save result to $scopes variable `$variableName`
-
$count
- The nember of messages to peek -
$queueName
- The name of the queue -
$variableName
- The variable name to store results in JSON format. If the variable name ismy-var
, the following variables will be created:-
${my-var[0].messageId}
- The message id -
${my-var[0].insertionTime}
- The message insertion time -
${my-var[0].expirationTime}
- The message expiration time -
${my-var[0].messageText}
- The message text
-
When I peek up to `5` messages from queue `users` and save result to scenario variable `messages`
Then `{"name" : "azure"}` is equal to `${messages[0].messageText}`
Send message
Sends message to the queue
When I send message `$message` to queue `$queueName` and save result to $scopes variable `$variableName`
-
$message
- The message to send -
$queueName
- The name of the queue -
$variableName
- The variable name to store results in JSON format. If the variable name ismy-var
, the following variables will be created:-
${my-var.messageId}
- The message id -
${my-var.insertionTime}
- The message insertion time -
${my-var.expirationTime}
- The message expiration time
-
When I send message `{
"id": "1807",
"eventType": "CreateUser",
"subject": "myapp/vehicles/motorcycles",
"eventTime": "2021-03-22T12:44:07+00:00",
"data": {
"make": "lada",
"model": "xray"
},
"dataVersion": "1.0"
}` to queue `users` and save result to scenario variable `result`