A B C D E F G I J L M N O P Q R S T U V W _

A

AbstractConfig - Class in org.apache.qpid.config
 
AbstractConfig() - Constructor for class org.apache.qpid.config.AbstractConfig
 
ACK_MODE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default message acknowledgement mode.
ACK_MODE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the proeprty to get the message acknowledgement mode from.
AMQConnectionFactoryInitialiser - Class in org.apache.qpid.config
 
AMQConnectionFactoryInitialiser() - Constructor for class org.apache.qpid.config.AMQConnectionFactoryInitialiser
 
avg(long[], long, long) - Static method in class org.apache.qpid.oldtopic.Publisher
 
avg(long[], long, long) - Static method in class org.apache.qpid.topic.Publisher
 

B

BROKER_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default broker url for the test.
BROKER_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the test broker url from.
bytesReceived(long) - Method in class org.apache.qpid.requestreply.PingPongBouncer.FailoverNotifier
 
bytesSent(long) - Method in class org.apache.qpid.requestreply.PingPongBouncer.FailoverNotifier
 

C

close() - Method in class org.apache.qpid.requestreply.PingPongProducer
Closes all of the producer and consumer connections.
closeConnection() - Method in class org.apache.qpid.ping.PingDurableClient
 
commitTx(Session) - Method in class org.apache.qpid.requestreply.PingPongBouncer
Convenience method to commit the transaction on the specified controlSession.
commitTx(Session) - Method in class org.apache.qpid.requestreply.PingPongProducer
Convenience method to commit the transaction on the specified controlSession.
Config - Class in org.apache.qpid.oldtopic
 
Config() - Constructor for class org.apache.qpid.oldtopic.Config
 
Config - Class in org.apache.qpid.topic
 
Config() - Constructor for class org.apache.qpid.topic.Config
 
ConnectionFactoryInitialiser - Interface in org.apache.qpid.config
 
Connector - Class in org.apache.qpid.config
 
Connector() - Constructor for class org.apache.qpid.config.Connector
 
ConnectorConfig - Interface in org.apache.qpid.config
 
CONSUME_ONLY_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value of the consumeOnly flag to use when publishing messages is not desired.
CONSUME_ONLY_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get when no messasges should be sent.
CONSUMER_ACK_MODE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default consumers message acknowledgement mode.
CONSUMER_ACK_MODE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the consumers message acknowledgement mode from.
CONSUMER_TRANSACTED_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the consumer transactional mode default setting.
CONSUMER_TRANSACTED_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the test consumer transacted mode from.
CONTROL_TOPIC - Static variable in class org.apache.qpid.topic.Listener
 
createConnection(ConnectorConfig) - Method in class org.apache.qpid.config.Connector
 
createConnection() - Method in class org.apache.qpid.oldtopic.Config
 
createConnection(String) - Method in class org.apache.qpid.requestreply.PingPongProducer
Establishes a connection to the broker, based on the configuration parameters that this ping client was created with.
createConnection() - Method in class org.apache.qpid.topic.Config
 
createControlConsumer() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createControlConsumer() - Method in class org.apache.qpid.topic.MessageFactory
 
createControlPublisher() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createControlPublisher() - Method in class org.apache.qpid.topic.Listener
 
createControlPublisher() - Method in class org.apache.qpid.topic.MessageFactory
 
createDurableTopicConsumer(String) - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createDurableTopicConsumer(String) - Method in class org.apache.qpid.topic.Listener
 
createDurableTopicConsumer(String) - Method in class org.apache.qpid.topic.MessageFactory
 
createEventMessage() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createEventMessage() - Method in class org.apache.qpid.topic.MessageFactory
 
createMessagePayload(int) - Static method in class org.apache.qpid.client.message.TestMessageFactory
 
createPingDestinations(int, String, String, boolean, boolean) - Method in class org.apache.qpid.requestreply.PingPongProducer
Creates consumers for the specified number of destinations.
createProducer() - Method in class org.apache.qpid.requestreply.PingPongProducer
Creates the producer to send the pings on.
createReplyConsumers(Collection<Destination>, String) - Method in class org.apache.qpid.requestreply.PingPongProducer
Creates consumers for the specified destinations and registers this pinger to listen to their messages.
createReportRequestMessage() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createReportRequestMessage() - Method in class org.apache.qpid.topic.MessageFactory
 
createReportResponseMessage(String) - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createReportResponseMessage(String) - Method in class org.apache.qpid.topic.Listener
 
createReportResponseMessage(String) - Method in class org.apache.qpid.topic.MessageFactory
 
createShutdownMessage() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createShutdownMessage() - Method in class org.apache.qpid.topic.MessageFactory
 
createTopicConsumer() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createTopicConsumer() - Method in class org.apache.qpid.topic.Listener
 
createTopicConsumer() - Method in class org.apache.qpid.topic.MessageFactory
 
createTopicPublisher() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
createTopicPublisher() - Method in class org.apache.qpid.topic.MessageFactory
 

D

