diff options
Diffstat (limited to 'java/client/src/test')
| -rw-r--r-- | 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/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java b/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java index 5e45d1d537..4a114321aa 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java +++ b/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); } } |