Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Removing log.info on tests

This commit is contained in:
Clebert Suconic 2020-04-23 22:04:13 -04:00
parent 16f17853ff
commit bddb67cd9a
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/replication/SharedNothingReplicationTest.java
View File

@ -109,7 +109,7 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
locator.addClusterTopologyListener(new ClusterTopologyListener() { locator.addClusterTopologyListener(new ClusterTopologyListener() {
@Override @Override
public void nodeUP(TopologyMember member, boolean last) { public void nodeUP(TopologyMember member, boolean last) {
logger.infof("nodeUP fired last=%s, live=%s, backup=%s", last, member.getLive(), member.getBackup()); logger.debugf("nodeUP fired last=%s, live=%s, backup=%s", last, member.getLive(), member.getBackup());
if (member.getBackup() != null) { if (member.getBackup() != null) {
replicated.countDown(); replicated.countDown();
} }
@ -138,9 +138,9 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
ClientMessage message = session.createMessage(true); ClientMessage message = session.createMessage(true);
// this will make journal's append executor busy // this will make journal's append executor busy
message.putLongProperty("delay", 500L); message.putLongProperty("delay", 500L);
logger.infof("try to send a message before replicated"); logger.debugf("try to send a message before replicated");
producer.send(message); producer.send(message);
logger.info("send message done"); logger.debugf("send message done");
producer.close(); producer.close();
session.close(); session.close();
@ -168,9 +168,9 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
ClientProducer producer = session.createProducer("slow"); ClientProducer producer = session.createProducer("slow");
ClientMessage message = session.createMessage(true); ClientMessage message = session.createMessage(true);
message.putLongProperty("delay", 0L); message.putLongProperty("delay", 0L);
logger.infof("try to send a message after replicated"); logger.debugf("try to send a message after replicated");
producer.send(message); producer.send(message);
logger.info("send message done"); logger.debugf("send message done");
producer.close(); producer.close();
session.close(); session.close();
@ -204,7 +204,7 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
if (!(info.userRecordType == JournalRecordIds.ADD_MESSAGE_PROTOCOL)) { if (!(info.userRecordType == JournalRecordIds.ADD_MESSAGE_PROTOCOL)) {
// ignore // ignore
} }
logger.infof("got live message %d", info.id); logger.debugf("got live message %d", info.id);
liveJournalCounter.incrementAndGet(); liveJournalCounter.incrementAndGet();
} }
}); });
@ -224,12 +224,12 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
if (!(info.userRecordType == JournalRecordIds.ADD_MESSAGE_PROTOCOL)) { if (!(info.userRecordType == JournalRecordIds.ADD_MESSAGE_PROTOCOL)) {
// ignore // ignore
} }
logger.infof("replicated message %d", info.id); logger.debugf("replicated message %d", info.id);
replicationCounter.incrementAndGet(); replicationCounter.incrementAndGet();
} }
}); });
logger.infof("expected %d messages, live=%d, backup=%d", j, liveJournalCounter.get(), replicationCounter.get()); logger.debugf("expected %d messages, live=%d, backup=%d", j, liveJournalCounter.get(), replicationCounter.get());
Assert.assertEquals("Live lost journal record", j, liveJournalCounter.get()); Assert.assertEquals("Live lost journal record", j, liveJournalCounter.get());
Assert.assertEquals("Backup did not replicated all journal", j, replicationCounter.get()); Assert.assertEquals("Backup did not replicated all journal", j, replicationCounter.get());
@ -333,9 +333,9 @@ public class SharedNothingReplicationTest extends ActiveMQTestBase {
try { try {
Long delay = record.getLongProperty("delay"); Long delay = record.getLongProperty("delay");
if (delay == null || delay.longValue() <= 0) { if (delay == null || delay.longValue() <= 0) {
logger.infof("encode message %d, caller=%s", record.getMessageID(), Thread.currentThread().getName()); logger.debugf("encode message %d, caller=%s", record.getMessageID(), Thread.currentThread().getName());
} else { } else {
logger.infof("sleep %d ms before encode message %d, caller=%s", delay.longValue(), record.getMessageID(), Thread.currentThread().getName()); logger.debugf("sleep %d ms before encode message %d, caller=%s", delay.longValue(), record.getMessageID(), Thread.currentThread().getName());
Thread.sleep(delay.longValue()); Thread.sleep(delay.longValue());
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {