path: root/qpid/java/systests/src/main/java/org/apache/qpid/test/framework/MessagingTestConfigProperties.java

/*
 *
 * 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.
 *
 */
package org.apache.qpid.test.framework;

import org.apache.qpid.junit.extensions.util.ParsedProperties;

import javax.jms.Session;
import java.util.Properties;

/**
 * MessagingTestConfigProperties defines a set of property names and default values for specifying a messaging topology,
 * and test parameters for running a messaging test over that topology. A Properties object holding some of these
 * properties, superimposed onto the defaults, is used to establish test topologies and control test behaviour.
 *
 * <p/>A complete list of the parameters, default values and comments on their usage is provided here:
 *
 * <p/><table><caption>Parameters</caption>
 * <tr><th> Parameter        <th> Default  <th> Comments
 * <tr><td> messageSize      <td> 0        <td> Message size in bytes. Not including any headers.
 * <tr><td> destinationName  <td> ping     <td> The root name to use to generate destination names to ping.
 * <tr><td> persistent       <td> false    <td> Determines whether peristent delivery is used.
 * <tr><td> transacted       <td> false    <td> Determines whether messages are sent/received in transactions.
 * <tr><td> broker           <td> tcp://localhost:5672 <td> Determines the broker to connect to.
 * <tr><td> virtualHost      <td> test     <td> Determines the virtual host to send all ping over.
 * <tr><td> rate             <td> 0        <td> The maximum rate (in hertz) to send messages at. 0 means no limit.
 * <tr><td> verbose          <td> false    <td> The verbose flag for debugging. Prints to console on every message.
 * <tr><td> pubsub           <td> false    <td> Whether to ping topics or queues. Uses p2p by default.
 * <tr><td> username         <td> guest    <td> The username to access the broker with.
 * <tr><td> password         <td> guest    <td> The password to access the broker with.
 * <tr><td> selector         <td> null     <td> Not used. Defines a message selector to filter pings with.
 * <tr><td> destinationCount <td> 1        <td> The number of receivers listening to the pings.
 * <tr><td> timeout          <td> 30000    <td> In milliseconds. The timeout to stop waiting for replies.
 * <tr><td> commitBatchSize  <td> 1        <td> The number of messages per transaction in transactional mode.
 * <tr><td> uniqueDests      <td> true     <td> Whether each receivers only listens to one ping destination or all.
 * <tr><td> durableDests     <td> false    <td> Whether or not durable destinations are used.
 * <tr><td> ackMode          <td> AUTO_ACK <td> The message acknowledgement mode. Possible values are:
 *                                               0 - SESSION_TRANSACTED
 *                                               1 - AUTO_ACKNOWLEDGE
 *                                               2 - CLIENT_ACKNOWLEDGE
 *                                               3 - DUPS_OK_ACKNOWLEDGE
 *                                               257 - NO_ACKNOWLEDGE
 *                                               258 - PRE_ACKNOWLEDGE
 * <tr><td> maxPending       <td> 0        <td> The maximum size in bytes, of messages sent but not yet received.
 *                                              Limits the volume of messages currently buffered on the client
 *                                              or broker. Can help scale test clients by limiting amount of buffered
 *                                              data to avoid out of memory errors.
 * </table>
 *
 * <p><table id="crc"><caption>CRC Card</caption>
 * <tr><th> Responsibilities <th> Collaborations
 * <tr><td> Provide the names and defaults of all test parameters.
 * </table>
 *
 * @todo Put a type-safe wrapper around these properties, but continue to store the parameters as properties. This is
 *       simply to ensure that it is a simple matter to serialize/deserialize string/string pairs onto messages.
 */
public class MessagingTestConfigProperties extends ParsedProperties
{
    // ====================== Connection Properties ==================================

    /** Holds the name of the default connection configuration. */
    public static final String CONNECTION_NAME = "broker";

    /** Holds the name of the property to get the initial context factory name from. */
    public static final String INITIAL_CONTEXT_FACTORY_PROPNAME = "java.naming.factory.initial";

