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 2020/09/13 20:08:54 UTC
[qpid-broker-j] branch 7.1.x updated: NO-JIRA: Add debug logging
into MultiNodeTest#transferMasterFromRemoteNode
This is an automated email from the ASF dual-hosted git repository.
orudyy pushed a commit to branch 7.1.x
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
The following commit(s) were added to refs/heads/7.1.x by this push:
new f6a159c NO-JIRA: Add debug logging into MultiNodeTest#transferMasterFromRemoteNode
f6a159c is described below
commit f6a159c8d4401c71662cf6bc64a3aad38ee3025a
Author: Alex Rudyy <or...@apache.org>
AuthorDate: Sun Sep 13 21:08:12 2020 +0100
NO-JIRA: Add debug logging into MultiNodeTest#transferMasterFromRemoteNode
---
.../store/berkeleydb/replication/GroupBrokerAdmin.java | 12 +++++++++++-
.../server/store/berkeleydb/replication/MultiNodeTest.java | 3 +++
2 files changed, 14 insertions(+), 1 deletion(-)
diff --git a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupBrokerAdmin.java b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupBrokerAdmin.java
index 583a025..4473b40 100644
--- a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupBrokerAdmin.java
+++ b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/GroupBrokerAdmin.java
@@ -391,7 +391,7 @@ public class GroupBrokerAdmin
return members;
}
- private GroupMember getMemberByAmqpPort(final int amqpPort)
+ GroupMember getMemberByAmqpPort(final int amqpPort)
{
return Arrays.stream(_members)
.filter(m -> m.getAmqpPort() == amqpPort)
@@ -521,5 +521,15 @@ public class GroupBrokerAdmin
{
return _nodeAttributes;
}
+
+ @Override
+ public String toString()
+ {
+ return "GroupMember{" +
+ "name='" + _name + '\'' +
+ ",bdbPort=" + _bdbPort +
+ ",amqpPort=" + _amqpPort +
+ '}';
+ }
}
}
diff --git a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
index bf1cfed..b6463bc 100644
--- a/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
+++ b/bdbstore/systests/src/test/java/org/apache/qpid/server/store/berkeleydb/replication/MultiNodeTest.java
@@ -368,6 +368,9 @@ public class MultiNodeTest extends GroupJmsTestBase
final int activeBrokerPort,
final int inactiveBrokerPort) throws Exception
{
+ LOGGER.info("Transfer mastership to {} from {}",
+ getBrokerAdmin().getMemberByAmqpPort(inactiveBrokerPort),
+ getBrokerAdmin().getMemberByAmqpPort(activeBrokerPort));
_failoverListener = new FailoverAwaitingListener();
getJmsProvider().addGenericConnectionListener(connection, _failoverListener);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org