DEFAULT_TEST_RESULTS_BATCH_SIZE - Static variable in class org.apache.qpid.ping.PingLatencyTestPerf
Holds the default test results logging batch size.
defaults - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default configuration properties.
DELAY_BEFORE_CONSUME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value for delay in ms to wait before starting thet test run.
DELAY_BEFORE_CONSUME_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the delay to wait in ms before starting the main test after having prefilled.
DESTINATION_COUNT_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default number of destinations to ping.
DESTINATION_COUNT_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the destination count from.
doFailover(String) - Method in class org.apache.qpid.requestreply.PingPongBouncer
Prompts the user to terminate the named broker, in order to test failover functionality.
doFailover() - Method in class org.apache.qpid.requestreply.PingPongBouncer
Prompts the user to terminate the broker, in order to test failover functionality.
DURABLE_DESTS_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value of the durable destinations flag.
DURABLE_DESTS_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the durable destinations flag from.
DURATION_DEFAULT - Static variable in class org.apache.qpid.ping.PingDurableClient
 
DURATION_PROPNAME - Static variable in class org.apache.qpid.ping.PingDurableClient
 

E

establishConnection(boolean, boolean) - Method in class org.apache.qpid.requestreply.PingPongProducer
Establishes a connection to the broker and creates message consumers and producers based on the parameters that this ping client was created with.
EXCLUSIVE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value of the exclusive flag to use when consuming messages.

F

FACTORY_NAME_DEAFULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default JNDI name of the connection factory.
FACTORY_NAME_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to define the JNDI factory name with.
FAIL_AFTER_COMMIT_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default failover after commit test flag.
FAIL_AFTER_COMMIT_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the fail after commit flag from.
FAIL_AFTER_SEND_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default failover after send test flag.
FAIL_AFTER_SEND_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the proeprty to get the fail after send flag from.
FAIL_BEFORE_COMMIT_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default failover before commit test flag.
FAIL_BEFORE_COMMIT_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the proeprty to get the fail before commit flag from.
FAIL_BEFORE_SEND_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default failover before send test flag.
FAIL_BEFORE_SEND_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the fail before send flag from.
FAIL_ONCE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
The default failover once flag, true means only do one failover, false means failover on every commit cycle.
FAIL_ONCE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the fail once flag from.
failoverComplete() - Method in class org.apache.qpid.requestreply.PingPongBouncer.FailoverNotifier
 
FILE_PROPERTIES_DEAFULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default file name of the JNDI initial context properties.
FILE_PROPERTIES_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to set the JNDI initial context properties with.

G

getAckMode() - Method in class org.apache.qpid.oldtopic.Config
 
getAckMode() - Method in class org.apache.qpid.topic.Config
 
getAckModeDescription(int) - Static method in class org.apache.qpid.oldtopic.Config
 
getAckModeDescription(int) - Static method in class org.apache.qpid.topic.Config
 
getBatch() - Method in class org.apache.qpid.oldtopic.Config
 
getBatch() - Method in class org.apache.qpid.topic.Config
 
getBatchSize() - Method in class org.apache.qpid.topic.Config
 
getClientCount() - Method in class org.apache.qpid.ping.PingClient
 
getClientId() - Method in class org.apache.qpid.oldtopic.Config
 
getClientId() - Method in class org.apache.qpid.topic.Config
 
getClients() - Method in class org.apache.qpid.oldtopic.Config
 
getClients() - Method in class org.apache.qpid.topic.Config
 
getConnection() - Method in class org.apache.qpid.requestreply.PingPongBouncer
Gets the underlying connection that this ping client is running on.
getConnectionFactory(ConnectorConfig) - Method in class org.apache.qpid.config.Connector
 
getConsumersPerDestination() - Method in class org.apache.qpid.ping.PingClient
Supplies the multiplier for the number of ping clients that will hear each ping when doing pub/sub pinging.
getConsumersPerDestination() - Method in class org.apache.qpid.requestreply.PingPongProducer
Gets the number of consumers that are listening to each destination in the test.
getDelay() - Method in class org.apache.qpid.oldtopic.Config
 
getDelay() - Method in class org.apache.qpid.topic.Config
 
getDestination() - Method in class org.apache.qpid.topic.Config
 
getDestinationsCount() - Method in class org.apache.qpid.topic.Config
 
getExpectedNumPings(int) - Method in class org.apache.qpid.requestreply.PingPongProducer
Calculates how many pings are expected to be received for the given number sent.
getFactory(ConnectorConfig) - Method in class org.apache.qpid.config.AMQConnectionFactoryInitialiser
 
getFactory(ConnectorConfig) - Method in interface org.apache.qpid.config.ConnectionFactoryInitialiser
 
getFactory() - Method in interface org.apache.qpid.config.ConnectorConfig
 
getFactory(ConnectorConfig) - Method in class org.apache.qpid.config.JBossConnectionFactoryInitialiser
 
getFactory() - Method in class org.apache.qpid.oldtopic.Config
 
getFactory() - Method in class org.apache.qpid.topic.Config
 
getHost() - Method in interface org.apache.qpid.config.ConnectorConfig
 
getHost() - Method in class org.apache.qpid.oldtopic.Config
 
getHost() - Method in class org.apache.qpid.topic.Config
 
getMessages() - Method in class org.apache.qpid.oldtopic.Config
 
getMessages() - Method in class org.apache.qpid.topic.Config
 
getPayload() - Method in class org.apache.qpid.oldtopic.Config
 
getPayload() - Method in class org.apache.qpid.topic.Config
 
