host:5672
Determines the broker to connect to. | | virtualHost | test | Determines the virtual host to send all ping over. |
| rate | 0 | The maximum rate (in hertz) to send messages at. 0 means no limit. |
| verbose | false | The verbose flag for debugging. Prints to console on every message. |
| pubsub | false | Whether to ping topics or queues. Uses p2p by default. |
| username | guest | The username to access the broker with. |
| password | guest | The password to access the broker with. |
| selector | null | Not used. Defines a message selector to filter pings with. |
| destinationCount | 1 | The number of receivers listening to the pings. |
| timeout | 30000 | In milliseconds. The timeout to stop waiting for replies. |
| commitBatchSize | 1 | The number of messages per transaction in transactional mode. |
| uniqueDests | true | Whether each receivers only listens to one ping destination or all. |
| durableDests | false | Whether or not durable destinations are used. |
| ackMode | AUTO_ACK | 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 |
| maxPending | 0 | 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. CRC Card | Responsibilities | Collaborations |
|---|
| Provide the names and defaults of all test parameters. |
@todo Put a type-safe wrapper around these properties, but continue to store the parameters as properties. This issimply to ensure that it is a simple matter to serialize/deserialize string/string pairs onto messages.
| * Sends a message on the test circuit. The exact nature of the message sent is controlled by the test parameters.
*/
protected void send()
{
// Cast the test properties into a typed interface for convenience.
MessagingTestConfigProperties props = new MessagingTestConfigProperties(testProps);
boolean transactional = props.getPublisherTransacted();
boolean rollback = props.getRollbackPublisher();
// Send a message through the publisher and log any exceptions raised.
try
{
CircuitEnd end = getLocalPublisherCircuitEnd();
|
| * @throws JMSException Any JMSException occurring during creation of the message is allowed to fall through.
*/
private Message createTestMessage(CircuitEnd client) throws JMSException
{
// Cast the test properties into a typed interface for convenience.
MessagingTestConfigProperties props = new MessagingTestConfigProperties(testProps);
return TestUtils.createTestMessageOfSize(client.getSession(), props.getMessageSize());
}
|
Related Classes of org.apache.qpid.test.framework.MessagingTestConfigProperties
Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.
|