diff options
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 { } |