getPort() - Method in interface org.apache.qpid.config.ConnectorConfig
 
getPort() - Method in class org.apache.qpid.oldtopic.Config
 
getPort() - Method in class org.apache.qpid.topic.Config
 
getRate() - Method in class org.apache.qpid.topic.Config
 
getReplyDestinations() - Method in class org.apache.qpid.ping.PingClient
Returns the ping destinations themselves as the reply destinations for this pinger to listen to.
getReplyDestinations() - Method in class org.apache.qpid.ping.PingDurableClient
Returns the ping destinations themselves as the reply destinations for this pinger to listen to.
getReplyDestinations() - Method in class org.apache.qpid.requestreply.PingPongProducer
Gets all the reply destinations (to listen for replies on).
getReport(Message) - Method in class org.apache.qpid.oldtopic.MessageFactory
 
getReport(Message) - Method in class org.apache.qpid.topic.MessageFactory
 
getSelector() - Method in class org.apache.qpid.topic.Config
 
getShutdownHook() - Method in class org.apache.qpid.ping.PingDurableClient
Gets a shutdown hook that will cleanly shut this down when it is running the ping loop.
getShutdownHook() - Method in class org.apache.qpid.requestreply.PingPongProducer
Gets a shutdown hook that will cleanly shut this down when it is running the ping loop.
getSubscriptionId() - Method in class org.apache.qpid.oldtopic.Config
 
getSubscriptionId() - Method in class org.apache.qpid.topic.Config
 
getTestCaseNameForTestMethod(String) - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Should provide a translation from the junit method name of a test to its test case name as known to the test clients that will run the test.
getTestMessage(Destination, int, boolean) - Method in class org.apache.qpid.ping.PingSendOnlyClient
 
getTestMessage(Destination, int, boolean) - Method in class org.apache.qpid.requestreply.PingPongProducer
Generates a test message of the specified size, with the specified reply-to destination and persistence flag.
getTimeout() - Method in class org.apache.qpid.topic.Config
 
getTimestamp(Message) - Method in class org.apache.qpid.requestreply.PingPongProducer
Extracts the nanosecond timestamp from a message.
getTimingController() - Method in class org.apache.qpid.ping.PingAsyncTestPerf
Gets the timing controller passed in by the test runner.
getTimingController() - Method in class org.apache.qpid.ping.PingLatencyTestPerf
Gets the timing controller passed in by the test runner.
getTopic() - Method in class org.apache.qpid.oldtopic.MessageFactory
 
getTopic() - Method in class org.apache.qpid.topic.MessageFactory
 
getWarmup() - Method in class org.apache.qpid.oldtopic.Config
 
getWarmup() - Method in class org.apache.qpid.topic.Config
 

I

isPubSub() - Method in class org.apache.qpid.requestreply.PingPongBouncer
Checks whether this client is a p2p or pub/sub ping client.
isPubSub() - Method in class org.apache.qpid.topic.Config
 
isReport(Message) - Method in class org.apache.qpid.oldtopic.MessageFactory
 
isReport(Message) - Method in class org.apache.qpid.topic.Listener
 
isReport(Message) - Method in class org.apache.qpid.topic.MessageFactory
 
isShutdown(Message) - Method in class org.apache.qpid.oldtopic.MessageFactory
 
isShutdown(Message) - Method in class org.apache.qpid.topic.Listener
 
isShutdown(Message) - Method in class org.apache.qpid.topic.MessageFactory
 
isTransacted() - Method in class org.apache.qpid.topic.Config
 

J

JBossConnectionFactoryInitialiser - Class in org.apache.qpid.config
 
JBossConnectionFactoryInitialiser() - Constructor for class org.apache.qpid.config.JBossConnectionFactoryInitialiser
 

L

Listener - Class in org.apache.qpid.oldtopic
 
Listener(Connection, int) - Constructor for class org.apache.qpid.oldtopic.Listener
 
Listener(Connection, int, String) - Constructor for class org.apache.qpid.oldtopic.Listener
 
Listener - Class in org.apache.qpid.topic
This class has not kept up to date with the topic_listener in the cpp tests.
Listener(Connection, int, String) - Constructor for class org.apache.qpid.topic.Listener
 

M

main(String[]) - Static method in class org.apache.qpid.oldtopic.Listener
 
main(String[]) - Static method in class org.apache.qpid.oldtopic.Publisher
 
main(String[]) - Static method in class org.apache.qpid.ping.PingDurableClient
Starts the ping/wait/receive process.
main(String[]) - Static method in class org.apache.qpid.ping.PingSendOnlyClient
Starts the ping/wait/receive process.
main(String[]) - Static method in class org.apache.qpid.requestreply.PingPongBouncer
Starts a stand alone ping-pong client running in verbose mode.
main(String[]) - Static method in class org.apache.qpid.requestreply.PingPongProducer
Starts a ping-pong loop running from the command line.
main(String[]) - Static method in class org.apache.qpid.topic.Listener
 
main(String[]) - Static method in class org.apache.qpid.topic.Publisher
 
max(long[]) - Static method in class org.apache.qpid.oldtopic.Publisher
 
max(long[]) - Static method in class org.apache.qpid.topic.Publisher
 