    /** Defines the class to use as the initial context factory by default. */
    public static final String INITIAL_CONTEXT_FACTORY_DEFAULT = "org.apache.qpid.jndi.PropertiesFileInitialContextFactory";

    /** Holds the name of the property to get the test broker url from. */
    public static final String BROKER_PROPNAME = "qpid.test.broker";

    /** Holds the default broker url for the test. */
    public static final String BROKER_DEFAULT = "vm://:1";

    /** Holds the name of the property to get the test broker virtual path. */
    public static final String VIRTUAL_HOST_PROPNAME = "virtualHost";

    /** Holds the default virtual path for the test. */
    public static final String VIRTUAL_HOST_DEFAULT = "test";

    /** Holds the name of the property to get the broker access username from. */
    public static final String USERNAME_PROPNAME = "username";

    /** Holds the default broker log on username. */
    public static final String USERNAME_DEFAULT = "guest";

    /** Holds the name of the property to get the broker access password from. */
    public static final String PASSWORD_PROPNAME = "password";

    /** Holds the default broker log on password. */
    public static final String PASSWORD_DEFAULT = "guest";

    // ====================== Messaging Topology Properties ==========================

    /** Holds the name of the property to get the bind publisher procuder flag from. */
    public static final String PUBLISHER_PRODUCER_BIND_PROPNAME = "publisherProducerBind";

    /** Holds the default value of the publisher producer flag. */
    public static final boolean PUBLISHER_PRODUCER_BIND_DEFAULT = true;

    /** Holds the name of the property to get the bind publisher procuder flag from. */
    public static final String PUBLISHER_CONSUMER_BIND_PROPNAME = "publisherConsumerBind";

    /** Holds the default value of the publisher consumer flag. */
    public static final boolean PUBLISHER_CONSUMER_BIND_DEFAULT = false;

    /** Holds the name of the property to get the bind receivers procuder flag from. */
    public static final String RECEIVER_PRODUCER_BIND_PROPNAME = "receiverProducerBind";

    /** Holds the default value of the receivers producer flag. */
    public static final boolean RECEIVER_PRODUCER_BIND_DEFAULT = false;

    /** Holds the name of the property to get the bind receivers procuder flag from. */
    public static final String RECEIVER_CONSUMER_BIND_PROPNAME = "receiverConsumerBind";

    /** Holds the default value of the receivers consumer flag. */
    public static final boolean RECEIVER_CONSUMER_BIND_DEFAULT = true;

    /** Holds the name of the property to get the publishers consumer active flag from. */
    public static final String PUBLISHER_CONSUMER_ACTIVE_PROPNAME = "publisherConsumerActive";

    /** Holds the default value of the publishers consumer active flag. */
    public static final boolean PUBLISHER_CONSUMER_ACTIVE_DEFAULT = true;

    /** Holds the name of the property to get the receivers consumer active flag from. */
    public static final String RECEIVER_CONSUMER_ACTIVE_PROPNAME = "receiverConsumerActive";

    /** Holds the default value of the receivers consumer active flag. */
    public static final boolean RECEIVER_CONSUMER_ACTIVE_DEFAULT = true;

    /** Holds the name of the property to get the destination name root from. */
    public static final String SEND_DESTINATION_NAME_ROOT_PROPNAME = "sendDestinationRoot";

    /** Holds the root of the name of the default destination to send to. */
    public static final String SEND_DESTINATION_NAME_ROOT_DEFAULT = "sendTo";

    /** Holds the name of the property to get the destination name root from. */
    public static final String RECEIVE_DESTINATION_NAME_ROOT_PROPNAME = "receiveDestinationRoot";

    /** Holds the root of the name of the default destination to send to. */
    public static final String RECEIVE_DESTINATION_NAME_ROOT_DEFAULT = "receiveFrom";

    /** Holds the name of the proeprty to get the destination count from. */
    public static final String DESTINATION_COUNT_PROPNAME = "destinationCount";

    /** Defines the default number of destinations to ping. */
    public static final int DESTINATION_COUNT_DEFAULT = 1;

    /** Holds the name of the property to get the p2p or pub/sub messaging mode from. */
    public static final String PUBSUB_PROPNAME = "pubsub";

