summaryrefslogtreecommitdiff
path: root/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-10-13 00:58:45 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-10-13 00:58:45 +0000
commit1e437d92f66da4ef0dffbfb85e9e66e5b4f4f980 (patch)
treefc7be07855ef97588f8af0bbe53d79107a9d5544 /java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java
parentb71808f6e2d65056b3cded958012ad1d96cd7391 (diff)
downloadqpid-python-1e437d92f66da4ef0dffbfb85e9e66e5b4f4f980.tar.gz
Migrate broker to new direct method dispatch mechanism
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1631275 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java')
-rw-r--r--java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java25
1 files changed, 13 insertions, 12 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java b/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java
index 06e590f8e5..4001ba7aa0 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBody.java
@@ -204,9 +204,8 @@ public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableA
return buf.toString();
}
- public static void process(final int channelId,
- final MarkableDataInput buffer,
- final MethodProcessor dispatcher) throws IOException, AMQFrameDecodingException
+ public static void process(final MarkableDataInput buffer,
+ final ServerChannelMethodProcessor dispatcher) throws IOException, AMQFrameDecodingException
{
int ticket = buffer.readUnsignedShort();
@@ -219,14 +218,16 @@ public class ExchangeDeclareBody extends AMQMethodBodyImpl implements EncodableA
boolean internal = (bitfield & 0x8) == 0x8;
boolean nowait = (bitfield & 0x10) == 0x10;
FieldTable arguments = EncodingUtils.readFieldTable(buffer);
- dispatcher.receiveExchangeDeclare(channelId,
- exchange,
- type,
- passive,
- durable,
- autoDelete,
- internal,
- nowait,
- arguments);
+ if(!dispatcher.ignoreAllButCloseOk())
+ {
+ dispatcher.receiveExchangeDeclare(exchange,
+ type,
+ passive,
+ durable,
+ autoDelete,
+ internal,
+ nowait,
+ arguments);
+ }
}
}