diff options
| author | Keith Wall <kwall@apache.org> | 2011-11-09 08:58:59 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2011-11-09 08:58:59 +0000 |
| commit | cc6ee2720ce235498297d76f35da4aea2c557de2 (patch) | |
| tree | eb8fcf6c3986a0063edd3080f9086e1107d45f7b /qpid/java/client/src/test | |
| parent | 960385b344d5ed47ac42c11438abba17f9e8f9a9 (diff) | |
| download | qpid-python-cc6ee2720ce235498297d76f35da4aea2c557de2.tar.gz | |
QPID-3518: Introduce client side ability to detect server side support.
Applied patch from Oleksandr Rudyy<orudyy@gmail.com> and myself.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1199662 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src/test')
| -rw-r--r-- | qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java | 7 | ||||
| -rw-r--r-- | qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java | 6 |
2 files changed, 10 insertions, 3 deletions
diff --git a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java index b5e7ae82b5..cd18b5181f 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java @@ -47,12 +47,17 @@ public class MessageConverterTest extends TestCase protected JMSTextMessage testTextMessage; protected JMSMapMessage testMapMessage; - private AMQSession _session = new TestAMQSession(); + private AMQConnection _connection; + private AMQSession _session; protected void setUp() throws Exception { super.setUp(); + + _connection = new MockAMQConnection("amqp://guest:guest@client/test?brokerlist='tcp://localhost:1'"); + _session = new TestAMQSession(_connection); + testTextMessage = new JMSTextMessage(AMQMessageDelegateFactory.FACTORY_0_8); //Set Message Text diff --git a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java index b9d1476055..06d0f4a3f9 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java @@ -29,10 +29,12 @@ import javax.jms.Topic; import javax.jms.TopicSubscriber; import org.apache.qpid.AMQException; +import org.apache.qpid.client.AMQConnection; import org.apache.qpid.client.AMQDestination; import org.apache.qpid.client.AMQSession; import org.apache.qpid.client.BasicMessageConsumer_0_8; import org.apache.qpid.client.BasicMessageProducer_0_8; +import org.apache.qpid.client.MockAMQConnection; import org.apache.qpid.client.failover.FailoverException; import org.apache.qpid.client.message.AMQMessageDelegateFactory; import org.apache.qpid.client.protocol.AMQProtocolHandler; @@ -43,9 +45,9 @@ import org.apache.qpid.framing.FieldTable; public class TestAMQSession extends AMQSession<BasicMessageConsumer_0_8, BasicMessageProducer_0_8> { - public TestAMQSession() + public TestAMQSession(AMQConnection connection) { - super(null, 0, false, AUTO_ACKNOWLEDGE, null, 0, 0); + super(connection, 0, false, AUTO_ACKNOWLEDGE, null, 0, 0); } public void acknowledgeMessage(long deliveryTag, boolean multiple) |