    /** Holds the pub/sub mode default, true means ping a topic, false means ping a queue. */
    public static final boolean PUBSUB_DEFAULT = false;

    // ======================  JMS Options and Flags =================================

    /** Holds the name of the property to get the test delivery mode from. */
    public static final String PERSISTENT_MODE_PROPNAME = "persistent";

    /** Holds the message delivery mode to use for the test. */
    public static final boolean PERSISTENT_MODE_DEFAULT = false;

    /** Holds the name of the property to get the test transactional mode from. */
    public static final String TRANSACTED_PUBLISHER_PROPNAME = "transactedPublisher";

    /** Holds the transactional mode to use for the test. */
    public static final boolean TRANSACTED_PUBLISHER_DEFAULT = false;

    /** Holds the name of the property to get the test transactional mode from. */
    public static final String TRANSACTED_RECEIVER_PROPNAME = "transactedReceiver";

    /** Holds the transactional mode to use for the test. */
    public static final boolean TRANSACTED_RECEIVER_DEFAULT = false;

    /** Holds the name of the property to set the no local flag from. */
    public static final String NO_LOCAL_PROPNAME = "noLocal";

    /** Defines the default value of the no local flag to use when consuming messages. */
    public static final boolean NO_LOCAL_DEFAULT = false;

    /** Holds the name of the property to get the message acknowledgement mode from. */
    public static final String ACK_MODE_PROPNAME = "ackMode";

    /** Defines the default message acknowledgement mode. */
    public static final int ACK_MODE_DEFAULT = Session.AUTO_ACKNOWLEDGE;

    /** Holds the name of the property to get the durable subscriptions flag from, when doing pub/sub messaging. */
    public static final String DURABLE_SUBSCRIPTION_PROPNAME = "durableSubscription";

    /** Defines the default value of the durable subscriptions flag. */
    public static final boolean DURABLE_SUBSCRIPTION_DEFAULT = false;

    // ======================  Qpid/AMQP Options and Flags ================================

    /** Holds the name of the property to set the exclusive flag from. */
    public static final String EXCLUSIVE_PROPNAME = "exclusive";

    /** Defines the default value of the exclusive flag to use when consuming messages. */
    public static final boolean EXCLUSIVE_DEFAULT = false;

    /** Holds the name of the property to set the immediate flag from. */
    public static final String IMMEDIATE_PROPNAME = "immediate";

    /** Defines the default value of the immediate flag to use when sending messages. */
    public static final boolean IMMEDIATE_DEFAULT = false;

    /** Holds the name of the property to set the mandatory flag from. */
    public static final String MANDATORY_PROPNAME = "mandatory";

    /** Defines the default value of the mandatory flag to use when sending messages. */
    public static final boolean MANDATORY_DEFAULT = false;

    /** Holds the name of the property to get the durable destinations flag from. */
    public static final String DURABLE_DESTS_PROPNAME = "durableDests";

    /** Default value for the durable destinations flag. */
    public static final boolean DURABLE_DESTS_DEFAULT = false;

    /** Holds the name of the property to set the prefetch size from. */
    public static final String PREFETCH_PROPNAME = "prefetch";

    /** Defines the default prefetch size to use when consuming messages. */
    public static final int PREFETCH_DEFAULT = 100;

    // ======================  Common Test Parameters ================================

    /** Holds the name of the property to get the test message size from. */
    public static final String MESSAGE_SIZE_PROPNAME = "messageSize";

    /** Used to set up a default message size. */
    public static final int MESSAGE_SIZE_DEAFULT = 0;

    /** Holds the name of the property to get the message rate from. */
    public static final String RATE_PROPNAME = "rate";

    /** Defines the default rate (in pings per second) to send pings at. 0 means as fast as possible, no restriction. */
    public static final int RATE_DEFAULT = 0;

    /** Holds the name of the proeprty to get the. */
    public static final String SELECTOR_PROPNAME = "selector";

    /** Holds the default message selector. */
    public static final String SELECTOR_DEFAULT = "";

