diff options
| author | Alex Rudyy <orudyy@apache.org> | 2013-06-26 14:53:34 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2013-06-26 14:53:34 +0000 |
| commit | 8bdc5010fef590e5dc3c424b1f41f8df42c47c11 (patch) | |
| tree | 4805fd38f0f9a321581cfb0079e1ef2dd571e84e /qpid/java/broker/src/test | |
| parent | 92067361c279257be2b2ee73484da61c9327c05a (diff) | |
| download | qpid-python-8bdc5010fef590e5dc3c424b1f41f8df42c47c11.tar.gz | |
QPID-4951: Add cause code and message into operational logs for session close initiated by the Broker
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1496951 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test')
2 files changed, 14 insertions, 0 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java index e94b79ba95..2f1276508c 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/logging/messages/ChannelMessagesTest.java @@ -61,4 +61,13 @@ public class ChannelMessagesTest extends AbstractTestMessages validateLogMessage(log, "CHN-1003", expected); } + public void testChannelCloseForced() + { + _logMessage = ChannelMessages.CLOSE_FORCED(1, "Test"); + List<Object> log = performLog(); + + String[] expected = {"Close : 1 - Test"}; + + validateLogMessage(log, "CHN-1003", expected); + } } diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java index 7f797afeda..ed60d5374b 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java @@ -405,6 +405,11 @@ public class MockSubscription implements Subscription { return getId().compareTo(o.getId()); } + + @Override + public void close(AMQConstant cause, String message) throws AMQException + { + } } private static class MockConnectionModel implements AMQConnectionModel |