java/perftests/example/perftests.js

/*
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 */
var jsonObject = {
    _tests:[]
};

jsonObject._tests= jsonObject._tests.concat(
    QPID.transform(
    {
      "_name": "Multiple clients: 1 consumer - 1 producer - PERSISTENT - message size=1024",
      "_queues":[
        {
          "_name": "direct://amq.direct//varying-consumers?durable='true'",
          "_durable": true,
          "_attributes":
            {
              "x-qpid-capacity": 10485760,
              "x-qpid-flow-resume-capacity": 8388608
            }
        }
      ],
      "_clients":[
        {
          "_name": "producingClient",
          "_connections":[
            {
              "_name": "connection__INDEX_",
              "_factory": "connectionfactory",
              "_sessions": [
                {
                  "_sessionName": "session__INDEX_",
                  "_acknowledgeMode": 1,
                  "_producers": [
                    {
                      "_name": "Producer__INDEX_",
                      "_destinationName": "direct://amq.direct//varying-consumers?durable='true'",
                      "_maximumDuration": 60000,
                      "_deliveryMode": 2,
                      "_messageSize": 1024
                    }
                  ]
                }
              ]
            }
          ]
        },
        {
          "_name": "consumingClient",
          "_connections":[
            {
              "_name": "connection__INDEX_",
              "_factory": "connectionfactory",
              "_sessions": [
                {
                  "_sessionName": "session__INDEX_",
                  "_acknowledgeMode": 1,
                  "_consumers": [
                    {
                      "_name": "Consumer__INDEX_",
                      "_destinationName": "direct://amq.direct//varying-consumers?durable='true'",
                      "_maximumDuration": 60000
                    }
                  ]
                }
              ]
            }
          ]
        }
      ]
    },
    function(json)
    {
        var producerNumbers = [1, 2, 5, 10];
        var consumerNumbers = [1, 2, 5, 10];
        var results = [];
        for( var i =0; i < producerNumbers.length; i++)
        {
            for( var j = 0; j < consumerNumbers.length; j++)
            {
                var test = QPID.cloneJSON(json);
                test._name = "Multiple clients: " + consumerNumbers[j] + " consumer - " + producerNumbers[i] + " producer";
                results.push(test);
                test._clients[0]._connections = QPID.times(producerNumbers[i], test._clients[0]._connections[0], "__INDEX_")
                test._clients[1]._connections = QPID.times(consumerNumbers[j], test._clients[1]._connections[0], "__INDEX_")
                for (var k =0; k< consumerNumbers[j]; k++)
                {
                    test._clients[1]._connections[k]._sessions[0]._consumers[0]._name = "consumer_" + k;
                    test._clients[1]._connections[k]._sessions[0]._sessionName = "session_" + k;
                    test._clients[1]._connections[k]._name = "connection_" + k;
                    test._clients[1]._connections[k]._sessions[0]._consumers[0]._maximumDuration = 30000;
                }
                for (var k =0; k< producerNumbers[i]; k++)
                {
                    test._clients[0]._connections[k]._sessions[0]._producers[0]._name = "producer_" + k;
                    test._clients[0]._connections[k]._sessions[0]._sessionName = "session_" + k;
                    test._clients[0]._connections[k]._name = "connection_" + k;
                    test._clients[0]._connections[k]._sessions[0]._producers[0]._maximumDuration= 30000;
                    test._queues[0]._attributes["x-qpid-capacity"] = Math.round(10485760/producerNumbers[i]);
                    test._queues[0]._attributes["x-qpid-flow-resume-capacity"] = Math.round(8388608/producerNumbers[i]);
                }
            }
        }
        return results;
    }
    )
);