diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2009-11-26 16:14:19 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2009-11-26 16:14:19 +0000 |
| commit | c1b62c2215391a3c785f18711bfb5bdefa946652 (patch) | |
| tree | 72080a9b4803edb239e91bc99b9ae400286d787f /java/broker | |
| parent | 471af25ece45407939721d8492d758e5cb16f73b (diff) | |
| download | qpid-python-c1b62c2215391a3c785f18711bfb5bdefa946652.tar.gz | |
Fixes for 0-9-1 support
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@884619 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java | 6 | ||||
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java index d4272239d1..31401ce9d9 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java +++ b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueUnbindHandler.java @@ -78,7 +78,7 @@ public class QueueUnbindHandler implements StateAwareMethodListener<QueueUnbindB if (queue == null) { - throw body.getConnectionException(AMQConstant.NOT_FOUND, "No default queue defined on channel and queue was null"); + throw body.getChannelException(AMQConstant.NOT_FOUND, "No default queue defined on channel and queue was null"); } routingKey = body.getRoutingKey() == null ? null : body.getRoutingKey().intern(); @@ -92,7 +92,7 @@ public class QueueUnbindHandler implements StateAwareMethodListener<QueueUnbindB if (queue == null) { - throw body.getConnectionException(AMQConstant.NOT_FOUND, "Queue " + body.getQueue() + " does not exist."); + throw body.getChannelException(AMQConstant.NOT_FOUND, "Queue " + body.getQueue() + " does not exist."); } final Exchange exch = exchangeRegistry.getExchange(body.getExchange()); if (exch == null) @@ -118,7 +118,7 @@ public class QueueUnbindHandler implements StateAwareMethodListener<QueueUnbindB { if(e.getErrorCode() == AMQConstant.NOT_FOUND) { - throw body.getConnectionException(AMQConstant.NOT_FOUND,e.getMessage(),e); + throw body.getChannelException(AMQConstant.NOT_FOUND,e.getMessage(),e); } throw body.getChannelException(AMQConstant.CHANNEL_ERROR, e.toString()); } diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java index 04b3e75f8c..0824d12416 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java +++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolEngine.java @@ -341,7 +341,7 @@ public class AMQProtocolEngine implements ProtocolEngine, Managable, AMQProtocol String locales = "en_US"; AMQMethodBody responseBody = getMethodRegistry().createConnectionStartBody((short) getProtocolMajorVersion(), - (short) getProtocolMinorVersion(), + (short) pv.getActualMinorVersion(), null, mechanisms.getBytes(), locales.getBytes()); |