org.apache.qpid.ping
Class PingSendOnlyClient

java.lang.Object
  extended by org.apache.qpid.requestreply.PingPongProducer
      extended by org.apache.qpid.ping.PingDurableClient
          extended by org.apache.qpid.ping.PingSendOnlyClient
All Implemented Interfaces:
Runnable, ExceptionListener

public class PingSendOnlyClient
extends PingDurableClient

CRC Card
Responsibilities Collaborations


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.requestreply.PingPongProducer
PingPongProducer.ChainedMessageListener, PingPongProducer.PerCorrelationId
 
Field Summary
 
Fields inherited from class org.apache.qpid.ping.PingDurableClient
DURATION_DEFAULT, DURATION_PROPNAME, NUM_MESSAGES_DEFAULT, NUM_MESSAGES_PROPNAME, NUM_MESSAGES_TO_ACTION_DEFAULT, NUM_MESSAGES_TO_ACTION_PROPNAME
 
Fields inherited from class org.apache.qpid.requestreply.PingPongProducer
_ackMode, _brokerDetails, _chainedMessageListener, _connection, _consAckMode, _consTransacted, _consumer, _consumerConnection, _consumerSession, _destinationName, _factoryName, _failAfterCommit, _failAfterSend, _failBeforeCommit, _failBeforeSend, _failOnce, _fileProperties, _isDurable, _isPubSub, _isUnique, _maxPendingSize, _messageSize, _noOfConsumers, _noOfDestinations, _overrideClientId, _password, _persistent, _pingDestinations, _producer, _producerSession, _publish, _queueJVMSequenceID, _queueNamePostfix, _queueSharedID, _rate, _rateLimiter, _replyDestination, _selector, _transacted, _txBatchSize, _username, _verbose, _virtualpath, ACK_MODE_DEFAULT, ACK_MODE_PROPNAME, BROKER_DEFAULT, BROKER_PROPNAME, CONSUME_ONLY_DEFAULT, CONSUME_ONLY_PROPNAME, CONSUMER_ACK_MODE_DEFAULT, CONSUMER_ACK_MODE_PROPNAME, CONSUMER_TRANSACTED_DEFAULT, CONSUMER_TRANSACTED_PROPNAME, defaults, DELAY_BEFORE_CONSUME, DELAY_BEFORE_CONSUME_PROPNAME, DESTINATION_COUNT_DEFAULT, DESTINATION_COUNT_PROPNAME, DURABLE_DESTS_DEFAULT, DURABLE_DESTS_PROPNAME, EXCLUSIVE_DEFAULT, FACTORY_NAME_DEAFULT, FACTORY_NAME_PROPNAME, FAIL_AFTER_COMMIT_DEFAULT, FAIL_AFTER_COMMIT_PROPNAME, FAIL_AFTER_SEND_DEFAULT, FAIL_AFTER_SEND_PROPNAME, FAIL_BEFORE_COMMIT_DEFAULT, FAIL_BEFORE_COMMIT_PROPNAME, FAIL_BEFORE_SEND_DEFAULT, FAIL_BEFORE_SEND_PROPNAME, FAIL_ONCE_DEFAULT, FAIL_ONCE_PROPNAME, FILE_PROPERTIES_DEAFULT, FILE_PROPERTIES_PROPNAME, MAX_PENDING_DEFAULT, MAX_PENDING_PROPNAME, MESSAGE_SIZE_DEAFULT, MESSAGE_SIZE_PROPNAME, MESSAGE_TIMESTAMP_PROPNAME, NO_LOCAL_DEFAULT, NUM_CONSUMERS_DEFAULT, NUM_CONSUMERS_PROPNAME, OVERRIDE_CLIENT_ID_DEAFULT, OVERRIDE_CLIENT_ID_PROPNAME, PASSWORD_DEFAULT, PASSWORD_PROPNAME, PERSISTENT_MODE_DEFAULT, PERSISTENT_MODE_PROPNAME, PING_QUEUE_NAME_DEFAULT, PING_QUEUE_NAME_PROPNAME, PREFETCH_DEFAULT, PREFILL_DEFAULT, PREFILL_PROPNAME, PUBSUB_DEFAULT, PUBSUB_PROPNAME, QUEUE_NAME_POSTFIX_DEFAULT, QUEUE_NAME_POSTFIX_PROPNAME, RATE_DEFAULT, RATE_PROPNAME, SELECTOR_DEFAULT, SELECTOR_PROPNAME, SEND_ONLY_DEFAULT, SEND_ONLY_PROPNAME, TIMEOUT_DEFAULT, TIMEOUT_PROPNAME, timestampFormatter, TRANSACTED_DEFAULT, TRANSACTED_PROPNAME, TX_BATCH_SIZE_DEFAULT, TX_BATCH_SIZE_PROPNAME, UNIQUE_DESTS_DEFAULT, UNIQUE_DESTS_PROPNAME, USERNAME_DEFAULT, USERNAME_PROPNAME, VERBOSE_DEFAULT, VERBOSE_PROPNAME, VIRTUAL_HOST_DEFAULT, VIRTUAL_HOST_PROPNAME
 
Constructor Summary
PingSendOnlyClient(Properties overrides)
           
 
Method Summary
 Message getTestMessage(Destination replyQueue, int messageSize, boolean persistent)
          Generates a test message of the specified size, with the specified reply-to destination and persistence flag.
static void main(String[] args)
          Starts the ping/wait/receive process.
 
Methods inherited from class org.apache.qpid.ping.PingDurableClient
closeConnection, getReplyDestinations, getShutdownHook, receive, send, takeAction
 
Methods inherited from class org.apache.qpid.requestreply.PingPongProducer
close, commitTx, createConnection, createPingDestinations, createProducer, createReplyConsumers, establishConnection, getConsumersPerDestination, getExpectedNumPings, getTimestamp, onException, onMessageWithConsumerNo, pause, pingAndWaitForReply, pingAndWaitForReply, pingLoop, pingNoWaitForReply, removeChainedMessageListener, run, sendMessage, setChainedMessageListener, setTimestamp, setupCorrelationID, start, stop, waitForUser
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface javax.jms.ExceptionListener
onException
 

Constructor Detail

PingSendOnlyClient

public PingSendOnlyClient(Properties overrides)
                   throws Exception
Throws:
Exception
Method Detail

main

public static void main(String[] args)
Starts the ping/wait/receive process.

Parameters:
args - The command line arguments.

getTestMessage

public Message getTestMessage(Destination replyQueue,
                              int messageSize,
                              boolean persistent)
                       throws JMSException
Description copied from class: PingPongProducer
Generates a test message of the specified size, with the specified reply-to destination and persistence flag.

Overrides:
getTestMessage in class PingPongProducer
Parameters:
replyQueue - The reply-to destination for the message.
messageSize - The desired size of the message in bytes.
persistent - true if the message should use persistent delivery, false otherwise.
Returns:
A freshly generated test message.
Throws:
JMSException - All underlying JMSException are allowed to fall through.


Licensed to the Apache Software Foundation