diff options
Diffstat (limited to 'java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java')
-rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java b/java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java index a97134a58d..925b161118 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java +++ b/java/broker/src/test/java/org/apache/qpid/server/util/InternalBrokerBaseCase.java @@ -44,13 +44,14 @@ import org.apache.qpid.server.store.MessageStore; import org.apache.qpid.server.store.TestableMemoryMessageStore; import org.apache.qpid.server.virtualhost.VirtualHost; import org.apache.qpid.test.utils.QpidTestCase; +import org.apache.qpid.util.MockChannel; public class InternalBrokerBaseCase extends QpidTestCase { private IApplicationRegistry _registry; private MessageStore _messageStore; - private AMQChannel _channel; + private MockChannel _channel; private InternalTestProtocolSession _session; private VirtualHost _virtualHost; private AMQQueue _queue; @@ -110,7 +111,7 @@ public class InternalBrokerBaseCase extends QpidTestCase _session = new InternalTestProtocolSession(_virtualHost); CurrentActor.set(_session.getLogActor()); - _channel = new AMQChannel(_session, 1, _messageStore); + _channel = new MockChannel(_session, 1, _messageStore); _session.addChannel(_channel); } @@ -242,7 +243,7 @@ public class InternalBrokerBaseCase extends QpidTestCase //Make Message Persistent properties.setDeliveryMode((byte) 2); - _headerBody.setProperties(properties); + _headerBody.properties = properties; channel.publishContentHeader(_headerBody); } @@ -282,12 +283,12 @@ public class InternalBrokerBaseCase extends QpidTestCase _messageStore = messageStore; } - public AMQChannel getChannel() + public MockChannel getChannel() { return _channel; } - public void setChannel(AMQChannel channel) + public void setChannel(MockChannel channel) { _channel = channel; } |