Cloud for AWS protocol

VuGen's Cloud for AWS protocol is used to create Vuser scripts that monitor the usage of Amazon Web Services Simple Queue Service (SQS).

In this topic:

About SQS

Amazon SQS is an AWS service that enables application components to communicate in the cloud, using a fully-managed message queueing service. The distributed messaging system allows the decoupling of producers and consumers.

There can be multiple end-to-end producers and consumers, and messages can be redundantly replicated on multiple servers. All message sending and receiving is highly configurable.

The basic flow for an SQS message is as follows:

For more information on working with SQS, see the SQS documentation on the Amazon website.

Back to top

Cloud for AWS protocol for SQS

VuGen's Cloud for AWS protocol enables you to write scripts to monitor and load test an SQS-based system. When the Cloud for AWS script is run in LoadRunner Controller, it can collect specific metrics regarding the exchange of messages, both sent and received.

The Cloud for AWS protocol supports scripting in Java, using standard Java conventions. All standard Java methods are available, plus a set of SQS-specific APIs.

VuGen uses its own classes to represent the SQS classes. The main class that interacts with the queue is LrSqsClient. The LrSqsClient acts as producer and consumer, and also has some utility functions.

There are multiple auxiliary classes in addition to the SQS client, and SQS specific objects. For details on the SQS classes and functions, see Cloud for AWS functions in the Function Reference (select the relevant version).

Back to top

SQS queue types

The Cloud for AWS protocol supports both types of SQS queues: standard (default) and FIFO (first-in, first-out). These queues have the following attributes:

Back to top

Key queue identifiers

The following describes some of the key identifiers used by VuGen with the Cloud for AWS protocol SQS APIs.

Visibility timeout

When a consumer polls SQS for new messages (ReceiveMessage request), a message is selected from the queue and returned to the consumer. However, the message is not automatically deleted from the queue. While the message is being processed by the consumer, to prevent other consumers from processing the message again, SQS sets a visibility timeout.

During the visibility timeout, the message is exclusively visible to the consumer. The consumer must call DeleteMessage within the visibility timeout period, to signal it has finished processing. The message is then removed from the queue and no other consumer will see it. If the visibility timeout expires before the consumer deletes the message, the message becomes visible to other consumers for receiving.

The default visibility timeout is 30 seconds. You can modify this for a message if, for example, you think it needs more processing time.

While the visibility timeout is still in effect, the handling of ReceiveMessage requests from other consumers is as follows:

• Standard queue: Consumers receive another available message (no guarantee of ordering).

• FIFO queue: Consumers receive a message from another message group. If the only messages are within the same message group, they are blocked to guarantee ordering.

  Note: SQS does not enable you to select the message group from which to receive the message. To receive from a specific group, you have to filter manually.

Back to top

Create and edit scripts

You can create Cloud for AWS SQS scripts using the VuGen editor and script designer.

Before creating a script, do the following:

• Set up your Java environment. For details, see Set up the environment for Java protocols.

• Initialize the SQS client and close the client, using VuGen's Cloud for AWS APIs.

• When the Region option Use Unicode UTF-8 for worldwide language support is enabled in Windows, the JDK version used for replaying, recording, or generating a Cloud for AWS script must be compatible with the UTF-8 option.

To generate the script:

1. In VuGen, open a Cloud for AWS script.
2. In the toolbar, click Design Script (Ctrl+R) to open the Script Designer wizard.
3. In the Initialize section, select a region, provide a URL, and indicate whether the queue uses FIFO mode. Click Save. The wizard adds the Initialize step to the list of Action Items in the right pane.

4. Select actions from the Menu and fill in the relevant details. Hover over a field to see a description for it displayed at the bottom of the pane.

   In the Attributes sections, you can click + to add new attributes as relevant.

   

5. Click Save to add the code to the script. The wizard adds the steps to the Action Items list.

6. Add transactions and think time using the built-in actions pane.

7. Check the order of the actions in the Action Items list. Drag the actions to change their location in the list. Double-click on an action to edit its contents.

   

8. Click Generate. VuGen shows the script in the Editor window.

9. Optionally copy additional custom Java code snippets into the script, into the relevant methods. Add all initializations in the init method and closures in the end method. For details, see Script classes and methods.

   Note: A Cloud for AWS script runs as a scalable multi-threaded application. Make sure that any code you include is thread-safe. For details, see Java protocol programming tips.

10. Enhance your script with rendezvous points, output messages, and other elements. For more information, see Enhance a Java script.

Back to top

Script classes and methods

When working with a Cloud for AWS script, you place all your code in the Actions class that is displayed when you open the script in VuGen. The Actions class contains three methods: init, action, and end.

The following table shows what to include in each method and when each method is executed:

Example script:

import lrapi.lr;
import ot.protocols.lraws.*;
import ot.protocols.lraws.lrsqs.*;

public class Actions
{
    public int init() throws Throwable {
        LrSqsClient.initClient(LrAwsRegion.EU_CENTRAL_1, "your_queue_url_here");
        return 0;
    }//end of init

    public int action() throws Throwable {
        LrSqsClient.sendMessage("Hello, world!");
        LrSqsMessage m = LrSqsClient.receiveMessage();
        lr.log_message(m.body());
        LrSqsClient.deleteMessage(m);
        return 0;
    }//end of action

    public int end() throws Throwable {
        LrSqsClient.closeClient();
        return 0;
    }//end of end
}

Back to top

See also:

• Cloud for AWS monitoring
• Cloud for AWS functions
• Create and open Vuser scripts