MAX_PENDING_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value for the maximum pending message size setting.
MAX_PENDING_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the maximum pending message size setting from.
MESSAGE_SIZE_DEAFULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Used to set up a default message size.
MESSAGE_SIZE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the test message size from.
MESSAGE_TIMESTAMP_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to store nanosecond timestamps in ping messages with.
MessageFactory - Class in org.apache.qpid.oldtopic
 
MessageFactory(Session) - Constructor for class org.apache.qpid.oldtopic.MessageFactory
 
MessageFactory(Session, int) - Constructor for class org.apache.qpid.oldtopic.MessageFactory
 
MessageFactory - Class in org.apache.qpid.topic
 
MessageFactory(Session) - Constructor for class org.apache.qpid.topic.MessageFactory
 
MessageFactory(Session, int) - Constructor for class org.apache.qpid.topic.MessageFactory
 
MessageThroughputPerf - Class in org.apache.qpid.test.testcases
MessageThroughputPerf runs a test over a Circuit controlled by the test parameters.
MessageThroughputPerf(String) - Constructor for class org.apache.qpid.test.testcases.MessageThroughputPerf
Creates a new test case with the specified name.
MessageThroughputPerf.PerThreadSetup - Class in org.apache.qpid.test.testcases
Holds the per-thread test configurations.
MessageThroughputPerf.PerThreadSetup() - Constructor for class org.apache.qpid.test.testcases.MessageThroughputPerf.PerThreadSetup
 
min(long[]) - Static method in class org.apache.qpid.oldtopic.Publisher
 
min(long[]) - Static method in class org.apache.qpid.topic.Publisher
 

N

newBytesMessage(Session, int) - Static method in class org.apache.qpid.client.message.TestMessageFactory
 
newJMSTextMessage(Session, int, String) - Static method in class org.apache.qpid.client.message.TestMessageFactory
 
newObjectMessage(Session, int) - Static method in class org.apache.qpid.client.message.TestMessageFactory
 
newObjectMessage(Session, Destination, int, boolean) - Static method in class org.apache.qpid.client.message.TestMessageFactory
Creates an ObjectMessage with given size and sets the JMS properties (JMSReplyTo and DeliveryMode)
newStreamMessage(Session, int) - Static method in class org.apache.qpid.client.message.TestMessageFactory
 
newTextMessage(Session, int) - Static method in class org.apache.qpid.client.message.TestMessageFactory
 
NO_LOCAL_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value of the no local flag to use when consuming messages.
NUM_CONSUMERS_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default number consumers per destination.
NUM_CONSUMERS_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the number of consumers per destination from.
NUM_MESSAGES_DEFAULT - Static variable in class org.apache.qpid.ping.PingDurableClient
 
NUM_MESSAGES_PROPNAME - Static variable in class org.apache.qpid.ping.PingDurableClient
 
NUM_MESSAGES_TO_ACTION_DEFAULT - Static variable in class org.apache.qpid.ping.PingDurableClient
 
NUM_MESSAGES_TO_ACTION_PROPNAME - Static variable in class org.apache.qpid.ping.PingDurableClient
 

O

onException(JMSException) - Method in class org.apache.qpid.requestreply.PingPongProducer
Callback method, implementing ExceptionListener.
onMessage(Message) - Method in class org.apache.qpid.oldtopic.Listener
 
onMessage(Message) - Method in class org.apache.qpid.oldtopic.Publisher
 
onMessage(Message) - Method in class org.apache.qpid.requestreply.PingPongBouncer
This is a callback method that is notified of all messages for which this has been registered as a message listener on a message consumer.
onMessage(Message, int, long) - Method in interface org.apache.qpid.requestreply.PingPongProducer.ChainedMessageListener
Notifies interested listeners about message arrival and important test stats, the number of messages remaining in the test, and the messages send timestamp.
onMessage(Message) - Method in class org.apache.qpid.topic.Listener
 
onMessage(Message) - Method in class org.apache.qpid.topic.Publisher
 
onMessageWithConsumerNo(Message, int) - Method in class org.apache.qpid.requestreply.PingPongProducer
Stores the received message in the replies map, then resets the boolean latch that a thread waiting for a correlating reply may be waiting on.
org.apache.qpid.client.message - package org.apache.qpid.client.message
 
org.apache.qpid.config - package org.apache.qpid.config
 
org.apache.qpid.oldtopic - package org.apache.qpid.oldtopic
 
org.apache.qpid.ping - package org.apache.qpid.ping
 
org.apache.qpid.requestreply - package org.apache.qpid.requestreply
 
org.apache.qpid.test.testcases - package org.apache.qpid.test.testcases
 
org.apache.qpid.topic - package org.apache.qpid.topic
 
OVERRIDE_CLIENT_ID_DEAFULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default value of the override client id flag.
OVERRIDE_CLIENT_ID_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to determine whether of not client id is overridden at connection time.

P

parseInt(String, String) - Method in class org.apache.qpid.config.AbstractConfig
 
parseLong(String, String) - Method in class org.apache.qpid.config.AbstractConfig
 