    /** Holds the name of the property to get the waiting timeout for response messages. */
    public static final String TIMEOUT_PROPNAME = "timeout";

    /** Default time to wait before assuming that a ping has timed out. */
    public static final long TIMEOUT_DEFAULT = 30000;

    /** Holds the name of the property to get the commit batch size from. */
    public static final String TX_BATCH_SIZE_PROPNAME = "commitBatchSize";

    /** Defines the default number of pings to send in each transaction when running transactionally. */
    public static final int TX_BATCH_SIZE_DEFAULT = 1;

    /** Holds the name of the property to set the maximum amount of pending message data for a producer to hold. */
    public static final String MAX_PENDING_PROPNAME = "maxPending";

    /** Defines the default maximum quantity of pending message data to allow producers to hold. */
    public static final int MAX_PENDING_DEFAULT = 0;

    /** Holds the name of the property to get the publisher rollback flag from. */
    public static final String ROLLBACK_PUBLISHER_PROPNAME = "rollbackPublisher";

    /** Holds the default publisher roll back setting. */
    public static final boolean ROLLBACK_PUBLISHER_DEFAULT = false;

    /** Holds the name of the property to get the publisher rollback flag from. */
    public static final String ROLLBACK_RECEIVER_PROPNAME = "rollbackReceiver";

    /** Holds the default publisher roll back setting. */
    public static final boolean ROLLBACK_RECEIVER_DEFAULT = false;

    // ====================== Options that control the bahviour of the test framework. =========================

    /** Holds the name of the property to get the behavioural mode of not applicable assertions. */
    public static final String NOT_APPLICABLE_ASSERTION_PROPNAME = "notApplicableAssertion";

    /** Holds the default behavioral mode of not applicable assertions, which is logging them as a warning. */
    public static final String NOT_APPLICABLE_ASSERTION_DEFAULT = "warn";

    /** Holds the name of the property to get the verbose mode proeprty from. */
    public static final String VERBOSE_PROPNAME = "verbose";

    /** Holds the default verbose mode. */
    public static final boolean VERBOSE_DEFAULT = false;

    /** Holds the default configuration properties. */
    public static ParsedProperties defaults = new ParsedProperties();

