diff options
| author | Rupert Smith <rupertlssmith@apache.org> | 2007-05-21 15:11:23 +0000 |
|---|---|---|
| committer | Rupert Smith <rupertlssmith@apache.org> | 2007-05-21 15:11:23 +0000 |
| commit | eaa113f7b7640bddf8328f3e8cc24ce72fb9b52c (patch) | |
| tree | f3cf5076251648b05710c2e65ef7a37ac0ac6b04 /qpid/java/client/src/test | |
| parent | d99f53fb5ef7970a63e150af0a22347c42767dd5 (diff) | |
| download | qpid-python-eaa113f7b7640bddf8328f3e8cc24ce72fb9b52c.tar.gz | |
Refactored exceptions to have single constructors and made room for wrapped causes.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@540165 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src/test')
| -rw-r--r-- | qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java index 5e45d1d537..4a114321aa 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java @@ -67,27 +67,27 @@ public class ChannelCloseMethodHandlerNoCloseOk implements StateAwareMethodListe _logger.error("Channel close received with errorCode " + errorCode + ", and reason " + reason); if (errorCode == AMQConstant.NO_CONSUMERS) { - throw new AMQNoConsumersException("Error: " + reason, null); + throw new AMQNoConsumersException("Error: " + reason, null, null); } else if (errorCode == AMQConstant.NO_ROUTE) { - throw new AMQNoRouteException("Error: " + reason, null); + throw new AMQNoRouteException("Error: " + reason, null, null); } else if (errorCode == AMQConstant.INVALID_ARGUMENT) { _logger.debug("Broker responded with Invalid Argument."); - throw new AMQInvalidArgumentException(String.valueOf(reason)); + throw new AMQInvalidArgumentException(String.valueOf(reason), null); } else if (errorCode == AMQConstant.INVALID_ROUTING_KEY) { _logger.debug("Broker responded with Invalid Routing Key."); - throw new AMQInvalidRoutingKeyException(String.valueOf(reason)); + throw new AMQInvalidRoutingKeyException(String.valueOf(reason), null); } else { - throw new AMQChannelClosedException(errorCode, "Error: " + reason); + throw new AMQChannelClosedException(errorCode, "Error: " + reason, null); } } |