PASSWORD_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default broker log on password.
PASSWORD_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the broker access password from.
pause(long) - Static method in class org.apache.qpid.requestreply.PingPongProducer
Convenience method for a short pause.
PERSISTENT_MODE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the message delivery mode to use for the test.
PERSISTENT_MODE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the test delivery mode from.
PING_QUEUE_NAME_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the default destination to send pings on.
PING_QUEUE_NAME_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the ping queue name from.
pingAndWaitForReply(Message, int, long, String) - Method in class org.apache.qpid.requestreply.PingPongProducer
Sends the specified number of ping message and then waits for all correlating replies.
pingAndWaitForReply(Message, int, int, long, String) - Method in class org.apache.qpid.requestreply.PingPongProducer
 
PingAsyncTestPerf - Class in org.apache.qpid.ping
PingAsyncTestPerf is a performance test that outputs multiple timings from its test method, using the timing controller interface supplied by the test runner from a seperate listener thread.
PingAsyncTestPerf(String) - Constructor for class org.apache.qpid.ping.PingAsyncTestPerf
Creates a new asynchronous ping performance test with the specified name.
PingClient - Class in org.apache.qpid.ping
PingClient is a PingPongProducer that does not need a PingPongBouncer to send replies to its pings.
PingClient(Properties) - Constructor for class org.apache.qpid.ping.PingClient
Creates a ping producer with the specified parameters, of which there are many.
PingDurableClient - Class in org.apache.qpid.ping
PingDurableClient is a variation of the PingPongProducer ping tool.
PingDurableClient(Properties) - Constructor for class org.apache.qpid.ping.PingDurableClient
 
PingLatencyTestPerf - Class in org.apache.qpid.ping
PingLatencyTestPerf is a performance test that outputs multiple timings from its test method, using the timing controller interface supplied by the test runner from a seperate listener thread.
PingLatencyTestPerf(String) - Constructor for class org.apache.qpid.ping.PingLatencyTestPerf
Creates a new asynchronous ping performance test with the specified name.
pingLoop() - Method in class org.apache.qpid.requestreply.PingPongProducer
Implements a single iteration of the ping loop.
pingNoWaitForReply(Message, int, String) - Method in class org.apache.qpid.requestreply.PingPongProducer
Sends the specified number of ping messages and does not wait for correlating replies.
PingPongBouncer - Class in org.apache.qpid.requestreply
PingPongBouncer is a message listener the bounces back messages to their reply to destination.
PingPongBouncer(String, String, String, String, String, boolean, boolean, String, boolean, boolean) - Constructor for class org.apache.qpid.requestreply.PingPongBouncer
Creates a PingPongBouncer on the specified producer and consumer sessions.
PingPongBouncer.FailoverNotifier - Class in org.apache.qpid.requestreply
A connection listener that logs out any failover complete events.
PingPongBouncer.FailoverNotifier() - Constructor for class org.apache.qpid.requestreply.PingPongBouncer.FailoverNotifier
 
PingPongProducer - Class in org.apache.qpid.requestreply
PingPongProducer is a client that sends test messages, and waits for replies to these messages.
PingPongProducer(Properties) - Constructor for class org.apache.qpid.requestreply.PingPongProducer
Creates a ping producer with the specified parameters, of which there are many.
PingPongProducer.ChainedMessageListener - Interface in org.apache.qpid.requestreply
Defines a chained message listener interface that can be attached to this pinger.
PingPongProducer.PerCorrelationId - Class in org.apache.qpid.requestreply
Holds information on each correlation id.
PingPongProducer.PerCorrelationId() - Constructor for class org.apache.qpid.requestreply.PingPongProducer.PerCorrelationId
 
PingPongTestPerf - Class in org.apache.qpid.requestreply
PingPongTestPerf is a full round trip ping test, that has been written with the intention of being scaled up to run many times simultaneously to simluate many clients/producer/connections.
PingPongTestPerf(String) - Constructor for class org.apache.qpid.requestreply.PingPongTestPerf
 
PingPongTestPerf.PerThreadSetup - Class in org.apache.qpid.requestreply
 
PingPongTestPerf.PerThreadSetup() - Constructor for class org.apache.qpid.requestreply.PingPongTestPerf.PerThreadSetup
 
PingSendOnlyClient - Class in org.apache.qpid.ping
Responsibilities Collaborations
PingSendOnlyClient(Properties) - Constructor for class org.apache.qpid.ping.PingSendOnlyClient
 
PingTestPerf - Class in org.apache.qpid.ping
PingTestPerf is a ping test, that has been written with the intention of being scaled up to run many times simultaneously to simluate many clients/producers/connections.
PingTestPerf(String) - Constructor for class org.apache.qpid.ping.PingTestPerf
 
PingTestPerf.PerThreadSetup - Class in org.apache.qpid.ping
 
PingTestPerf.PerThreadSetup() - Constructor for class org.apache.qpid.ping.PingTestPerf.PerThreadSetup
 
postThreadSetUp() - Method in class org.apache.qpid.ping.PingTestPerf
Called after all threads have completed their setup.
postThreadSetUp() - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Called after all threads have completed their setup.
preFailover(boolean) - Method in class org.apache.qpid.requestreply.PingPongBouncer.FailoverNotifier
 
PREFETCH_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default prefetch size to use when consuming messages.
PREFILL_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value for the number of messages to prefill.
PREFILL_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the number of message to prefill the broker with before starting the main test.
preResubscribe() - Method in class org.apache.qpid.requestreply.PingPongBouncer.FailoverNotifier
 
Publisher - Class in org.apache.qpid.oldtopic
 
