Skip to content

Commit 4e3f360

Browse files
committed
merge bug24092 into default
2 parents 41a9ddd + 0b772d3 commit 4e3f360

File tree

3 files changed

+3
-4
lines changed

3 files changed

+3
-4
lines changed

src/com/rabbitmq/client/ConsumerCancelledException.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ public class ConsumerCancelledException extends RuntimeException implements
2424
/** Default for non-checking. */
2525
private static final long serialVersionUID = 1L;
2626

27-
@Override
2827
public ConsumerCancelledException sensibleClone() {
2928
try {
3029
return (ConsumerCancelledException) super.clone();

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,6 @@ public void testConsumerCancellationInterruptsQueuingConsumerWait()
5757
final QueueingConsumer consumer = new QueueingConsumer(channel);
5858
Runnable receiver = new Runnable() {
5959

60-
@Override
6160
public void run() {
6261
try {
6362
try {

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,9 +108,10 @@ public void testTTLMustBePositive() throws Exception {
108108
public void testQueueRedeclareEquivalence() throws Exception {
109109
declareQueue(TTL_QUEUE_NAME, 10);
110110
try {
111-
declareQueue(TTL_QUEUE_NAME, 20);
111+
declareQueue(TTL_QUEUE_NAME, 20);
112+
fail("Should not be able to redeclare with different TTL");
112113
} catch(IOException ex) {
113-
checkShutdownSignal(AMQP.NOT_ALLOWED, ex);
114+
checkShutdownSignal(AMQP.PRECONDITION_FAILED, ex);
114115
}
115116
}
116117

0 commit comments

Comments
 (0)