diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2009-08-03 13:27:39 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2009-08-03 13:27:39 +0000 |
| commit | 014ebe841ae307d4077a45cb522b49fe758ce9d5 (patch) | |
| tree | 8a80bca827718ab6b1e188d4c32bddd66182ec69 /qpid/java/broker/src/test | |
| parent | 4377b1a6910c7dc0c18060349e2fd6ca704b94ff (diff) | |
| download | qpid-python-014ebe841ae307d4077a45cb522b49fe758ce9d5.tar.gz | |
QPID-2002: Added testing of Channel Logging
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@800368 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test')
2 files changed, 8 insertions, 5 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 2a37eae728..b4dd3da2e6 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 @@ -27,15 +27,12 @@ public class ChannelMessagesTest extends AbstractTestMessages { public void testMessage1001() { - Integer prefetch = 12345; - - _logMessage = ChannelMessages.CHN_1001(prefetch); + _logMessage = ChannelMessages.CHN_1001(); List<Object> log = performLog(); // We use the MessageFormat here as that is what the ChannelMessage // will do, this makes the resulting value 12,345 - String[] expected = {"Create", "Prefetch", - MessageFormat.format("{0, number}", prefetch)}; + String[] expected = {"Create"}; validateLogMessage(log, "CHN-1001", expected); } diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java index b9dcd972b1..c301969ae5 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java @@ -24,6 +24,7 @@ import org.apache.qpid.AMQException; import org.apache.qpid.AMQConnectionException; import org.apache.qpid.framing.*; import org.apache.qpid.server.AMQChannel; +import org.apache.qpid.server.logging.LogActor; import org.apache.qpid.server.output.ProtocolOutputConverter; import org.apache.qpid.server.output.ProtocolOutputConverterRegistry; import org.apache.qpid.server.virtualhost.VirtualHost; @@ -62,6 +63,11 @@ public class MockProtocolSession implements AMQProtocolSession return _sessionID; } + public LogActor getLogActor() + { + return null; //To change body of implemented methods use File | Settings | File Templates. + } + public void dataBlockReceived(AMQDataBlock message) throws Exception { } |