You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2018/05/18 16:31:14 UTC
qpid-jms-amqp-0-x git commit: NO-JIRA: Add extra debug logging and
add asserts to verify broker store persistence
Repository: qpid-jms-amqp-0-x
Updated Branches:
refs/heads/master f88d51591 -> 0363e6963
NO-JIRA: Add extra debug logging and add asserts to verify broker store persistence
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/commit/0363e696
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/tree/0363e696
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/diff/0363e696
Branch: refs/heads/master
Commit: 0363e696399655cc94565354153fe650fd1b6075
Parents: f88d515
Author: Alex Rudyy <or...@apache.org>
Authored: Fri May 18 17:29:21 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Fri May 18 17:29:21 2018 +0100
----------------------------------------------------------------------
.../qpid/systest/core/brokerj/SpawnQpidBrokerAdmin.java | 2 +-
.../apache/qpid/systest/core/cpp/SpawnQpidBrokerAdmin.java | 7 +++++++
.../qpid/systest/connection/FailoverBehaviourTest.java | 8 +++++++-
.../qpid/systest/core/brokerj/SpawnQpidBrokerAdminTest.java | 1 -
4 files changed, 15 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/0363e696/systests/src/main/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdmin.java
----------------------------------------------------------------------
diff --git a/systests/src/main/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdmin.java b/systests/src/main/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdmin.java
index b3c967f..c2379b8 100644
--- a/systests/src/main/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdmin.java
+++ b/systests/src/main/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdmin.java
@@ -281,7 +281,7 @@ public class SpawnQpidBrokerAdmin extends AbstractSpawnQpidBrokerAdmin
jvmArguments.add("--initial-config-path");
jvmArguments.add(escapePath(testInitialConfiguration.toString()));
- LOGGER.debug("Spawning broker JVM :", jvmArguments);
+ LOGGER.debug("Spawning broker JVM : {}", jvmArguments);
String[] cmd = jvmArguments.toArray(new String[jvmArguments.size()]);
return new ProcessBuilder(cmd);
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/0363e696/systests/src/main/java/org/apache/qpid/systest/core/cpp/SpawnQpidBrokerAdmin.java
----------------------------------------------------------------------
diff --git a/systests/src/main/java/org/apache/qpid/systest/core/cpp/SpawnQpidBrokerAdmin.java b/systests/src/main/java/org/apache/qpid/systest/core/cpp/SpawnQpidBrokerAdmin.java
index 5cc27d2..764402b 100644
--- a/systests/src/main/java/org/apache/qpid/systest/core/cpp/SpawnQpidBrokerAdmin.java
+++ b/systests/src/main/java/org/apache/qpid/systest/core/cpp/SpawnQpidBrokerAdmin.java
@@ -27,12 +27,17 @@ import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import org.apache.qpid.systest.core.AbstractSpawnQpidBrokerAdmin;
import org.apache.qpid.systest.core.BrokerAdminException;
import org.apache.qpid.systest.core.LogConsumer;
public class SpawnQpidBrokerAdmin extends AbstractSpawnQpidBrokerAdmin
{
+ private static final Logger LOGGER = LoggerFactory.getLogger(SpawnQpidBrokerAdmin.class);
+
private static final String SYSTEST_PROPERTY_BROKER_EXECUTABLE = "qpid.systest.broker.executable";
private static final String SYSTEST_PROPERTY_BROKER_MODULE_DIR = "qpid.systest.broker.moduleDir";
private static final String SYSTEST_PROPERTY_BROKER_STORE_INITIALIZED = "qpid.systest.broker.storeInitialized";
@@ -143,6 +148,7 @@ public class SpawnQpidBrokerAdmin extends AbstractSpawnQpidBrokerAdmin
@Override
public void restart()
{
+ LOGGER.info("Restarting the broker");
try
{
_previousPort = getBrokerAddress(PortType.AMQP).getPort();
@@ -195,6 +201,7 @@ public class SpawnQpidBrokerAdmin extends AbstractSpawnQpidBrokerAdmin
cmd.add("--no-module-dir");
}
+ LOGGER.info("Spawning cpp broker : {}", cmd );
return new ProcessBuilder(cmd);
}
}
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/0363e696/systests/src/test/java/org/apache/qpid/systest/connection/FailoverBehaviourTest.java
----------------------------------------------------------------------
diff --git a/systests/src/test/java/org/apache/qpid/systest/connection/FailoverBehaviourTest.java b/systests/src/test/java/org/apache/qpid/systest/connection/FailoverBehaviourTest.java
index 6654a4a..9601de6 100644
--- a/systests/src/test/java/org/apache/qpid/systest/connection/FailoverBehaviourTest.java
+++ b/systests/src/test/java/org/apache/qpid/systest/connection/FailoverBehaviourTest.java
@@ -232,6 +232,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testTransactionRolledBackExceptionThrownOnCommitAfterFailoverOnMessageReceiving() throws Exception
{
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.SESSION_TRANSACTED, true);
produceMessages();
_producerSession.commit();
@@ -284,6 +285,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testRollbackAfterFailover() throws Exception
{
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.SESSION_TRANSACTED, true);
produceMessages();
@@ -332,6 +334,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testRecoverAfterFailover() throws Exception
{
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.CLIENT_ACKNOWLEDGE, true);
produceMessages();
@@ -356,6 +359,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testRecoverWithConsumedMessagesAfterFailover() throws Exception
{
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.CLIENT_ACKNOWLEDGE, true);
produceMessages();
@@ -385,7 +389,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testAcknowledgeAfterFailover() throws Exception
{
- LOGGER.debug("KWDEBUG");
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.CLIENT_ACKNOWLEDGE, true);
produceMessages();
@@ -442,6 +446,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testAcknowledgeAfterMessageReceivingAfterFailover() throws Exception
{
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.CLIENT_ACKNOWLEDGE, true);
produceMessages();
@@ -830,6 +835,7 @@ public class FailoverBehaviourTest extends JmsTestBase implements ExceptionListe
@Test
public void testFailoverWhenConnectionStopped() throws Exception
{
+ assumeTrue(getBrokerAdmin().supportsPersistence());
init(Session.SESSION_TRANSACTED, true);
produceMessages();
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/0363e696/systests/src/test/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdminTest.java
----------------------------------------------------------------------
diff --git a/systests/src/test/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdminTest.java b/systests/src/test/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdminTest.java
index fa25dac..335b5d8 100644
--- a/systests/src/test/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdminTest.java
+++ b/systests/src/test/java/org/apache/qpid/systest/core/brokerj/SpawnQpidBrokerAdminTest.java
@@ -27,7 +27,6 @@ import static org.apache.qpid.systest.core.brokerj.SpawnQpidBrokerAdmin.SYSTEST_
import static org.apache.qpid.systest.core.brokerj.SpawnQpidBrokerAdmin.SYSTEST_PROPERTY_VIRTUALHOSTNODE_TYPE;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.CoreMatchers.notNullValue;
-import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
import static org.junit.Assume.assumeThat;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org