summaryrefslogtreecommitdiff
path: root/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java')
-rw-r--r--java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java b/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java
index 71ab38ec0a..edc6fdba1e 100644
--- a/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java
+++ b/java/integrationtests/src/main/java/org/apache/qpid/sustained/SustainedClientTestCase.java
@@ -46,7 +46,7 @@ import java.util.concurrent.CountDownLatch;
/**
* Implements test case 3, basic pub/sub. Sends/received a specified number of messages to a specified route on the
- * default topic exchange, using the specified number of receiver connections. Produces reports on the actual number of
+ * default topic exchange, using the specified number of receivers connections. Produces reports on the actual number of
* messages sent/received.
*
* <p><table id="crc"><caption>CRC Card</caption>
@@ -68,7 +68,7 @@ public class SustainedClientTestCase extends TestCase3BasicPubSub implements Exc
/** The role to be played by the test. */
private Roles role;
- /** The number of receiver connection to use. */
+ /** The number of receivers connection to use. */
private int numReceivers;
/** The routing key to send them to on the default direct exchange. */
@@ -114,7 +114,7 @@ public class SustainedClientTestCase extends TestCase3BasicPubSub implements Exc
* Assigns the role to be played by this test case. The test parameters are fully specified in the assignment
* message. When this method return the test case will be ready to execute.
*
- * @param role The role to be played; sender or receiver.
+ * @param role The role to be played; sender or receivers.
* @param assignRoleMessage The role assingment message, contains the full test parameters.
*
* @throws JMSException Any JMSException resulting from reading the message are allowed to fall through.
@@ -172,11 +172,11 @@ public class SustainedClientTestCase extends TestCase3BasicPubSub implements Exc
break;
- // Otherwise the receiver role is being assigned, so set this up to listen for messages on the required number
- // of receiver connections.
+ // Otherwise the receivers role is being assigned, so set this up to listen for messages on the required number
+ // of receivers connections.
case RECEIVER:
console.info("Creating Receiver");
- // Create the required number of receiver connections.
+ // Create the required number of receivers connections.
connection = new Connection[numReceivers];
session = new Session[numReceivers];