Skip to content

Commit f5d3f28

Browse files
author
Tim Watson
committed
cosmetic; english
1 parent 4eb616e commit f5d3f28

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

test/src/com/rabbitmq/client/test/functional/PerQueueTTL.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -87,28 +87,28 @@ public void testTTLMustBePositive() throws Exception {
8787
}
8888
}
8989

90-
public void testQueueRedeclareEquivalence() throws Exception {
90+
public void testQueueReDeclareEquivalence() throws Exception {
9191
declareQueue(10);
9292
try {
9393
declareQueue(20);
94-
fail("Should not be able to redeclare with different x-message-ttl");
94+
fail("Should not be able to re-declare with different x-message-ttl");
9595
} catch (IOException ex) {
9696
checkShutdownSignal(AMQP.PRECONDITION_FAILED, ex);
9797
}
9898
}
9999

100-
public void testQueueRedeclareSemanticEquivalence() throws Exception {
100+
public void testQueueReDeclareSemanticEquivalence() throws Exception {
101101
declareQueue((byte) 10);
102102
declareQueue(10);
103103
declareQueue((short) 10);
104104
declareQueue(10L);
105105
}
106106

107-
public void testQueueRedeclareSemanticNonEquivalence() throws Exception {
107+
public void testQueueReDeclareSemanticNonEquivalence() throws Exception {
108108
declareQueue(10);
109109
try {
110110
declareQueue(10.0);
111-
fail("Should not be able to redeclare with x-message-ttl argument of different type");
111+
fail("Should not be able to re-declare with x-message-ttl argument of different type");
112112
} catch (IOException ex) {
113113
checkShutdownSignal(AMQP.PRECONDITION_FAILED, ex);
114114
}
@@ -154,9 +154,9 @@ public void testTransactionalPublishWithGet() throws Exception {
154154
}
155155

156156
/*
157-
* Test expiry of requeued messages
157+
* Test expiry of re-queued messages
158158
*/
159-
public void testExpiryWithRequeue() throws Exception {
159+
public void testExpiryWithReQueue() throws Exception {
160160
declareAndBindQueue(100);
161161

162162
publish(MSG[0]);
@@ -176,9 +176,9 @@ public void testExpiryWithRequeue() throws Exception {
176176
}
177177

178178
/*
179-
* Test expiry of requeued messages after being consumed instantly
179+
* Test expiry of re-queued messages after being consumed instantly
180180
*/
181-
public void testExpiryWithRequeueAfterConsume() throws Exception {
181+
public void testExpiryWithReQueueAfterConsume() throws Exception {
182182
declareAndBindQueue(100);
183183
QueueingConsumer c = new QueueingConsumer(channel);
184184
channel.basicConsume(TTL_QUEUE_NAME, c);
@@ -190,7 +190,7 @@ public void testExpiryWithRequeueAfterConsume() throws Exception {
190190
Thread.sleep(150);
191191
openChannel();
192192

193-
assertNull("Requeued message not expired", get());
193+
assertNull("ReQueued message not expired", get());
194194
}
195195

196196
public void testZeroTTLDelivery() throws Exception {
@@ -207,7 +207,7 @@ public void testZeroTTLDelivery() throws Exception {
207207
Delivery d = c.nextDelivery(100);
208208
assertNotNull(d);
209209

210-
// requeued messages should expire
210+
// re-queued messages should expire
211211
channel.basicReject(d.getEnvelope().getDeliveryTag(), true);
212212
assertNull(c.nextDelivery(100));
213213
}

0 commit comments

Comments
 (0)