    static
    {
        defaults.setPropertyIfNull(INITIAL_CONTEXT_FACTORY_PROPNAME, INITIAL_CONTEXT_FACTORY_DEFAULT);
        defaults.setPropertyIfNull(BROKER_PROPNAME, BROKER_DEFAULT);
        defaults.setPropertyIfNull(VIRTUAL_HOST_PROPNAME, VIRTUAL_HOST_DEFAULT);
        defaults.setPropertyIfNull(USERNAME_PROPNAME, USERNAME_DEFAULT);
        defaults.setPropertyIfNull(PASSWORD_PROPNAME, PASSWORD_DEFAULT);

        defaults.setPropertyIfNull(PUBLISHER_PRODUCER_BIND_PROPNAME, PUBLISHER_PRODUCER_BIND_DEFAULT);
        defaults.setPropertyIfNull(PUBLISHER_CONSUMER_BIND_PROPNAME, PUBLISHER_CONSUMER_BIND_DEFAULT);
        defaults.setPropertyIfNull(RECEIVER_PRODUCER_BIND_PROPNAME, RECEIVER_PRODUCER_BIND_DEFAULT);
        defaults.setPropertyIfNull(RECEIVER_CONSUMER_BIND_PROPNAME, RECEIVER_CONSUMER_BIND_DEFAULT);
        defaults.setPropertyIfNull(PUBLISHER_CONSUMER_ACTIVE_PROPNAME, PUBLISHER_CONSUMER_ACTIVE_DEFAULT);
        defaults.setPropertyIfNull(RECEIVER_CONSUMER_ACTIVE_PROPNAME, RECEIVER_CONSUMER_ACTIVE_DEFAULT);
        defaults.setPropertyIfNull(SEND_DESTINATION_NAME_ROOT_PROPNAME, SEND_DESTINATION_NAME_ROOT_DEFAULT);
        defaults.setPropertyIfNull(RECEIVE_DESTINATION_NAME_ROOT_PROPNAME, RECEIVE_DESTINATION_NAME_ROOT_DEFAULT);
        defaults.setPropertyIfNull(DESTINATION_COUNT_PROPNAME, DESTINATION_COUNT_DEFAULT);
        defaults.setPropertyIfNull(PUBSUB_PROPNAME, PUBSUB_DEFAULT);

        defaults.setPropertyIfNull(PERSISTENT_MODE_PROPNAME, PERSISTENT_MODE_DEFAULT);
        defaults.setPropertyIfNull(TRANSACTED_PUBLISHER_PROPNAME, TRANSACTED_PUBLISHER_DEFAULT);
        defaults.setPropertyIfNull(TRANSACTED_RECEIVER_PROPNAME, TRANSACTED_RECEIVER_DEFAULT);
        defaults.setPropertyIfNull(NO_LOCAL_PROPNAME, NO_LOCAL_DEFAULT);
        defaults.setPropertyIfNull(ACK_MODE_PROPNAME, ACK_MODE_DEFAULT);
        defaults.setPropertyIfNull(DURABLE_SUBSCRIPTION_PROPNAME, DURABLE_SUBSCRIPTION_DEFAULT);

        defaults.setPropertyIfNull(EXCLUSIVE_PROPNAME, EXCLUSIVE_DEFAULT);
        defaults.setPropertyIfNull(IMMEDIATE_PROPNAME, IMMEDIATE_DEFAULT);
        defaults.setPropertyIfNull(MANDATORY_PROPNAME, MANDATORY_DEFAULT);
        defaults.setPropertyIfNull(DURABLE_DESTS_PROPNAME, DURABLE_DESTS_DEFAULT);
        defaults.setPropertyIfNull(PREFETCH_PROPNAME, PREFETCH_DEFAULT);

        defaults.setPropertyIfNull(MESSAGE_SIZE_PROPNAME, MESSAGE_SIZE_DEAFULT);
        defaults.setPropertyIfNull(RATE_PROPNAME, RATE_DEFAULT);
        defaults.setPropertyIfNull(SELECTOR_PROPNAME, SELECTOR_DEFAULT);
        defaults.setPropertyIfNull(TIMEOUT_PROPNAME, TIMEOUT_DEFAULT);
        defaults.setPropertyIfNull(TX_BATCH_SIZE_PROPNAME, TX_BATCH_SIZE_DEFAULT);
        defaults.setPropertyIfNull(MAX_PENDING_PROPNAME, MAX_PENDING_DEFAULT);
        defaults.setPropertyIfNull(ROLLBACK_PUBLISHER_PROPNAME, ROLLBACK_PUBLISHER_DEFAULT);
        defaults.setPropertyIfNull(ROLLBACK_RECEIVER_PROPNAME, ROLLBACK_RECEIVER_DEFAULT);

        defaults.setPropertyIfNull(NOT_APPLICABLE_ASSERTION_PROPNAME, NOT_APPLICABLE_ASSERTION_DEFAULT);
        defaults.setPropertyIfNull(VERBOSE_PROPNAME, VERBOSE_DEFAULT);
    }

    /**
     * Creates a test configuration based on the defaults.
     */
    public MessagingTestConfigProperties()
    {
        super(defaults);
    }

    /**
     * Creates a test configuration based on the supplied properties.
     *
     * @param properties The test configuration.
     */
    public MessagingTestConfigProperties(Properties properties)
    {
        super(properties);
    }

    /**
     * The size of test messages to send.
     *
     * @return The size of test messages to send.
     */
    public int getMessageSize()
    {
        return getPropertyAsInteger(MESSAGE_SIZE_PROPNAME);
    }

    /**
     * Flag to indicate that the publishing producer should be set up to publish to a destination.
     *
     * @return Flag to indicate that the publishing producer should be set up to publish to a destination.
     */
    public boolean getPublisherProducerBind()
    {
        return getPropertyAsBoolean(PUBLISHER_PRODUCER_BIND_PROPNAME);
    }

