|
|||||||||
| Home >> All >> org >> activemq >> [ usecases overview ] | PREV NEXT | ||||||||
A
- ACTIVEMQ_SERVER - Static variable in class org.activemq.usecases.NoDestinationErrorTest
- ACTIVEMQ_SERVER - Static variable in class org.activemq.usecases.SystemTest
- AvailableConsumerTest - class org.activemq.usecases.AvailableConsumerTest.
- TODO this test case relies on a perfect distribution of messages, dispatched one by one to each consumer.
- AvailableConsumerTest() - Constructor for class org.activemq.usecases.AvailableConsumerTest
- AvailableConsumerTest.BlockingConsumer - class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer.
- AvailableConsumerTest.BlockingConsumer(String, String) - Constructor for class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- AvailableConsumerTest.BrokerThread - class org.activemq.usecases.AvailableConsumerTest.BrokerThread.
- AvailableConsumerTest.BrokerThread(String, String, String[]) - Constructor for class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- AvailableConsumerTest.MessagePublisher - class org.activemq.usecases.AvailableConsumerTest.MessagePublisher.
- AvailableConsumerTest.MessagePublisher(String, String) - Constructor for class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- AvailableConsumerTest.MessagePublisher(String, String, int) - Constructor for class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- assertMessagesAreReceived() - Method in class org.activemq.usecases.CompositePublishTest
- assertTextMessageEquals(String, Message) - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
B
- BASE_PORT - Static variable in class org.activemq.usecases.BecksNetworkTest
- BROKER_INITIALIZATION_DELAY - Static variable in class org.activemq.usecases.AvailableConsumerTest
- BecksNetworkTest - class org.activemq.usecases.BecksNetworkTest.
- BecksNetworkTest() - Constructor for class org.activemq.usecases.BecksNetworkTest
- BecksNetworkTest.JMSComponent - class org.activemq.usecases.BecksNetworkTest.JMSComponent.
- BecksNetworkTest.JMSComponent(BecksNetworkTest.SimulationState, String, String) - Constructor for class org.activemq.usecases.BecksNetworkTest.JMSComponent
- BecksNetworkTest.MessageConsumerComponent - class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent.
- BecksNetworkTest.MessageConsumerComponent(BecksNetworkTest.SimulationState, String, String) - Constructor for class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- BecksNetworkTest.MessageProducerComponent - class org.activemq.usecases.BecksNetworkTest.MessageProducerComponent.
- BecksNetworkTest.MessageProducerComponent(BecksNetworkTest.SimulationState, String, String, int) - Constructor for class org.activemq.usecases.BecksNetworkTest.MessageProducerComponent
- BecksNetworkTest.SimulationComponent - class org.activemq.usecases.BecksNetworkTest.SimulationComponent.
- BecksNetworkTest.SimulationComponent(BecksNetworkTest.SimulationState, String) - Constructor for class org.activemq.usecases.BecksNetworkTest.SimulationComponent
- BecksNetworkTest.SimulationState - class org.activemq.usecases.BecksNetworkTest.SimulationState.
- BecksNetworkTest.SimulationState(int) - Constructor for class org.activemq.usecases.BecksNetworkTest.SimulationState
- bindAddress - Variable in class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- broker - Variable in class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- broker - Variable in class org.activemq.usecases.DurableSubscriptionTestSupport
- broker - Variable in class org.activemq.usecases.NoDestinationErrorTest
- broker - Variable in class org.activemq.usecases.SystemTest
- brokerConnection - Variable in class org.activemq.usecases.QueueDuplicatesTest
- brokerContainer - Variable in class org.activemq.usecases.ReliableReconnectTest
- brokerUrl - Variable in class org.activemq.usecases.NoDestinationErrorTest
- brokerUrl - Variable in class org.activemq.usecases.QueueDuplicatesTest.SendingThread
- brokerUrl - Variable in class org.activemq.usecases.QueueDuplicatesTest
- brokerUrl - Variable in class org.activemq.usecases.SystemTest
C
- COUNT - Static variable in class org.activemq.usecases.ChangeSentMessageTest
- COUNT - Static variable in class org.activemq.usecases.ChangeSessionDeliveryModeTest
- ChangeSentMessageTest - class org.activemq.usecases.ChangeSentMessageTest.
- ChangeSentMessageTest() - Constructor for class org.activemq.usecases.ChangeSentMessageTest
- ChangeSessionDeliveryModeTest - class org.activemq.usecases.ChangeSessionDeliveryModeTest.
- ChangeSessionDeliveryModeTest() - Constructor for class org.activemq.usecases.ChangeSessionDeliveryModeTest
- CompositeConsumeTest - class org.activemq.usecases.CompositeConsumeTest.
- CompositeConsumeTest() - Constructor for class org.activemq.usecases.CompositeConsumeTest
- CompositePublishTest - class org.activemq.usecases.CompositePublishTest.
- CompositePublishTest() - Constructor for class org.activemq.usecases.CompositePublishTest
- ConsumeQueuePrefetchTest - class org.activemq.usecases.ConsumeQueuePrefetchTest.
- ConsumeQueuePrefetchTest() - Constructor for class org.activemq.usecases.ConsumeQueuePrefetchTest
- ConsumeTopicPrefetchTest - class org.activemq.usecases.ConsumeTopicPrefetchTest.
- ConsumeTopicPrefetchTest() - Constructor for class org.activemq.usecases.ConsumeTopicPrefetchTest
- CreateTemporaryQueueBeforeStartTest - class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest.
- CreateTemporaryQueueBeforeStartTest() - Constructor for class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- cleanupSimulation(AvailableConsumerTest.BrokerThread[], AvailableConsumerTest.MessagePublisher[], AvailableConsumerTest.BlockingConsumer[]) - Static method in class org.activemq.usecases.AvailableConsumerTest
- closeBroker - Variable in class org.activemq.usecases.ReliableReconnectTest
- closeConsumer() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- closeSession() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- connection - Variable in class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- connection - Variable in class org.activemq.usecases.DeadLetterTest
- connection - Variable in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- connection - Variable in class org.activemq.usecases.DurableSubscriptionTestSupport
- connection - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- connection - Variable in class org.activemq.usecases.TransactionTest
- consumeMessagesDeliveredWhileConsumerClosed() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- consumeMessge(int) - Method in class org.activemq.usecases.ConsumeTopicPrefetchTest
- consumer - Variable in class org.activemq.usecases.DeadLetterTest
- consumer - Variable in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- consumer - Variable in class org.activemq.usecases.DurableSubscriptionTestSupport
- consumer - Variable in class org.activemq.usecases.NoDestinationErrorTest
- consumer - Variable in class org.activemq.usecases.SystemTest
- consumer - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- consumer - Variable in class org.activemq.usecases.TransactionTest
- consumerClientId - Variable in class org.activemq.usecases.ReliableReconnectTest
- consumerCount - Variable in class org.activemq.usecases.NoDestinationErrorTest
- consumerCount - Variable in class org.activemq.usecases.SystemTest
- consumerSession - Variable in class org.activemq.usecases.NoDestinationErrorTest
- consumerSession - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- consumerSession - Variable in class org.activemq.usecases.TransactionTest
- consumerTimeout - Variable in class org.activemq.usecases.ConsumeTopicPrefetchTest
- consumers - Variable in class org.activemq.usecases.CompositePublishTest
- createAddressString(String[], String, String) - Static method in class org.activemq.usecases.BecksNetworkTest
- createBroker() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- createBroker() - Method in class org.activemq.usecases.NoDestinationErrorTest
- Sets up and starts the broker.
- createBroker() - Method in class org.activemq.usecases.StartAndStopBrokerTest
- createBroker() - Method in class org.activemq.usecases.SystemTest
- Sets up and starts the broker.
- createBrokers(String[]) - Static method in class org.activemq.usecases.AvailableConsumerTest
- createConnection() - Method in class org.activemq.usecases.ConsumeTopicPrefetchTest
- createConnection() - Method in class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- createConnection() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- createConnectionFactory() - Method in class org.activemq.usecases.CompositePublishTest
- createConnectionFactory() - Method in class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- createConnectionFactory(String, boolean) - Static method in class org.activemq.usecases.NoDestinationErrorTest
- Creates the connection to the broker.
- createConnectionFactory(String, boolean) - Static method in class org.activemq.usecases.SystemTest
- Creates the connection to the broker.
- createConnectionFactory(String, String, String) - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- createConsumer(String) - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- createConsumer(Connection) - Method in class org.activemq.usecases.ReliableReconnectTest
- createConsumerConnection() - Method in class org.activemq.usecases.ReliableReconnectTest
- createConsumers(String, int, String) - Static method in class org.activemq.usecases.AvailableConsumerTest
- createDestination() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- createDestination(Session, String, boolean) - Static method in class org.activemq.usecases.NoDestinationErrorTest
- Creates the session destination.
- createDestination(Session, String, boolean) - Static method in class org.activemq.usecases.SystemTest
- Creates the session destination.
- createEmbeddedRemoteBrokerConnectionFactory() - Method in class org.activemq.usecases.EmbeddedRemoteConnectorTest
- createFactory(String) - Method in class org.activemq.usecases.QueueDuplicatesTest
- createMessageBody(String, int) - Static method in class org.activemq.usecases.BecksNetworkTest.MessageProducerComponent
- createMessageListener(int, List) - Method in class org.activemq.usecases.CompositePublishTest
- createPersistenceAdapter() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- createPersistenceAdapter() - Method in class org.activemq.usecases.EmbeddedRemoteConnectorTest
- Returns the persistence adapter.
- createPersistenceAdapter() - Method in class org.activemq.usecases.JDBCDurableSubscriptionTest
- createPersistenceAdapter() - Method in class org.activemq.usecases.JournalDurableSubscriptionTest
- createPersistenceAdapter() - Method in class org.activemq.usecases.NoDestinationErrorTest
- Returns the persistence adapter.
- createPersistenceAdapter() - Method in class org.activemq.usecases.SystemTest
- Returns the persistence adapter.
- createProducer(Session, Destination) - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- createPublishers(String, int, String) - Static method in class org.activemq.usecases.AvailableConsumerTest
- createReceiveConnection() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.EmbeddedRemoteConnectorTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingHttpTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingJavaConfigurationTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingTcpTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.TwoMulticastDiscoveryBrokerTopicSendReceiveTest
- createReceiverConnectionFactory() - Method in class org.activemq.usecases.TwoZeroconfDiscoveryBrokerTopicSendReceiveTest
- createReliableURL(String[]) - Static method in class org.activemq.usecases.AvailableConsumerTest
- createSendConnection() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- createSenderConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- createSenderConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingHttpTest
- createSenderConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingJavaConfigurationTest
- createSenderConnectionFactory() - Method in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingTcpTest
- createSenderConnectionFactory() - Method in class org.activemq.usecases.TwoMulticastDiscoveryBrokerTopicSendReceiveTest
- createSenderConnectionFactory() - Method in class org.activemq.usecases.TwoZeroconfDiscoveryBrokerTopicSendReceiveTest
- createSession(String) - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- createSession(Connection, boolean) - Static method in class org.activemq.usecases.NoDestinationErrorTest
- Creates the connection session.
- createSession(String) - Method in class org.activemq.usecases.QueueDuplicatesTest
- createSession(Connection, boolean) - Static method in class org.activemq.usecases.SystemTest
- Creates the connection session.
D
- DeadLetterTest - class org.activemq.usecases.DeadLetterTest.
- DeadLetterTest() - Constructor for class org.activemq.usecases.DeadLetterTest
- DurableConsumerCloseAndReconnectTest - class org.activemq.usecases.DurableConsumerCloseAndReconnectTest.
- DurableConsumerCloseAndReconnectTest() - Constructor for class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- DurableSubscriptionTestSupport - class org.activemq.usecases.DurableSubscriptionTestSupport.
- DurableSubscriptionTestSupport() - Constructor for class org.activemq.usecases.DurableSubscriptionTestSupport
- deliveryMode - Variable in class org.activemq.usecases.DeadLetterTest
- deliveryMode - Variable in class org.activemq.usecases.ReliableReconnectTest
- deliveryMode - Variable in class org.activemq.usecases.TopicRedeliverTest
- destination - Variable in class org.activemq.usecases.DeadLetterTest
- destination - Variable in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- destination - Variable in class org.activemq.usecases.ReliableReconnectTest
- destoryBroker() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- destoryBroker() - Method in class org.activemq.usecases.NoDestinationErrorTest
- Closes the broker.
- destoryBroker() - Method in class org.activemq.usecases.SystemTest
- Closes the broker.
- doTest() - Method in class org.activemq.usecases.DeadLetterTest
- doTest() - Method in class org.activemq.usecases.NoDestinationErrorTest
- doTest() - Method in class org.activemq.usecases.SystemTest
- Executes the unit test by running the producers and consumers.
- done() - Method in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- done() - Method in class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- done() - Method in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- durableSubscriber - Variable in class org.activemq.usecases.DeadLetterTest
E
- EmbeddedRemoteConnectorTest - class org.activemq.usecases.EmbeddedRemoteConnectorTest.
- EmbeddedRemoteConnectorTest() - Constructor for class org.activemq.usecases.EmbeddedRemoteConnectorTest
- ExceptionListenerTest - class org.activemq.usecases.ExceptionListenerTest.
- ExceptionListenerTest(String) - Constructor for class org.activemq.usecases.ExceptionListenerTest
F
- FINISHED - Static variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- firstBatch - Variable in class org.activemq.usecases.ReliableReconnectTest
- formatter - Static variable in class org.activemq.usecases.QueueDuplicatesTest
G
- getConnectionFactory() - Method in class org.activemq.usecases.ReliableReconnectTest
- getDeliveryMode() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- getDestinations() - Method in class org.activemq.usecases.CompositeConsumeTest
- Returns the destinations on which we publish
- getDestinations() - Method in class org.activemq.usecases.CompositePublishTest
- Returns the destinations to which we consume
- getId() - Method in class org.activemq.usecases.BecksNetworkTest.SimulationComponent
- getNumberOfMessagesConsumed() - Method in class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- getPrefix() - Method in class org.activemq.usecases.CompositeConsumeTest
- getPrefix() - Method in class org.activemq.usecases.CompositePublishTest
- getState() - Method in class org.activemq.usecases.BecksNetworkTest.SimulationState
- getSubject() - Method in class org.activemq.usecases.CompositeConsumeTest
- Returns the subscription subject
- getSubject() - Method in class org.activemq.usecases.CompositePublishTest
- Returns the subject on which we publish
- getSubjects() - Method in class org.activemq.usecases.SystemTest
- Generates the topic/queue destinations.
I
- INITIALIZED - Static variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- idGen - Variable in class org.activemq.usecases.ReliableReconnectTest
- idGen - Variable in class org.activemq.usecases.TopicRedeliverTest
- init - Variable in class org.activemq.usecases.EmbeddedRemoteConnectorTest
- init - Variable in class org.activemq.usecases.JDBCDurableSubscriptionTest
- init - Variable in class org.activemq.usecases.JournalDurableSubscriptionTest
- init - Variable in class org.activemq.usecases.NoDestinationErrorTest
- init - Variable in class org.activemq.usecases.SystemTest
- isBlocked() - Method in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- isDurable - Variable in class org.activemq.usecases.NoDestinationErrorTest
- isDurable - Variable in class org.activemq.usecases.SystemTest
- isEmbeddedBroker - Variable in class org.activemq.usecases.NoDestinationErrorTest
- isEmbeddedBroker - Variable in class org.activemq.usecases.SystemTest
- isException - Variable in class org.activemq.usecases.ExceptionListenerTest
- isPersistent - Variable in class org.activemq.usecases.NoDestinationErrorTest
- isPersistent - Variable in class org.activemq.usecases.SystemTest
- isTopic() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- isTopic - Variable in class org.activemq.usecases.NoDestinationErrorTest
- isTopic() - Method in class org.activemq.usecases.QueueConsumerCloseAndReconnectTest
- isTopic - Variable in class org.activemq.usecases.SystemTest
J
- JDBCDurableSubscriptionTest - class org.activemq.usecases.JDBCDurableSubscriptionTest.
- JDBCDurableSubscriptionTest() - Constructor for class org.activemq.usecases.JDBCDurableSubscriptionTest
- JournalDurableSubscriptionTest - class org.activemq.usecases.JournalDurableSubscriptionTest.
- JournalDurableSubscriptionTest() - Constructor for class org.activemq.usecases.JournalDurableSubscriptionTest
L
- LAST_MESSAGE - Static variable in class org.activemq.usecases.NoDestinationErrorTest
- LAST_MESSAGE - Static variable in class org.activemq.usecases.SystemTest
- latch - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- latch - Variable in class org.activemq.usecases.TransactionTest
- log - Static variable in class org.activemq.usecases.AvailableConsumerTest
- log - Static variable in class org.activemq.usecases.BecksNetworkTest
- log - Static variable in class org.activemq.usecases.SystemTest
M
- MAX_RETRY_COUNT - Static variable in class org.activemq.usecases.TopicRedeliverTest
- MESSAGE_BODY_KEY - Static variable in class org.activemq.usecases.BecksNetworkTest
- MESSAGE_COUNT - Static variable in class org.activemq.usecases.DeadLetterTest
- MESSAGE_COUNT - Static variable in class org.activemq.usecases.ReliableReconnectTest
- MESSAGE_PRODUCER_KEY - Static variable in class org.activemq.usecases.BecksNetworkTest
- MESSAGE_RECEIVE_DELAY - Static variable in class org.activemq.usecases.BecksNetworkTest
- MESSAGE_SEND_DELAY - Static variable in class org.activemq.usecases.BecksNetworkTest
- m_blocked - Variable in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- m_connection - Variable in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- m_connection - Variable in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- m_connection - Variable in class org.activemq.usecases.BecksNetworkTest.JMSComponent
- m_consumer - Variable in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- m_consumer - Variable in class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- m_container - Variable in class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- m_id - Variable in class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- m_id - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationComponent
- m_inOnMessage - Variable in class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- m_linkedURLs - Variable in class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- m_messagesConsumed - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- m_messagesProduced - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- m_myURL - Variable in class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- m_numExpectedMessages - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- m_numMessagesConsumed - Variable in class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- m_numMessagesToSend - Variable in class org.activemq.usecases.BecksNetworkTest.MessageProducerComponent
- m_producer - Variable in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- m_producer - Variable in class org.activemq.usecases.BecksNetworkTest.MessageProducerComponent
- m_queue - Variable in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- m_queue - Variable in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- m_queue - Variable in class org.activemq.usecases.BecksNetworkTest.JMSComponent
- m_session - Variable in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- m_session - Variable in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- m_session - Variable in class org.activemq.usecases.BecksNetworkTest.JMSComponent
- m_simulationState - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationComponent
- m_state - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- m_stateLock - Variable in class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- m_stateLock - Variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- m_url - Variable in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- m_url - Variable in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- m_url - Variable in class org.activemq.usecases.BecksNetworkTest.JMSComponent
- main(String[]) - Static method in class org.activemq.usecases.BecksNetworkTest
- makeConsumer() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- makeMessages(int) - Method in class org.activemq.usecases.ConsumeTopicPrefetchTest
- messageCount - Variable in class org.activemq.usecases.EmbeddedRemoteConnectorTest
- messageCount - Variable in class org.activemq.usecases.NoDestinationErrorTest
- messageCount - Variable in class org.activemq.usecases.SystemTest
- messageLists - Variable in class org.activemq.usecases.CompositePublishTest
- messageTexts - Variable in class org.activemq.usecases.ConsumeTopicPrefetchTest
- messagesReceived - Variable in class org.activemq.usecases.ReliableReconnectTest
- msgCommitted - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- msgCounter - Static variable in class org.activemq.usecases.NoDestinationErrorTest
- msgCounter - Static variable in class org.activemq.usecases.SystemTest
- msgRedelivered - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- msgRolledBack - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- msgSent - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- msgs - Variable in class org.activemq.usecases.QueueDuplicatesTest.SimpleConsumer
N
- NUM_BROKERS - Static variable in class org.activemq.usecases.BecksNetworkTest
- NUM_CONSUMERS - Static variable in class org.activemq.usecases.BecksNetworkTest
- NUM_MESSAGES - Static variable in class org.activemq.usecases.BecksNetworkTest
- NUM_MESSAGES - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- NUM_PRODUCERS - Static variable in class org.activemq.usecases.BecksNetworkTest
- NoDestinationErrorTest - class org.activemq.usecases.NoDestinationErrorTest.
- This Unit Test is created to test the memory leakage when a new producer is created and closed for each message that was sent.
- NoDestinationErrorTest() - Constructor for class org.activemq.usecases.NoDestinationErrorTest
- NonPersistentDurableTopicSystemTest - class org.activemq.usecases.NonPersistentDurableTopicSystemTest.
- NonPersistentDurableTopicSystemTest() - Constructor for class org.activemq.usecases.NonPersistentDurableTopicSystemTest
- NonPersistentNonDurableTopicSystemTest - class org.activemq.usecases.NonPersistentNonDurableTopicSystemTest.
- NonPersistentNonDurableTopicSystemTest() - Constructor for class org.activemq.usecases.NonPersistentNonDurableTopicSystemTest
O
- onException(JMSException) - Method in class org.activemq.usecases.ExceptionListenerTest
- onMessage(Message) - Method in class org.activemq.usecases.AvailableConsumerTest.BlockingConsumer
- onMessage(Message) - Method in class org.activemq.usecases.BecksNetworkTest.MessageConsumerComponent
- onMessage(Message) - Method in class org.activemq.usecases.ChangeSessionDeliveryModeTest
- onMessage(Message) - Method in class org.activemq.usecases.PublishOnTopicConsumedMessageTest
- onMessage(Message) - Method in class org.activemq.usecases.QueueDuplicatesTest.SimpleConsumer
- onMessage(Message) - Method in class org.activemq.usecases.SystemTest
- Processes the received message.
- onMessageConsumed(String, String) - Method in class org.activemq.usecases.BecksNetworkTest.SimulationState
- onMessageProduced(String, String) - Method in class org.activemq.usecases.BecksNetworkTest.SimulationState
- org.activemq.usecases - package org.activemq.usecases
P
- PersistentDurableTopicSystemTest - class org.activemq.usecases.PersistentDurableTopicSystemTest.
- PersistentDurableTopicSystemTest() - Constructor for class org.activemq.usecases.PersistentDurableTopicSystemTest
- PersistentNonDurableTopicSystemTest - class org.activemq.usecases.PersistentNonDurableTopicSystemTest.
- PersistentNonDurableTopicSystemTest() - Constructor for class org.activemq.usecases.PersistentNonDurableTopicSystemTest
- ProducerMap - Static variable in class org.activemq.usecases.NoDestinationErrorTest
- ProducerMap - Static variable in class org.activemq.usecases.SystemTest
- PublishOnDurableTopicConsumedMessageTest - class org.activemq.usecases.PublishOnDurableTopicConsumedMessageTest.
- PublishOnDurableTopicConsumedMessageTest() - Constructor for class org.activemq.usecases.PublishOnDurableTopicConsumedMessageTest
- PublishOnQueueConsumedMessageTest - class org.activemq.usecases.PublishOnQueueConsumedMessageTest.
- PublishOnQueueConsumedMessageTest() - Constructor for class org.activemq.usecases.PublishOnQueueConsumedMessageTest
- PublishOnTemporaryQueueConsumedMessageTest - class org.activemq.usecases.PublishOnTemporaryQueueConsumedMessageTest.
- PublishOnTemporaryQueueConsumedMessageTest() - Constructor for class org.activemq.usecases.PublishOnTemporaryQueueConsumedMessageTest
- PublishOnTopicConsumedMessageTest - class org.activemq.usecases.PublishOnTopicConsumedMessageTest.
- PublishOnTopicConsumedMessageTest() - Constructor for class org.activemq.usecases.PublishOnTopicConsumedMessageTest
- prefetchSize - Variable in class org.activemq.usecases.ConsumeTopicPrefetchTest
- producer - Variable in class org.activemq.usecases.DeadLetterTest
- producer - Variable in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- producer - Variable in class org.activemq.usecases.DurableSubscriptionTestSupport
- producer - Variable in class org.activemq.usecases.NoDestinationErrorTest
- producer - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- producer - Variable in class org.activemq.usecases.TransactionTest
- producerCount - Variable in class org.activemq.usecases.NoDestinationErrorTest
- producerCount - Variable in class org.activemq.usecases.SystemTest
- producerSession - Variable in class org.activemq.usecases.NoDestinationErrorTest
- producerSession - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- producerSession - Variable in class org.activemq.usecases.TransactionTest
- publish() - Method in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- publish() - Method in class org.activemq.usecases.SystemTest
- Creates the message producer threads.
- publish(int, String) - Method in class org.activemq.usecases.SystemTest
- Creates the producer and send the messages.
Q
- QUEUE_NAME - Static variable in class org.activemq.usecases.BecksNetworkTest
- QueueConsumerCloseAndReconnectTest - class org.activemq.usecases.QueueConsumerCloseAndReconnectTest.
- QueueConsumerCloseAndReconnectTest() - Constructor for class org.activemq.usecases.QueueConsumerCloseAndReconnectTest
- QueueDuplicatesTest - class org.activemq.usecases.QueueDuplicatesTest.
- QueueDuplicatesTest(String) - Constructor for class org.activemq.usecases.QueueDuplicatesTest
- QueueDuplicatesTest.SendingThread - class org.activemq.usecases.QueueDuplicatesTest.SendingThread.
- QueueDuplicatesTest.SendingThread(String, String) - Constructor for class org.activemq.usecases.QueueDuplicatesTest.SendingThread
- QueueDuplicatesTest.SimpleConsumer - class org.activemq.usecases.QueueDuplicatesTest.SimpleConsumer.
- QueueDuplicatesTest.SimpleConsumer() - Constructor for class org.activemq.usecases.QueueDuplicatesTest.SimpleConsumer
- QueueRedeliverTest - class org.activemq.usecases.QueueRedeliverTest.
- QueueRedeliverTest() - Constructor for class org.activemq.usecases.QueueRedeliverTest
- QueueSystemTest - class org.activemq.usecases.QueueSystemTest.
- QueueSystemTest() - Constructor for class org.activemq.usecases.QueueSystemTest
- queue - Variable in class org.activemq.usecases.NoDestinationErrorTest
- queue - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- queue - Variable in class org.activemq.usecases.TransactionTest
R
- RECEIVE_TIMEOUT - Static variable in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- RECEIVE_TIMEOUT - Static variable in class org.activemq.usecases.ReliableReconnectTest
- RECEIVE_TIMEOUT - Static variable in class org.activemq.usecases.TopicRedeliverTest
- RUNNING - Static variable in class org.activemq.usecases.BecksNetworkTest.SimulationState
- ReliableReconnectTest - class org.activemq.usecases.ReliableReconnectTest.
- ReliableReconnectTest() - Constructor for class org.activemq.usecases.ReliableReconnectTest
- ReliableReconnectTest(String) - Constructor for class org.activemq.usecases.ReliableReconnectTest
- receiveBroker - Variable in class org.activemq.usecases.EmbeddedRemoteConnectorTest
- receiveBroker - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingJavaConfigurationTest
- receiveConnection - Variable in class org.activemq.usecases.CompositePublishTest
- receiveFactory - Variable in class org.activemq.usecases.TwoBrokerQueueSendReceiveTest
- receiveFactory - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- receiveSession - Variable in class org.activemq.usecases.CompositePublishTest
- receivedText - Variable in class org.activemq.usecases.TransactionRollbackOrderTest
- receivedText - Variable in class org.activemq.usecases.TransactionTest
- receiverBroker - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingTcpTest
- replyProducer - Variable in class org.activemq.usecases.PublishOnTopicConsumedMessageTest
- resetProducerMap() - Method in class org.activemq.usecases.SystemTest
- Returns the message entries and clears the map for another set of messages to be processed.
- restartBroker() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- root - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingJavaConfigurationTest
- run() - Method in class org.activemq.usecases.AvailableConsumerTest.BrokerThread
- run() - Method in class org.activemq.usecases.BecksNetworkTest.SimulationComponent
- run() - Method in class org.activemq.usecases.QueueDuplicatesTest.SendingThread
- runSimulation(String[], int, String) - Method in class org.activemq.usecases.AvailableConsumerTest
S
- StartAndStopBrokerTest - class org.activemq.usecases.StartAndStopBrokerTest.
- StartAndStopBrokerTest() - Constructor for class org.activemq.usecases.StartAndStopBrokerTest
- SubscribeClosePublishThenConsumeTest - class org.activemq.usecases.SubscribeClosePublishThenConsumeTest.
- SubscribeClosePublishThenConsumeTest() - Constructor for class org.activemq.usecases.SubscribeClosePublishThenConsumeTest
- SystemTest - class org.activemq.usecases.SystemTest.
- SystemTest() - Constructor for class org.activemq.usecases.SystemTest
- Default constructor
- SystemTest(boolean, boolean, boolean, int, int, int, int, String) - Constructor for class org.activemq.usecases.SystemTest
- Constructor
- sendBroker - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingJavaConfigurationTest
- sendConnection - Variable in class org.activemq.usecases.CompositePublishTest
- sendFactory - Variable in class org.activemq.usecases.TwoBrokerQueueSendReceiveTest
- sendFactory - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveTest
- sendMessage() - Method in class org.activemq.usecases.AvailableConsumerTest.MessagePublisher
- senderBroker - Variable in class org.activemq.usecases.TwoBrokerTopicSendReceiveUsingTcpTest
- session - Variable in class org.activemq.usecases.DeadLetterTest
- session - Variable in class org.activemq.usecases.DurableConsumerCloseAndReconnectTest
- session - Variable in class org.activemq.usecases.DurableSubscriptionTestSupport
- setState(int) - Method in class org.activemq.usecases.BecksNetworkTest.SimulationState
- setUp() - Method in class org.activemq.usecases.CompositePublishTest
- setUp() - Method in class org.activemq.usecases.ConsumeQueuePrefetchTest
- setUp() - Method in class org.activemq.usecases.CreateTemporaryQueueBeforeStartTest
- setUp() - Method in class org.activemq.usecases.DeadLetterTest
- setUp() - Method in class org.activemq.usecases.DurableSubscriptionTestSupport
- setUp() - Method in class org.activemq.usecases.NoDestinationErrorTest
- Sets up the resources of the unit test.
- setUp() - Method in class org.activemq.usecases.NonPersistentDurableTopicSystemTest
- Sets up the resources of the unit test.
- setUp() - Method in class org.activemq.usecases.NonPersistentNonDurableTopicSystemTest
- Sets up the resources of the unit test.
- setUp() - Method in class org.activemq.usecases.PersistentDurableTopicSystemTest
- Sets up the resources of the unit test.
- setUp() - Method in class org.activemq.usecases.PersistentNonDurable