Publisher(Connection, int, int, boolean) - Constructor for class org.apache.qpid.oldtopic.Publisher
 
Publisher - Class in org.apache.qpid.topic
 
Publisher(Connection, int, int, boolean) - Constructor for class org.apache.qpid.topic.Publisher
 
PUBSUB_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the pub/sub mode default, true means ping a topic, false means ping a queue.
PUBSUB_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the p2p or pub/sub messaging mode from.

Q

QUEUE_NAME_POSTFIX_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default queue name postfix value.
QUEUE_NAME_POSTFIX_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the queue name postfix from.

R

RATE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default rate (in pings per second) to send pings at.
RATE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the message rate from.
receive(int) - Method in class org.apache.qpid.ping.PingDurableClient
 
removeChainedMessageListener() - Method in class org.apache.qpid.requestreply.PingPongProducer
Removes any chained message listeners from this pinger.
RESPONSE_QUEUE - Static variable in class org.apache.qpid.topic.Listener
 
run() - Method in class org.apache.qpid.requestreply.PingPongProducer
Implements a ping loop that repeatedly pings until the publish flag becomes false.

S

SELECTOR_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default message selector.
SELECTOR_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the proeprty to get the.
send() - Method in class org.apache.qpid.ping.PingDurableClient
Performs the main test procedure implemented by this ping client.
SEND_ONLY_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value of the consumeOnly flag to use when publishing messages is not desired.
SEND_ONLY_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get when no messasges should be sent.
sendMessage(int, Message) - Method in class org.apache.qpid.requestreply.PingPongProducer
Sends the sepcified message, applies rate limiting and possibly commits the current transaction.
setBatch(int) - Method in class org.apache.qpid.oldtopic.Config
 
setBatch(int) - Method in class org.apache.qpid.topic.Config
 
setChainedMessageListener(PingPongProducer.ChainedMessageListener) - Method in class org.apache.qpid.requestreply.PingPongProducer
Sets a chained message listener.
setClients(int) - Method in class org.apache.qpid.oldtopic.Config
 
setClients(int) - Method in class org.apache.qpid.topic.Config
 
setConnection(AMQConnection) - Method in class org.apache.qpid.requestreply.PingPongBouncer
Sets the connection that this ping client is using.
setDelay(long) - Method in class org.apache.qpid.oldtopic.Config
 
setDelay(long) - Method in class org.apache.qpid.topic.Config
 
setHost(String) - Method in class org.apache.qpid.oldtopic.Config
 
setHost(String) - Method in class org.apache.qpid.topic.Config
 
setMessages(int) - Method in class org.apache.qpid.oldtopic.Config
 
setMessages(int) - Method in class org.apache.qpid.topic.Config
 
setOption(String, String) - Method in class org.apache.qpid.config.AbstractConfig
 
setOption(String, String) - Method in class org.apache.qpid.oldtopic.Config
 
setOption(String, String) - Method in class org.apache.qpid.topic.Config
 
setOptions(String[]) - Method in class org.apache.qpid.config.AbstractConfig
 
setPayload(int) - Method in class org.apache.qpid.oldtopic.Config
 
setPayload(int) - Method in class org.apache.qpid.topic.Config
 
setPort(int) - Method in class org.apache.qpid.oldtopic.Config
 
setPort(int) - Method in class org.apache.qpid.topic.Config
 
setPubSub(boolean) - Method in class org.apache.qpid.requestreply.PingPongBouncer
Sets or clears the pub/sub flag to indiciate whether this client is pinging a queue or a topic.
setTimeout(long) - Method in class org.apache.qpid.topic.Config
 
setTimestamp(Message) - Method in class org.apache.qpid.requestreply.PingPongProducer
Sets the current time in nanoseconds as the timestamp on the message.
setTimingController(TimingController) - Method in class org.apache.qpid.ping.PingAsyncTestPerf
Accepts a timing controller from the test runner.
setTimingController(TimingController) - Method in class org.apache.qpid.ping.PingLatencyTestPerf
Accepts a timing controller from the test runner.
setTimingController(TimingController) - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Used by test runners that can supply a TimingController to set the controller on an aware test.
setUp() - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Overrides the parent setUp method so that the in-vm broker creation is not done on a per test basis.
setUp() - Method in class org.apache.qpid.topic.TopicWithSelectorsTransientVolumeTest
 
setupCorrelationID(String, int) - Method in class org.apache.qpid.requestreply.PingPongProducer
 
setWarmup(int) - Method in class org.apache.qpid.oldtopic.Config
 
setWarmup(int) - Method in class org.apache.qpid.topic.Config
 
start() - Method in class org.apache.qpid.requestreply.PingPongProducer
Starts the producer and consumer connections.
stop() - Method in class org.apache.qpid.requestreply.PingPongProducer
Stops the ping loop by clearing the publish flag.
suite() - Static method in class org.apache.qpid.ping.PingAsyncTestPerf
Compile all the tests into a test suite.
suite() - Static method in class org.apache.qpid.ping.PingLatencyTestPerf
Compile all the tests into a test suite.
suite() - Static method in class org.apache.qpid.ping.PingTestPerf
Compile all the tests into a test suite.
suite() - Static method in class org.apache.qpid.requestreply.PingPongTestPerf
Compile all the tests into a test suite.
suite() - Static method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Compiles all the tests in this class into a suite.

