You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by bo...@apache.org on 2015/10/09 09:29:57 UTC
qpid-proton git commit: PROTON-1017: Add a (ignored) test
Repository: qpid-proton
Updated Branches:
refs/heads/master f6444b2a1 -> 4f6d9fb53
PROTON-1017: Add a (ignored) test
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/4f6d9fb5
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/4f6d9fb5
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/4f6d9fb5
Branch: refs/heads/master
Commit: 4f6d9fb5345c24b8d4f4dd5a1d79c0f8e0fb79c8
Parents: f6444b2
Author: Bozo Dragojevic <bo...@digiverse.si>
Authored: Fri Oct 9 09:26:51 2015 +0200
Committer: Bozo Dragojevic <bo...@digiverse.si>
Committed: Fri Oct 9 09:29:37 2015 +0200
----------------------------------------------------------------------
.../systemtests/ProtonEngineExampleTest.java | 75 ++++++++++++++++++++
1 file changed, 75 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/4f6d9fb5/proton-j/src/test/java/org/apache/qpid/proton/systemtests/ProtonEngineExampleTest.java
----------------------------------------------------------------------
diff --git a/proton-j/src/test/java/org/apache/qpid/proton/systemtests/ProtonEngineExampleTest.java b/proton-j/src/test/java/org/apache/qpid/proton/systemtests/ProtonEngineExampleTest.java
index a24bbdd..21a9210 100644
--- a/proton-j/src/test/java/org/apache/qpid/proton/systemtests/ProtonEngineExampleTest.java
+++ b/proton-j/src/test/java/org/apache/qpid/proton/systemtests/ProtonEngineExampleTest.java
@@ -43,6 +43,7 @@ import org.apache.qpid.proton.amqp.transport.SenderSettleMode;
import org.apache.qpid.proton.engine.Delivery;
import org.apache.qpid.proton.engine.Receiver;
import org.apache.qpid.proton.message.Message;
+import org.junit.Ignore;
import org.junit.Test;
/**
@@ -303,6 +304,80 @@ public class ProtonEngineExampleTest extends EngineTestBase
LOGGER.fine(bold("======== Done!"));
}
+ @Ignore("This test does not have a fix yet")
+ @Test
+ public void testPROTON_1017() throws Exception
+ {
+ LOGGER.fine(bold("======== About to create transports"));
+
+ getClient().transport = Proton.transport();
+ ProtocolTracerEnabler.setProtocolTracer(getClient().transport, TestLoggingHelper.CLIENT_PREFIX);
+
+ getServer().transport = Proton.transport();
+ ProtocolTracerEnabler.setProtocolTracer(getServer().transport, " " + TestLoggingHelper.SERVER_PREFIX);
+
+ doOutputInputCycle();
+
+ getClient().connection = Proton.connection();
+ getClient().transport.bind(getClient().connection);
+
+ getServer().connection = Proton.connection();
+ getServer().transport.bind(getServer().connection);
+
+
+
+ LOGGER.fine(bold("======== About to open connections"));
+ getClient().connection.open();
+ getServer().connection.open();
+
+ doOutputInputCycle();
+
+
+
+ LOGGER.fine(bold("======== About to open and close client session"));
+ getClient().session = getClient().connection.session();
+ getClient().session.open();
+ getClient().session.close();
+ pumpClientToServer();
+
+ getServer().session = getServer().connection.sessionHead(of(UNINITIALIZED), of(CLOSED));
+ assertEndpointState(getServer().session, UNINITIALIZED, CLOSED);
+
+ getServer().session.open();
+ assertEndpointState(getServer().session, ACTIVE, CLOSED);
+
+ getServer().session.close();
+ assertEndpointState(getServer().session, CLOSED, CLOSED);
+
+ pumpServerToClient();
+ assertEndpointState(getClient().session, CLOSED, CLOSED);
+
+
+ LOGGER.fine(bold("======== About to close client's connection"));
+
+ getClient().connection.close();
+
+ pumpClientToServer();
+
+
+ LOGGER.fine(bold("======== Server about to process client's connection closure"));
+
+ assertEquals(CLOSED, getServer().connection.getRemoteState());
+ getServer().connection.close();
+
+ pumpServerToClient();
+
+
+ LOGGER.fine(bold("======== Checking client has nothing more to pump"));
+
+
+ assertClientHasNothingToOutput();
+
+ LOGGER.fine(bold("======== Done!"));
+ }
+
+
+
/**
* Simulates creating a local terminus using the properties supplied by the remote link endpoint.
*
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org