You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/08/03 17:40:42 UTC
[activemq-artemis] 02/03: NO-JIRA using latch::countdown on
RedeployTest instead of new Runnable
This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit b6d78076d46a8a2a64047d8b9eae8f8c2faf2c56
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Tue Aug 3 12:34:18 2021 -0400
NO-JIRA using latch::countdown on RedeployTest instead of new Runnable
I have done this just because I thought it was prettier
---
.../tests/integration/jms/RedeployTest.java | 56 ++++------------------
1 file changed, 8 insertions(+), 48 deletions(-)
diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java
index 2541e1b..88ef2a9 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/RedeployTest.java
@@ -106,12 +106,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -156,12 +151,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -210,12 +200,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -266,12 +251,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -342,12 +322,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -391,12 +366,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -441,12 +411,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);
@@ -901,12 +866,7 @@ public class RedeployTest extends ActiveMQTestBase {
final ReusableLatch latch = new ReusableLatch(1);
- Runnable tick = new Runnable() {
- @Override
- public void run() {
- latch.countDown();
- }
- };
+ Runnable tick = latch::countDown;
embeddedActiveMQ.getActiveMQServer().getReloadManager().setTick(tick);