T

takeAction() - Method in class org.apache.qpid.ping.PingDurableClient
Performs an aribtrary action once the 'numMesagesToAction' count is reached on sending messages.
tearDown() - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Overrides the parent setUp method so that the in-vm broker clean-up is not done on a per test basis.
tearDown() - Method in class org.apache.qpid.topic.TopicWithSelectorsTransientVolumeTest
 
test50SubscribersWith90PercentMatched() - Method in class org.apache.qpid.topic.TopicWithSelectorsTransientVolumeTest
1 Topic with 50 subscribers using a selector, and 1 producer sending 50,000 1K messages with 90% selector success ratio.
TEST_RESULTS_BATCH_SIZE_DEFAULT - Static variable in class org.apache.qpid.ping.PingAsyncTestPerf
Holds the default test results logging batch size.
TEST_RESULTS_BATCH_SIZE_PROPNAME - Static variable in class org.apache.qpid.ping.PingAsyncTestPerf
Holds the name of the property to get the test results logging batch size.
TEST_RESULTS_BATCH_SIZE_PROPNAME - Static variable in class org.apache.qpid.ping.PingLatencyTestPerf
Holds the name of the property to get the test results logging batch size.
testAsyncPingOk(int) - Method in class org.apache.qpid.ping.PingAsyncTestPerf
Sends the specified number of pings, asynchronously outputs timings on every batch boundary, and waits until all replies have been received or a time out occurs before exiting this method.
testCircuit - Variable in class org.apache.qpid.test.testcases.MessageThroughputPerf.PerThreadSetup
Holds the test circuit to run tests on.
TestMessageFactory - Class in org.apache.qpid.client.message
 
TestMessageFactory() - Constructor for class org.apache.qpid.client.message.TestMessageFactory
 
testParameters - Variable in class org.apache.qpid.ping.PingTestPerf
Holds a property reader to extract the test parameters from.
testPingLatency(int) - Method in class org.apache.qpid.ping.PingLatencyTestPerf
Sends the specified number of pings, asynchronously outputs timings on every batch boundary, and waits until all replies have been received or a time out occurs before exiting this method.
testPingOk(int) - Method in class org.apache.qpid.ping.PingTestPerf
 
testPingPongOk(int) - Method in class org.apache.qpid.requestreply.PingPongTestPerf
 
testThroughput(int) - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Performs the a basic P2P test case.
threadSetUp() - Method in class org.apache.qpid.ping.PingAsyncTestPerf
Performs test fixture creation on a per thread basis.
threadSetUp() - Method in class org.apache.qpid.ping.PingLatencyTestPerf
Performs test fixture creation on a per thread basis.
threadSetup - Variable in class org.apache.qpid.ping.PingTestPerf
Thread local to hold the per-thread test setup fields.
threadSetUp() - Method in class org.apache.qpid.ping.PingTestPerf
Performs test fixture creation on a per thread basis.
threadSetup - Variable in class org.apache.qpid.requestreply.PingPongTestPerf
Thread local to hold the per-thread test setup fields.
threadSetUp() - Method in class org.apache.qpid.requestreply.PingPongTestPerf
Performs test fixture creation on a per thread basis.
threadSetup - Variable in class org.apache.qpid.test.testcases.MessageThroughputPerf
Thread local to hold the per-thread test setup fields.
threadSetUp() - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Performs test fixture creation on a per thread basis.
threadTearDown() - Method in class org.apache.qpid.ping.PingTestPerf
Performs test fixture clean
threadTearDown() - Method in class org.apache.qpid.requestreply.PingPongTestPerf
Performs test fixture clean
threadTearDown() - Method in class org.apache.qpid.test.testcases.MessageThroughputPerf
Called when a test thread is destroyed.
TIMEOUT_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Default time to wait before assuming that a ping has timed out.
TIMEOUT_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the waiting timeout for response messages.
timeOutStart - Variable in class org.apache.qpid.requestreply.PingPongProducer.PerCorrelationId
Holds the last timestamp that the timeout was reset to.
timestampFormatter - Static variable in class org.apache.qpid.requestreply.PingPongBouncer
A convenient formatter to use when time stamping output.
timestampFormatter - Static variable in class org.apache.qpid.requestreply.PingPongProducer
A convenient formatter to use when time stamping output.
TopicWithSelectorsTransientVolumeTest - Class in org.apache.qpid.topic
 
TopicWithSelectorsTransientVolumeTest() - Constructor for class org.apache.qpid.topic.TopicWithSelectorsTransientVolumeTest
 
trafficLight - Variable in class org.apache.qpid.requestreply.PingPongProducer.PerCorrelationId
Holds a countdown on number of expected messages.
TRANSACTED_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the transactional mode to use for the test.
TRANSACTED_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the test transactional mode from.
TX_BATCH_SIZE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default number of pings to send in each transaction when running transactionally.
TX_BATCH_SIZE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the commit batch size from.

U

UNIQUE_DESTS_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Defines the default value for the unique destinations property.
UNIQUE_DESTS_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the unique destinations flag from.
usePersistentMessages() - Method in class org.apache.qpid.oldtopic.Config
 
usePersistentMessages() - Method in class org.apache.qpid.topic.Config
 
