qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject [15/50] [abbrv] qpid-proton git commit: PROTON-1017: Add a (ignored) test
Date Fri, 23 Oct 2015 14:36:17 GMT
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/go1
Commit: 4f6d9fb5345c24b8d4f4dd5a1d79c0f8e0fb79c8
Parents: f6444b2
Author: Bozo Dragojevic <bozzo@digiverse.si>
Authored: Fri Oct 9 09:26:51 2015 +0200
Committer: Bozo Dragojevic <bozzo@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


Mime
View raw message