    /**
     * Flag to indicate that the publishing consumer should be set up to receive from a destination.
     *
     * @return Flag to indicate that the publishing consumer should be set up to receive from a destination.
     */
    public boolean getPublisherConsumerBind()
    {
        return getPropertyAsBoolean(PUBLISHER_CONSUMER_BIND_PROPNAME);
    }

    /**
     * Flag to indicate that the receiving producer should be set up to publish to a destination.
     *
     * @return Flag to indicate that the receiving producer should be set up to publish to a destination.
     */
    public boolean getReceiverProducerBind()
    {
        return getPropertyAsBoolean(RECEIVER_PRODUCER_BIND_PROPNAME);
    }

    /**
     * Flag to indicate that the receiving consumer should be set up to receive from a destination.
     *
     * @return Flag to indicate that the receiving consumer should be set up to receive from a destination.
     */
    public boolean getReceiverConsumerBind()
    {
        return getPropertyAsBoolean(RECEIVER_CONSUMER_BIND_PROPNAME);
    }

    /**
     * Flag to indicate that the publishing consumer should be created and actively listening.
     *
     * @return Flag to indicate that the publishing consumer should be created.
     */
    public boolean getPublisherConsumerActive()
    {
        return getPropertyAsBoolean(PUBLISHER_CONSUMER_ACTIVE_PROPNAME);
    }

    /**
     * Flag to indicate that the receiving consumers should be created and actively listening.
     *
     * @return Flag to indicate that the receiving consumers should be created and actively listening.
     */
    public boolean getReceiverConsumerActive()
    {
        return getPropertyAsBoolean(RECEIVER_CONSUMER_ACTIVE_PROPNAME);
    }

    /**
     * A root to create all test destination names from.
     *
     * @return A root to create all test destination names from.
     */
    public String getSendDestinationNameRoot()
    {
        return getProperty(SEND_DESTINATION_NAME_ROOT_PROPNAME);
    }

    /**
     * A root to create all receiving destination names from.
     *
     * @return A root to create all receiving destination names from.
     */
    public String getReceiveDestinationNameRoot()
    {
        return getProperty(RECEIVE_DESTINATION_NAME_ROOT_PROPNAME);
    }

    /**
     * Flag to indicate that persistent messages should be used.
     *
     * @return Flag to indicate that persistent messages should be used.
     */
    public boolean getPersistentMode()
    {
        return getPropertyAsBoolean(PERSISTENT_MODE_PROPNAME);
    }

    /**
     * Flag to indicate that transactional messages should be sent by the publisher.
     *
     * @return Flag to indicate that transactional messages should be sent by the publisher.
     */
    public boolean getPublisherTransacted()
    {
        return getPropertyAsBoolean(TRANSACTED_PUBLISHER_PROPNAME);
    }

    /**
     * Flag to indicate that transactional receives should be used by the receiver.
     *
     * @return Flag to indicate that transactional receives should be used by the receiver.
     */
    public boolean getReceiverTransacted()
    {
        return getPropertyAsBoolean(TRANSACTED_PUBLISHER_PROPNAME);
    }

    /**
     * The name of the virtual host to run all tests over.
     *
     * @return The name of the virtual host to run all tests over.
     */
    public String getVirtualHost()
    {
        return getProperty(VIRTUAL_HOST_PROPNAME);
    }

    /**
     * Limiting rate for each sender in messages per second, or zero for unlimited.
     *
     * @return Limiting rate for each sender in messages per second, or zero for unlimited.
     */
    public String getRate()
    {
        return getProperty(RATE_PROPNAME);
    }

    /**
     * Flag to indicate that test messages should be received publish/subscribe style by all receivers.
     *
     * @return Flag to indicate that test messages should be received publish/subscribe style by all receivers.
     */
    public boolean getPubsub()
    {
        return getPropertyAsBoolean(PUBSUB_PROPNAME);
    }

    /**
     * The username credentials to run tests with.
     *
     * @return The username credentials to run tests with.
     */
    public String getUsername()
    {
        return getProperty(USERNAME_PROPNAME);
    }