USERNAME_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default broker log on username.
USERNAME_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the broker access username from.

V

VERBOSE_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default verbose mode.
VERBOSE_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the verbose mode proeprty from.
VIRTUAL_HOST_DEFAULT - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default virtual path for the test.
VIRTUAL_HOST_PROPNAME - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the property to get the test broker virtual path.

W

waitForUser(String) - Method in class org.apache.qpid.requestreply.PingPongProducer
Outputs a prompt to the console and waits for the user to press return.

_

_ackMode - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the acknowledgement mode used for the producers.
_brokerDetails - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the broker url.
_chainedMessageListener - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds a message listener that this message listener chains all its messages to.
_connection - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the connection for the message producer.
_consAckMode - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the acknowledgement mode setting for the consumers.
_consTransacted - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the consumers transactional mode flag.
_consumer - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the message consumer to receive the ping replies through.
_consumerConnection - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the consumer connections.
_consumerSession - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the controlSession on which ping replies are received.
_correlationId - Variable in class org.apache.qpid.ping.PingTestPerf.PerThreadSetup
 
_destinationName - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the root name from which to generate test destination names.
_factoryName - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the JNDI name of the JMS connection factory.
_failAfterCommit - Variable in class org.apache.qpid.requestreply.PingPongBouncer
This flag is used to indicate that the user should be prompted to a kill a broker, in order to test failover, immediate after committing a transaction.
_failAfterCommit - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate that the user should be prompted to terminate a broker, to test failover after a commit.
_failAfterSend - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate that the user should be prompted to terminate a broker, to test failover after a send.
_failBeforeCommit - Variable in class org.apache.qpid.requestreply.PingPongBouncer
This flag is used to indicate that the user should be prompted to kill a broker, in order to test failover, immediately before committing a transaction.
_failBeforeCommit - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate that the user should be prompted to terminate a broker, to test failover before a commit.
_failBeforeSend - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate that the user should be prompted to terminate a broker, to test failover before a send.
_failOnce - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate that failover prompting should only be done on the first commit, not on every commit.
_fileProperties - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the name of the properties file to configure JNDI with.
_isDurable - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate that durable destination should be used.
_isPubSub - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate if this is a point to point or pub/sub ping client.
_isUnique - Variable in class org.apache.qpid.requestreply.PingPongProducer
Flag used to indicate if the destinations should be unique client.
_maxPendingSize - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the size of the maximum amount of pending data that the client should buffer, sending is suspended if this limit is breached.
_messageSize - Variable in class org.apache.qpid.requestreply.PingPongProducer
Determines what size of messages this producer sends.
_noOfConsumers - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the number of consumers per destination.
_noOfDestinations - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the number of destinations to ping.
_overrideClientId - Variable in class org.apache.qpid.requestreply.PingPongProducer
Allows setting of client ID on the connection, rather than through the connection URL.
_password - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the password to access the broker with.
_persistent - Variable in class org.apache.qpid.requestreply.PingPongProducer
Determines whether this producer sends persistent messages.
_pingClient - Variable in class org.apache.qpid.ping.PingTestPerf.PerThreadSetup
Holds the test ping client.
_pingDestinations - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the set of destinations that this ping producer pings.
_producer - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the message producer to send the pings through.
_producerSession - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the producer controlSession, needed to create ping messages.
_publish - Variable in class org.apache.qpid.requestreply.PingPongProducer
Used to tell the ping loop when to terminate, it only runs while this is true.
_queueJVMSequenceID - Static variable in class org.apache.qpid.requestreply.PingPongProducer
This id generator is used to generate ids to append to the queue name to ensure that queues can be unique when creating multiple ping producers in the same JVM.
_queueMsgCounts - Variable in class org.apache.qpid.topic.TopicWithSelectorsTransientVolumeTest
 
_queueNamePostfix - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the default queue name postfix value.
_queueSharedID - Variable in class org.apache.qpid.requestreply.PingPongProducer
This id generator is used to generates ids that are only unique within this pinger.
_rate - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the maximum send rate in herz.
_rateLimiter - Variable in class org.apache.qpid.requestreply.PingPongProducer
Used to restrict the sending rate to a specified limit.
_replyDestination - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the destination where the response messages will arrive.
_selector - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the message selector to filter the pings with.
_sendPauseMonitor - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Holds a monitor which is used to synchronize sender and receivers threads, where the sender has elected to wait until the number of unreceived message is reduced before continuing to send.
_subscribers - Variable in class org.apache.qpid.topic.TopicWithSelectorsTransientVolumeTest
 
_transacted - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the producers transactional mode flag.
_txBatchSize - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the number of sends that should be performed in every transaction when using transactions.
_unreceived - Static variable in class org.apache.qpid.requestreply.PingPongProducer
Keeps a count of the number of message currently sent but not received.
_username - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the username to access the broker with.
_verbose - Variable in class org.apache.qpid.requestreply.PingPongProducer
Used to indicate that the ping loop should print out whenever it pings.
_virtualpath - Variable in class org.apache.qpid.requestreply.PingPongProducer
Holds the virtual host on the broker to run the tests through.

A B C D E F G I J L M N O P Q R S T U V W _
CRC Card

Licensed to the Apache Software Foundation