You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2014/11/13 12:54:57 UTC
[3/3] qpid-jms git commit: Start on brokerless integration test of
transactions. Need to flesh out DataImpl array handling to proceed.
Start on brokerless integration test of transactions. Need to flesh out DataImpl array handling to proceed.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b0a29665
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b0a29665
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b0a29665
Branch: refs/heads/master
Commit: b0a2966564b8fc7fb76b32c090f511a06ad198eb
Parents: 017d006
Author: Robert Gemmell <ro...@apache.org>
Authored: Thu Nov 13 11:51:56 2014 +0000
Committer: Robert Gemmell <ro...@apache.org>
Committed: Thu Nov 13 11:51:56 2014 +0000
----------------------------------------------------------------------
.../jms/integration/ConnectionIntegrationTest.java | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b0a29665/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java
index 3a7b6ac..6ebc02a 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/ConnectionIntegrationTest.java
@@ -29,6 +29,8 @@ import javax.jms.Session;
import org.apache.qpid.jms.test.QpidJmsTestCase;
import org.apache.qpid.jms.test.testpeer.TestAmqpPeer;
+import org.apache.qpid.jms.test.testpeer.matchers.CoordinatorMatcher;
+import org.junit.Ignore;
import org.junit.Test;
// TODO find a way to make the test abort immediately if the TestAmqpPeer throws an exception
@@ -55,6 +57,21 @@ public class ConnectionIntegrationTest extends QpidJmsTestCase {
}
@Test(timeout=5000)
+ @Ignore // TODO: fails because DataImpl used to encode the TestPeer output can't encode arrays yet
+ public void testCreateTransactedSession() throws Exception {
+ try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) {
+ Connection connection = testFixture.establishConnecton(testPeer);
+
+ CoordinatorMatcher txCoordinatorMatcher = new CoordinatorMatcher();
+
+ testPeer.expectBegin(true);
+ testPeer.expectSenderAttach(txCoordinatorMatcher, false, false);
+ Session session = connection.createSession(true, Session.SESSION_TRANSACTED);
+ assertNotNull("Session should not be null", session);
+ }
+ }
+
+ @Test(timeout=5000)
public void testConnectionMetaDataVersion() throws Exception {
try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) {
Connection connection = testFixture.establishConnecton(testPeer);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org