Skip to content

Commit 250573a

Browse files
author
Alexandru Scvortov
committed
don't bind to amq.default in java tests
1 parent c062a6c commit 250573a

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ public class FrameMax extends BrokerTestCase {
4949
* than what Rabbit suggests. */
5050
final static int FRAME_MAX = 70000;
5151
final static int REAL_FRAME_MAX = FRAME_MAX - 8;
52-
final static String ROUTING_KEY = "something";
5352

5453
private String queueName;
5554

@@ -63,7 +62,6 @@ protected void createResources()
6362
throws IOException
6463
{
6564
queueName = channel.queueDeclare().getQueue();
66-
channel.queueBind(queueName, "", ROUTING_KEY);
6765
}
6866

6967
/* Frame content should be less or equal to frame-max - 8. */
@@ -72,7 +70,7 @@ public void testFrameSizes()
7270
{
7371
/* This should result in at least 3 frames. */
7472
int howMuch = 2*FRAME_MAX;
75-
basicPublishVolatile(new byte[howMuch], ROUTING_KEY);
73+
basicPublishVolatile(new byte[howMuch], queueName);
7674
/* Receive everything that was sent out. */
7775
while (howMuch > 0) {
7876
try {

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -118,7 +118,7 @@ public void testQueueExclusiveForDelete() throws Exception {
118118

119119
public void testQueueExclusiveForBind() throws Exception {
120120
try {
121-
channel.queueBind(q, "", ""); // NB uses default exchange
121+
channel.queueBind(q, "amq.direct", "");
122122
} catch (IOException ioe) {
123123
checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
124124
return;
@@ -134,9 +134,9 @@ public void testQueueExclusiveForBind() throws Exception {
134134
// *doesn't* make sense to include it.
135135

136136
public void testQueueExclusiveForUnbind() throws Exception {
137-
altChannel.queueBind(q, "", ""); // NB uses default exchange
137+
altChannel.queueBind(q, "amq.direct", "");
138138
try {
139-
channel.queueUnbind(q, "", "");
139+
channel.queueUnbind(q, "amq.direct", "");
140140
} catch (IOException ioe) {
141141
checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
142142
return;

0 commit comments

Comments
 (0)