    /**
     * The password credentials to run tests with.
     *
     * @return The password credentials to run tests with.
     */
    public String getPassword()
    {
        return getProperty(PASSWORD_PROPNAME);
    }

    /**
     * The timeout duration to fail tests on, should they receive no messages within it.
     *
     * @return The timeout duration to fail tests on, should they receive no messages within it.
     */
    public long getTimeout()
    {
        return getPropertyAsLong(TIMEOUT_PROPNAME);
    }

    /**
     * The number of messages to batch into each transaction in transational tests.
     *
     * @return The number of messages to batch into each transaction in transational tests.
     */
    public int getTxBatchSize()
    {
        return getPropertyAsInteger(TX_BATCH_SIZE_PROPNAME);
    }

    /**
     * Flag to indicate that tests should use durable destinations.
     *
     * @return Flag to indicate that tests should use durable destinations.
     */
    public boolean getDurableDests()
    {
        return getPropertyAsBoolean(DURABLE_DESTS_PROPNAME);
    }

    /**
     * The ack mode for message receivers to use.
     *
     * @return The ack mode for message receivers to use.
     */
    public int getAckMode()
    {
        return getPropertyAsInteger(ACK_MODE_PROPNAME);
    }

    /**
     * Flag to indicate that tests should use durable subscriptions.
     *
     * @return Flag to indicate that tests should use durable subscriptions.
     */
    public boolean getDurableSubscription()
    {
        return getPropertyAsBoolean(DURABLE_SUBSCRIPTION_PROPNAME);
    }

    /**
     * The maximum amount of in-flight data, in bytes, that tests should send at any time.
     *
     * @return The maximum amount of in-flight data, in bytes, that tests should send at any time.
     */
    public int getMaxPending()
    {
        return getPropertyAsInteger(MAX_PENDING_PROPNAME);
    }

    /**
     * The size of the prefetch queue to use.
     *
     * @return The size of the prefetch queue to use.
     */
    public int getPrefetch()
    {
        return getPropertyAsInteger(PREFETCH_PROPNAME);
    }

    /**
     * Flag to indicate that subscriptions should be no-local.
     *
     * @return Flag to indicate that subscriptions should be no-local.
     */
    public boolean getNoLocal()
    {
        return getPropertyAsBoolean(NO_LOCAL_PROPNAME);
    }

    /**
     * Flag to indicate that subscriptions should be exclusive.
     *
     * @return Flag to indicate that subscriptions should be exclusive.
     */
    public boolean getExclusive()
    {
        return getPropertyAsBoolean(EXCLUSIVE_PROPNAME);
    }

    /**
     * Flag to indicate that messages must be delivered immediately.
     *
     * @return Flag to indicate that messages must be delivered immediately.
     */
    public boolean getImmediate()
    {
        return getPropertyAsBoolean(IMMEDIATE_PROPNAME);
    }

    /**
     * Flag to indicate that messages must be routable.
     *
     * @return Flag to indicate that messages must be routable.
     */
    public boolean getMandatory()
    {
        return getPropertyAsBoolean(MANDATORY_PROPNAME);
    }

    /**
     * Gets the value of a flag to indicate that the publisher should rollback all messages sent.
     *
     * @return A flag to indicate that the publisher should rollback all messages sent.
     */
    public boolean getRollbackPublisher()
    {
        return getPropertyAsBoolean(ROLLBACK_PUBLISHER_PROPNAME);
    }

    /**
     * Gets the value of a flag to indicate that the receiver should rollback all messages received, then receive them
     * again.
     *
     * @return A flag to indicate that the publisher should rollback all messages received.
     */
    public boolean getRollbackReceiver()
    {
        return getPropertyAsBoolean(ROLLBACK_RECEIVER_PROPNAME);
    }

    /**
     * Gets the behavioural mode of not applicable assertions. Should be one of 'quiet', 'warn' or 'fail'.
     *
     * @return The behavioural mode of not applicable assertions.
     */
    public String getNotApplicableAssertionMode()
    {
        return getProperty(NOT_APPLICABLE_ASSERTION_PROPNAME);
    }
}