[1/2] activemq-artemis git commit: ARTEMIS-1447 Reuse thread pools on JDBC Locks

2017-10-27 Thread clebertsuconic 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 6cc786ff1 -> 60ce40f3a


ARTEMIS-1447 Reuse thread pools on JDBC Locks

I had moved the initialization of the thread pools for that..
I also have changed the CrticialAnalyzer to use the same pools as part of this


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/1af6d986
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/1af6d986
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/1af6d986

Branch: refs/heads/master
Commit: 1af6d986a570f4c0db87cdd141fad3c66b84ea92
Parents: 6cc786f
Author: Clebert Suconic 
Authored: Fri Oct 27 15:14:28 2017 -0400
Committer: Clebert Suconic 
Committed: Fri Oct 27 22:32:53 2017 -0400

--
 .../core/server/ActiveMQScheduledComponent.java |  7 ++
 .../utils/critical/CriticalAnalyzerImpl.java| 85 
 .../core/server/impl/ActiveMQServerImpl.java| 12 +--
 3 files changed, 47 insertions(+), 57 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1af6d986/artemis-commons/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQScheduledComponent.java
--
diff --git 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQScheduledComponent.java
 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQScheduledComponent.java
index d9a8938..0ca8255 100644
--- 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQScheduledComponent.java
+++ 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQScheduledComponent.java
@@ -188,6 +188,13 @@ public abstract class ActiveMQScheduledComponent 
implements ActiveMQComponent, R
   return this;
}
 
+   public synchronized ActiveMQScheduledComponent setPeriod(long period, 
TimeUnit unit) {
+  this.period = period;
+  this.timeUnit = unit;
+  restartIfNeeded();
+  return this;
+   }
+
public long getInitialDelay() {
   return initialDelay;
}

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1af6d986/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/critical/CriticalAnalyzerImpl.java
--
diff --git 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/critical/CriticalAnalyzerImpl.java
 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/critical/CriticalAnalyzerImpl.java
index 55c1854..1c2c0eb 100644
--- 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/critical/CriticalAnalyzerImpl.java
+++ 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/critical/CriticalAnalyzerImpl.java
@@ -19,9 +19,10 @@ package org.apache.activemq.artemis.utils.critical;
 
 import java.util.ConcurrentModificationException;
 import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.Semaphore;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
 
+import org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent;
 import org.apache.activemq.artemis.utils.collections.ConcurrentHashSet;
 import org.jboss.logging.Logger;
 
@@ -31,7 +32,29 @@ public class CriticalAnalyzerImpl implements 
CriticalAnalyzer {
 
private volatile long timeoutNanoSeconds;
 
-   private volatile long checkTimeNanoSeconds;
+   // one minute by default.. the server will change it for sure
+   private volatile long checkTimeNanoSeconds = TimeUnit.SECONDS.toNanos(60);
+
+   private final ActiveMQScheduledComponent scheduledComponent;
+
+   private final AtomicBoolean running = new AtomicBoolean(false);
+
+   public CriticalAnalyzerImpl() {
+  // this will make the scheduled component to start its own pool
+
+  /* Important: The scheduled component should have its own thread pool...
+   *  otherwise in case of a deadlock, or a starvation of the server the 
analyzer won't pick up any
+   *  issues and won't be able to shutdown the server or halt the VM
+   */
+  this.scheduledComponent = new ActiveMQScheduledComponent(null, null, 
checkTimeNanoSeconds, TimeUnit.NANOSECONDS, false) {
+ @Override
+ public void run() {
+logger.trace("Checking critical analyzer");
+check();
+ }
+  };
+
+   }
 
@Override
public void clear() {
@@ -41,10 +64,6 @@ public class CriticalAnalyzerImpl implements 
CriticalAnalyzer {
 
private CopyOnWriteArrayList actions = new 
CopyOnWriteArrayList<>();
 
-   private Thread thread;
-
-   private final Semaphore running = new Semaphore(1);
-

[2/2] activemq-artemis git commit: This closes #1620

2017-10-27 Thread clebertsuconic 
This closes #1620


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/60ce40f3
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/60ce40f3
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/60ce40f3

Branch: refs/heads/master
Commit: 60ce40f3a82bd3b99d08da6fa3dc164449391adc
Parents: 6cc786f 1af6d98
Author: Clebert Suconic 
Authored: Fri Oct 27 23:07:31 2017 -0400
Committer: Clebert Suconic 
Committed: Fri Oct 27 23:07:31 2017 -0400

--
 .../core/server/ActiveMQScheduledComponent.java |  7 ++
 .../utils/critical/CriticalAnalyzerImpl.java| 85 
 .../core/server/impl/ActiveMQServerImpl.java| 12 +--
 3 files changed, 47 insertions(+), 57 deletions(-)
--

Jenkins build became unstable: ActiveMQ-Java8 » ActiveMQ :: Unit Tests #1083

2017-10-27 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: MQTT Protocol #1083

2017-10-27 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java8 #1083

2017-10-27 Thread Apache Jenkins Server 
See

[1/2] activemq-artemis git commit: This closes #1619

2017-10-27 Thread jbertram 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master dc4681b0d -> 6cc786ff1


This closes #1619


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6cc786ff
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6cc786ff
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6cc786ff

Branch: refs/heads/master
Commit: 6cc786ff152117e98a2c1786a16e679f5bdb65f3
Parents: dc4681b 33cab06
Author: Justin Bertram 
Authored: Fri Oct 27 12:26:48 2017 -0500
Committer: Justin Bertram 
Committed: Fri Oct 27 12:26:48 2017 -0500

--
 .../server/impl/jdbc/ActiveMQScheduledLeaseLock.java|  2 +-
 .../artemis/core/server/impl/jdbc/JdbcNodeManager.java  | 12 
 2 files changed, 9 insertions(+), 5 deletions(-)
--

[2/2] activemq-artemis git commit: ARTEMIS-1447 JDBC NodeManager to support JDBC HA Shared Store

2017-10-27 Thread jbertram 
ARTEMIS-1447 JDBC NodeManager to support JDBC HA Shared Store

It fixes the NPE on server start due to:
 - missing SqlProviderFactory
 - missing executor factory/scheduled pool (ie using exclusive scheduled pools)

It fixes the WARNINGS due to wrong slowness detection while renewing 
JdbcLeaseLock.


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/33cab063
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/33cab063
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/33cab063

Branch: refs/heads/master
Commit: 33cab063eab6e45a594132e4a19d41da98ac70db
Parents: dc4681b
Author: Francesco Nigro 
Authored: Fri Oct 27 17:43:29 2017 +0200
Committer: Justin Bertram 
Committed: Fri Oct 27 12:26:48 2017 -0500

--
 .../server/impl/jdbc/ActiveMQScheduledLeaseLock.java|  2 +-
 .../artemis/core/server/impl/jdbc/JdbcNodeManager.java  | 12 
 2 files changed, 9 insertions(+), 5 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/33cab063/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/ActiveMQScheduledLeaseLock.java
--
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/ActiveMQScheduledLeaseLock.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/ActiveMQScheduledLeaseLock.java
index 30db629..89762dc 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/ActiveMQScheduledLeaseLock.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/ActiveMQScheduledLeaseLock.java
@@ -92,7 +92,7 @@ final class ActiveMQScheduledLeaseLock extends 
ActiveMQScheduledComponent implem
   }
   //logic to detect slowness of DB and/or the scheduled executor service
   detectAndReportRenewSlowness(lockName, lastRenewStart, renewStart, 
renewPeriodMillis, lock.expirationMillis());
-  this.lastLockRenewStart = lastRenewStart;
+  this.lastLockRenewStart = renewStart;
}
 
private static void detectAndReportRenewSlowness(String lockName,

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/33cab063/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/JdbcNodeManager.java
--
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/JdbcNodeManager.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/JdbcNodeManager.java
index f4baeea..8cb852d 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/JdbcNodeManager.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/jdbc/JdbcNodeManager.java
@@ -28,6 +28,8 @@ import 
org.apache.activemq.artemis.core.io.IOCriticalErrorListener;
 import org.apache.activemq.artemis.core.server.ActivateCallback;
 import org.apache.activemq.artemis.core.server.ActiveMQServerLogger;
 import org.apache.activemq.artemis.core.server.NodeManager;
+import org.apache.activemq.artemis.jdbc.store.drivers.JDBCUtils;
+import org.apache.activemq.artemis.jdbc.store.sql.GenericSQLProvider;
 import org.apache.activemq.artemis.jdbc.store.sql.SQLProvider;
 import org.apache.activemq.artemis.utils.ExecutorFactory;
 import org.apache.activemq.artemis.utils.UUID;
@@ -56,11 +58,13 @@ public final class JdbcNodeManager extends NodeManager {
   ExecutorFactory executorFactory,
   IOCriticalErrorListener 
ioCriticalErrorListener) {
   if (configuration.getDataSource() != null) {
+ final SQLProvider.Factory sqlProviderFactory = 
configuration.getSqlProviderFactory() == null ? new 
GenericSQLProvider.Factory() : configuration.getSqlProviderFactory();
  final String brokerId = java.util.UUID.randomUUID().toString();
- return usingDataSource(brokerId, 
configuration.getJdbcLockExpirationMillis(), 
configuration.getJdbcLockRenewPeriodMillis(), 
configuration.getJdbcLockAcquisitionTimeoutMillis(), 
configuration.getDataSource(), 
configuration.getSqlProviderFactory().create(configuration.getNodeManagerStoreTableName(),
 SQLProvider.DatabaseStoreType.NODE_MANAGER), scheduledExecutorService, 
executorFactory, ioCriticalErrorListener);
+ return usingDataSource(brokerId, 
configuration.getJdbcLockExpirationMillis(), 
configuration.getJdbcLockRenewPeriodMillis(), 
configuration.getJdbcLockAcquisitionTimeoutMillis(), 
configuration.getDataSource(),

[2/2] activemq-artemis git commit: ARTEMIS-1483 upgrade beanutils

2017-10-27 Thread michaelpearce 
ARTEMIS-1483 upgrade beanutils


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ba01bf70
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ba01bf70
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ba01bf70

Branch: refs/heads/master
Commit: ba01bf70734a0aa6ad614b4dfc7a3401dfae3c39
Parents: 7a3317c
Author: Justin Bertram 
Authored: Fri Oct 27 07:41:14 2017 -0500
Committer: Michael André Pearce 
Committed: Fri Oct 27 16:47:11 2017 +0100

--
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ba01bf70/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 9a74e95..dbab986 100644
--- a/pom.xml
+++ b/pom.xml
@@ -77,7 +77,7 @@
   3.0
   5.14.5
   10.11.1.1
-  1.9.2
+  1.9.3
   2.1.10
   3.2.2
   1.14

[1/2] activemq-artemis git commit: This closes #1618

2017-10-27 Thread michaelpearce 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 7a3317c56 -> dc4681b0d


This closes #1618


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/dc4681b0
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/dc4681b0
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/dc4681b0

Branch: refs/heads/master
Commit: dc4681b0d7010684a0b848ea2eea2b78b2eac14c
Parents: 7a3317c ba01bf7
Author: Michael André Pearce 
Authored: Fri Oct 27 16:47:11 2017 +0100
Committer: Michael André Pearce 
Committed: Fri Oct 27 16:47:11 2017 +0100

--
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--

[2/2] activemq-artemis git commit: ARTEMIS-1467 clean up example

2017-10-27 Thread michaelpearce 
ARTEMIS-1467 clean up example

- Rename example project
- Leverage built-in 5.x Camel support instead of using WAR
- Clarify instructions
- Fix pom names/structure


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b07588a0
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b07588a0
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b07588a0

Branch: refs/heads/master
Commit: b07588a020aa3fb8cc8ac55bda8d555203b93fc9
Parents: 6d8e89d
Author: Justin Bertram 
Authored: Thu Oct 26 15:37:17 2017 -0500
Committer: Michael André Pearce 
Committed: Fri Oct 27 16:44:12 2017 +0100

--
 .../sub-modules/artemis-jms-bridge/README.md|  93 
 .../activemq-artemis-camel/pom.xml  | 101 -
 .../src/main/resources/bridge.xml   |  67 -
 .../src/main/webapp/WEB-INF/web.xml |  30 
 .../artemis-jms-bridge/pom.xml  |  99 -
 .../bridge/ConnectionFactoryFactoryBean.java|  35 -
 .../artemis/bridge/DestinationFactoryBean.java  |  36 -
 .../src/main/resources/bridge.xml   |  69 -
 .../src/main/webapp/WEB-INF/web.xml |  30 
 .../sub-modules/artemis-jms-bridge/pom.xml  |  64 
 .../artemis-jms-bridge/README.md| 148 +++
 .../artemis-jms-bridge/pom.xml  |  93 
 .../bridge/ConnectionFactoryFactoryBean.java|  32 
 .../artemis/bridge/DestinationFactoryBean.java  |  33 +
 .../src/main/resources/bridge.xml   |  66 +
 .../src/main/webapp/WEB-INF/web.xml |  30 
 .../sub-modules/inter-broker-bridge/pom.xml |  39 +
 examples/features/sub-modules/pom.xml   |   2 +-
 pom.xml |   9 +-
 19 files changed, 447 insertions(+), 629 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b07588a0/examples/features/sub-modules/artemis-jms-bridge/README.md
--
diff --git a/examples/features/sub-modules/artemis-jms-bridge/README.md 
b/examples/features/sub-modules/artemis-jms-bridge/README.md
deleted file mode 100644
index 9f60eb4..000
--- a/examples/features/sub-modules/artemis-jms-bridge/README.md
+++ /dev/null
@@ -1,93 +0,0 @@
-# artemis-jms-bridge
-
-An example project showing how to do different varieties of bridging with 
ActiveMQ Brokers.
-
-## ActiveMQ to Artemis Camel Bridge
-
-This is an example of using Camel in the ActiveMQ broker to bridge messages 
between ActiveMQ and Artemis.
-
-### Prerequisites
-
-- install ActiveMQ
-- install Artemis
-
-### Preparing
-
-From the root directory run `mvn clean package`
-
-Copy activemq-artemis-camel/target/activemq-artemis-camel-1.0.0-SNAPSHOT.war 
to the deploy dir of the ActiveMQ installation.
-
-Create an instance of the Artemis broker `$ARTEMIS_HOME/bin/artemis create 
--allow-anonymous --user admin --password password  myBroker`
-
-Edit the $ARTEMIS_INSTANCE/etc/broker.xml and change the acceptor to listen to 
port 61617. Comment or remove all other acceptors.
-
-```xml
-
-   tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300
-
-```
-
-### Testing
-
-Start the Artemis broker.
-
-`$ARTEMIS_INSTANCE/bin/artemis run`
-
-Start the ActiveMQ broker.
-
-`$ACTIVEMQ_HOME/bin/standalone`
-
-Send some messages to the ActiveMQ broker.
-
-`./apache-activemq-5.11.0/bin/activemq producer --user admin --password 
password --destination queue://TEST.FOO`
-
-Log into the Artemis console and browse the messages in the TEST.FOO queue.
-
-## Artemis to ActiveMQ JMS Bridge
-
-This is an example of using the JMS bridge shipped with the Artemis broker to 
bridge to ActiveMQ.
-
-###Prerequisites
-
-- install ActiveMQ
-- install Artemis
-
-###Preparing
-
-From the root dir run `mvn clean package`.
-
-Copy artemis-jms-bridge/target/artemis-jms-bridge-1.0.0-SNAPSHOT.war to the 
web directory of the Artemis installation.
-
-Create an instance of the Artemis broker `$ARTEMIS_HOME/bin/artemis create 
--allow-anonymous --user admin --password password  myBroker`
-
-Edit the $ARTEMIS_INSTANCE/etc/broker.xml and change the acceptor to use invm.
-
-```xml
-
-   tcp://0.0.0.0:61617?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300
-   vm://0
-
-```
-
-Edit the $ARTEMIS_INSTANCE/etc/bootstrap.xml and add the war file.
-
-```xml
-
-```
-
-###Testing
-
-
-Start the ActiveMQ broker.
-

[1/2] activemq-artemis git commit: This closes #1616

2017-10-27 Thread michaelpearce 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 6d8e89df9 -> 7a3317c56


This closes #1616


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/7a3317c5
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/7a3317c5
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/7a3317c5

Branch: refs/heads/master
Commit: 7a3317c56b6766c8c54fb69a710190f0956a2edc
Parents: 6d8e89d b07588a
Author: Michael André Pearce 
Authored: Fri Oct 27 16:44:12 2017 +0100
Committer: Michael André Pearce 
Committed: Fri Oct 27 16:44:12 2017 +0100

--
 .../sub-modules/artemis-jms-bridge/README.md|  93 
 .../activemq-artemis-camel/pom.xml  | 101 -
 .../src/main/resources/bridge.xml   |  67 -
 .../src/main/webapp/WEB-INF/web.xml |  30 
 .../artemis-jms-bridge/pom.xml  |  99 -
 .../bridge/ConnectionFactoryFactoryBean.java|  35 -
 .../artemis/bridge/DestinationFactoryBean.java  |  36 -
 .../src/main/resources/bridge.xml   |  69 -
 .../src/main/webapp/WEB-INF/web.xml |  30 
 .../sub-modules/artemis-jms-bridge/pom.xml  |  64 
 .../artemis-jms-bridge/README.md| 148 +++
 .../artemis-jms-bridge/pom.xml  |  93 
 .../bridge/ConnectionFactoryFactoryBean.java|  32 
 .../artemis/bridge/DestinationFactoryBean.java  |  33 +
 .../src/main/resources/bridge.xml   |  66 +
 .../src/main/webapp/WEB-INF/web.xml |  30 
 .../sub-modules/inter-broker-bridge/pom.xml |  39 +
 examples/features/sub-modules/pom.xml   |   2 +-
 pom.xml |   9 +-
 19 files changed, 447 insertions(+), 629 deletions(-)
--

Build failed in Jenkins: ActiveMQ-Java8-All-UnitTests #758

2017-10-27 Thread Apache Jenkins Server 
See 


Changes:

[gtully] [no jira] more lenient for ci builds - intermittetnt failure

[gtully] [AMQ-6847] pause dispatch for message move to avoid redelivery with

--
[...truncated 271.38 KB...]
Running org.apache.activemq.bugs.AMQ5712Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 32.016 sec - in 
org.apache.activemq.bugs.AMQ5712Test
Running org.apache.activemq.bugs.AMQ5814Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.062 sec - in 
org.apache.activemq.bugs.AMQ5814Test
Running org.apache.activemq.bugs.AMQ5822Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.168 sec - in 
org.apache.activemq.bugs.AMQ5822Test
Running org.apache.activemq.bugs.AMQ5844Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.25 sec - in 
org.apache.activemq.bugs.AMQ5844Test
Running org.apache.activemq.bugs.AMQ5863CompositePublishTest
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.104 sec - in 
org.apache.activemq.bugs.AMQ5863CompositePublishTest
Running org.apache.activemq.bugs.AMQ5893Test
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.159 sec - in 
org.apache.activemq.bugs.AMQ5893Test
Running org.apache.activemq.bugs.AMQ5914Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.441 sec - in 
org.apache.activemq.bugs.AMQ5914Test
Running org.apache.activemq.bugs.AMQ5921Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.938 sec - in 
org.apache.activemq.bugs.AMQ5921Test
Running org.apache.activemq.bugs.AMQ6000Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.153 sec - in 
org.apache.activemq.bugs.AMQ6000Test
Running org.apache.activemq.bugs.AMQ6059Test
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.324 sec - in 
org.apache.activemq.bugs.AMQ6059Test
Running org.apache.activemq.bugs.AMQ6094Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 70.957 sec - in 
org.apache.activemq.bugs.AMQ6094Test
Running org.apache.activemq.bugs.AMQ6117Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.19 sec - in 
org.apache.activemq.bugs.AMQ6117Test
Running org.apache.activemq.bugs.AMQ6121Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 9.691 sec - in 
org.apache.activemq.bugs.AMQ6121Test
Running org.apache.activemq.bugs.AMQ6122Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.297 sec - in 
org.apache.activemq.bugs.AMQ6122Test
Running org.apache.activemq.bugs.AMQ6125Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.813 sec - in 
org.apache.activemq.bugs.AMQ6125Test
Running org.apache.activemq.bugs.AMQ6131Test
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 16.845 sec - in 
org.apache.activemq.bugs.AMQ6131Test
Running org.apache.activemq.bugs.AMQ6133PersistJMSRedeliveryTest
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 22.307 sec - in 
org.apache.activemq.bugs.AMQ6133PersistJMSRedeliveryTest
Running org.apache.activemq.bugs.AMQ6194Test
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.054 sec - in 
org.apache.activemq.bugs.AMQ6194Test
Running org.apache.activemq.bugs.AMQ6240Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 8.122 sec - in 
org.apache.activemq.bugs.AMQ6240Test
Running org.apache.activemq.bugs.AMQ6244Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.969 sec - in 
org.apache.activemq.bugs.AMQ6244Test
Running org.apache.activemq.bugs.AMQ6254Test
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 4.513 sec - in 
org.apache.activemq.bugs.AMQ6254Test
Running org.apache.activemq.bugs.AMQ6264Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.878 sec - in 
org.apache.activemq.bugs.AMQ6264Test
Running org.apache.activemq.bugs.AMQ6293Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 2.865 sec - in 
org.apache.activemq.bugs.AMQ6293Test
Running org.apache.activemq.bugs.AMQ6387Test
Tests run: 4, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.319 sec - in 
org.apache.activemq.bugs.AMQ6387Test
Running org.apache.activemq.bugs.AMQ6432Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 15.024 sec - in 
org.apache.activemq.bugs.AMQ6432Test
Running org.apache.activemq.bugs.AMQ6459Test
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.988 sec - in 
org.apache.activemq.bugs.AMQ6459Test
Running org.apache.activemq.bugs.AMQ6463Test
Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 31.124 sec <<< 
FAILURE! - in org.apache.activemq.bugs.AMQ6463Test
testBlockedSechedulerSendNoError(org.apache.activemq.bugs.AMQ6463Test)  Time 
elapsed: 30.983 sec  <<< FAILURE!
junit.framework.AssertionFailedError: got blocked event
at

Jenkins build is back to stable : ActiveMQ-Artemis-Master #1416

2017-10-27 Thread Apache Jenkins Server 
See

[2/2] activemq-artemis git commit: This closes #1617

2017-10-27 Thread jbertram 
This closes #1617


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6d8e89df
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6d8e89df
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6d8e89df

Branch: refs/heads/master
Commit: 6d8e89df9c92938c3e2345059f7ba447ea53f4a1
Parents: 9a5a3d4 84fb07b
Author: Justin Bertram 
Authored: Fri Oct 27 08:45:02 2017 -0500
Committer: Justin Bertram 
Committed: Fri Oct 27 08:45:02 2017 -0500

--
 .../apache/activemq/artemis/core/client/impl/Topology.java  | 9 +++--
 1 file changed, 7 insertions(+), 2 deletions(-)
--

[1/2] activemq-artemis git commit: ARTEMIS-1484 Live's topology update may be ignored

2017-10-27 Thread jbertram 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 9a5a3d496 -> 6d8e89df9


ARTEMIS-1484 Live's topology update may be ignored

If the current node has no connector to Live, it is better
to update it from older message than to have none.


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/84fb07be
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/84fb07be
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/84fb07be

Branch: refs/heads/master
Commit: 84fb07be53b28dd17688bd1a7f81b51bdc4570b9
Parents: 9a5a3d4
Author: Erich Duda 
Authored: Thu Oct 26 15:36:24 2017 +0200
Committer: Erich Duda 
Committed: Fri Oct 27 10:48:33 2017 +0200

--
 .../apache/activemq/artemis/core/client/impl/Topology.java  | 9 +++--
 1 file changed, 7 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/84fb07be/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/Topology.java
--
diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/Topology.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/Topology.java
index 096fd66..966167f 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/Topology.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/Topology.java
@@ -202,7 +202,7 @@ public final class Topology {
 sendMemberUp(nodeId, memberInput);
 return true;
  }
- if (uniqueEventID > currentMember.getUniqueEventID()) {
+ if (uniqueEventID > currentMember.getUniqueEventID() || 
(currentMember.getLive() == null && memberInput.getLive() != null)) {
 TopologyMemberImpl newMember = new TopologyMemberImpl(nodeId, 
memberInput.getBackupGroupName(), memberInput.getScaleDownGroupName(), 
memberInput.getLive(), memberInput.getBackup());
 
 if (newMember.getLive() == null && currentMember.getLive() != 
null) {
@@ -219,7 +219,12 @@ public final class Topology {
newMember, new Exception("trace"));
 }
 
-newMember.setUniqueEventID(uniqueEventID);
+if (uniqueEventID > currentMember.getUniqueEventID()) {
+   newMember.setUniqueEventID(uniqueEventID);
+} else {
+   newMember.setUniqueEventID(currentMember.getUniqueEventID());
+}
+
 topology.remove(nodeId);
 topology.put(nodeId, newMember);
 sendMemberUp(nodeId, newMember);

activemq-artemis git commit: ARTEMIS-1482 Catch malformed SimpleString

2017-10-27 Thread martyntaylor 
Repository: activemq-artemis
Updated Branches:
  refs/heads/1.x 459e5976c -> 466f5f8eb


ARTEMIS-1482 Catch malformed SimpleString


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/466f5f8e
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/466f5f8e
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/466f5f8e

Branch: refs/heads/1.x
Commit: 466f5f8ebe955250666178418783fcb8e930c73a
Parents: 459e597
Author: Martyn Taylor 
Authored: Wed Oct 25 14:19:19 2017 +0100
Committer: Martyn Taylor 
Committed: Wed Oct 25 14:23:53 2017 +0100

--
 .../core/buffers/impl/ChannelBufferWrapper.java |  3 ++
 .../artemis/utils/ChannelBufferWrapperTest.java | 44 
 2 files changed, 47 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/466f5f8e/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
--
diff --git 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
index 496c146..0b5fb34 100644
--- 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
+++ 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ChannelBufferWrapper.java
@@ -89,6 +89,9 @@ public class ChannelBufferWrapper implements ActiveMQBuffer {
 
private SimpleString readSimpleStringInternal() {
   int len = buffer.readInt();
+  if (len > buffer.readableBytes()) {
+ throw new IndexOutOfBoundsException();
+  }
   byte[] data = new byte[len];
   buffer.readBytes(data);
   return new SimpleString(data);

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/466f5f8e/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ChannelBufferWrapperTest.java
--
diff --git 
a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ChannelBufferWrapperTest.java
 
b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ChannelBufferWrapperTest.java
new file mode 100644
index 000..6ef72dc
--- /dev/null
+++ 
b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ChannelBufferWrapperTest.java
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.artemis.utils;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper;
+import org.junit.Test;
+
+import static org.junit.Assert.assertTrue;
+
+public class ChannelBufferWrapperTest {
+
+
+   @Test
+   public void testOutOfBoundsThrownOnMalformedString() {
+  ByteBuf byteBuffer = ByteBufAllocator.DEFAULT.buffer(4);
+  byteBuffer.writeInt(100);
+
+  Exception e = null;
+  try {
+ ChannelBufferWrapper cbw = new ChannelBufferWrapper(byteBuffer);
+ cbw.readSimpleString();
+  } catch (IndexOutOfBoundsException iob) {
+ e = iob;
+  }
+  assertTrue(e instanceof IndexOutOfBoundsException);
+   }
+
+}

[2/2] activemq git commit: [AMQ-6847] pause dispatch for message move to avoid redelivery with pending ack/remove/audit rollback

2017-10-27 Thread gtully 
[AMQ-6847] pause dispatch for message move to avoid redelivery with pending 
ack/remove/audit rollback


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2ea5d142
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2ea5d142
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2ea5d142

Branch: refs/heads/master
Commit: 2ea5d1420bbbf90bd151e19a75e6ca33c773f1f4
Parents: 005403e
Author: gtully 
Authored: Fri Oct 27 11:40:06 2017 +0100
Committer: gtully 
Committed: Fri Oct 27 11:40:06 2017 +0100

--
 .../apache/activemq/broker/region/Queue.java| 31 +
 .../apache/activemq/broker/jmx/MBeanTest.java   | 47 
 2 files changed, 70 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/2ea5d142/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
--
diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java 
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
index f440f76..4a2d272 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
@@ -1471,18 +1471,33 @@ public class Queue extends BaseDestination implements 
Task, UsageListener, Index
  * @throws Exception
  */
 public boolean moveMessageTo(ConnectionContext context, 
QueueMessageReference m, ActiveMQDestination dest) throws Exception {
-BrokerSupport.resend(context, m.getMessage(), dest);
-removeMessage(context, m);
-messagesLock.writeLock().lock();
+Set destsToPause = regionBroker.getDestinations(dest);
 try {
-messages.rollback(m.getMessageId());
-if (isDLQ()) {
-DeadLetterStrategy stratagy = getDeadLetterStrategy();
-stratagy.rollback(m.getMessage());
+for (Destination d: destsToPause) {
+if (d instanceof Queue) {
+((Queue)d).pauseDispatch();
+}
+}
+BrokerSupport.resend(context, m.getMessage(), dest);
+removeMessage(context, m);
+messagesLock.writeLock().lock();
+try {
+messages.rollback(m.getMessageId());
+if (isDLQ()) {
+DeadLetterStrategy stratagy = getDeadLetterStrategy();
+stratagy.rollback(m.getMessage());
+}
+} finally {
+messagesLock.writeLock().unlock();
 }
 } finally {
-messagesLock.writeLock().unlock();
+for (Destination d: destsToPause) {
+if (d instanceof Queue) {
+((Queue)d).resumeDispatch();
+}
+}
 }
+
 return true;
 }
 

http://git-wip-us.apache.org/repos/asf/activemq/blob/2ea5d142/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
index d72d709..ecc6894 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
@@ -54,6 +54,7 @@ import org.apache.activemq.ActiveMQPrefetchPolicy;
 import org.apache.activemq.ActiveMQSession;
 import org.apache.activemq.BlobMessage;
 import org.apache.activemq.EmbeddedBrokerTestSupport;
+import org.apache.activemq.RedeliveryPolicy;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.region.BaseDestination;
 import org.apache.activemq.broker.region.policy.PolicyEntry;
@@ -180,6 +181,52 @@ public class MBeanTest extends EmbeddedBrokerTestSupport {
 assertEquals("no forwards", 0, queueNew.getForwardCount());
 }
 
+public void testMoveFromDLQImmediateDLQ() throws Exception {
+
+RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
+redeliveryPolicy.setMaximumRedeliveries(0);
+
((ActiveMQConnectionFactory)connectionFactory).setRedeliveryPolicy(redeliveryPolicy);
+Connection connection = connectionFactory.createConnection();
+
+// populate
+useConnection(connection);
+
+Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+Destination dest = session.createQueue(getDestinationString());
+MessageConsumer consumer =

[1/2] activemq git commit: [no jira] more lenient for ci builds - intermittetnt failure

2017-10-27 Thread gtully 
Repository: activemq
Updated Branches:
  refs/heads/master 8e576be1d -> 2ea5d1420


[no jira] more lenient for ci builds - intermittetnt failure


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/005403e9
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/005403e9
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/005403e9

Branch: refs/heads/master
Commit: 005403e94b6c3e62240b744bfa1f030fa28b77ae
Parents: 8e576be
Author: gtully 
Authored: Fri Oct 27 11:37:04 2017 +0100
Committer: gtully 
Committed: Fri Oct 27 11:37:04 2017 +0100

--
 .../org/apache/activemq/broker/scheduler/JmsSchedulerTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/005403e9/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
index 8d5737d..0739070 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
@@ -156,7 +156,7 @@ public class JmsSchedulerTest extends 
JobSchedulerTestSupport {
 // make sure the message isn't delivered early
 Thread.sleep(2000);
 assertEquals(latch.getCount(), COUNT);
-latch.await(5, TimeUnit.SECONDS);
+latch.await(10, TimeUnit.SECONDS);
 assertEquals(latch.getCount(), 0);
 connection.close();
 }
@@ -225,7 +225,7 @@ public class JmsSchedulerTest extends 
JobSchedulerTestSupport {
 connection.start();
 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 MessageConsumer consumer = session.createConsumer(destination);
-Message msg = consumer.receive(5000);
+Message msg = consumer.receive(1);
 assertNotNull("Didn't receive the message", msg);
 
 //send another message

svn commit: r1020102 - in /websites/production/activemq/content: cache/main.pageCache message-groups.html

2017-10-27 Thread buildbot 
Author: buildbot
Date: Fri Oct 27 10:24:03 2017
New Revision: 1020102

Log:
Production update by buildbot for activemq

Modified:
websites/production/activemq/content/cache/main.pageCache
websites/production/activemq/content/message-groups.html

Modified: websites/production/activemq/content/cache/main.pageCache
==
Binary files - no diff available.

Modified: websites/production/activemq/content/message-groups.html
==
--- websites/production/activemq/content/message-groups.html (original)
+++ websites/production/activemq/content/message-groups.html Fri Oct 27 
10:24:03 2017
@@ -37,6 +37,7 @@



+

[CONF] Apache ActiveMQ > Message Groups

2017-10-27 Thread Gary Tully (Confluence) 
Title: Message Title



 
 
 
 
 
 
 

Gary Tully edited a page 
 
 
  
 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
Message Groups 
 
 
  
 
 
 
 
 
 
 ... As the appropriate test case shows, adding a small time pause before dispatching or setting a minimum consumer number, ensures equal message group distribution. 
 
 
 
 Note 
 
 
 
 
 
 
 
 
title 
Availability 
 
 
  
 
 
 
 
  Available since version 5.3   
 
 
      Competing demands of memory consumption, load balancing, complexity, etc.   The default behavior which is limited to 1024 message groups in an LRU cache may not match you expectation w.r.t message order... some detail to explain:   MessageGroupHashBucket and SimpleMessageGroupMap message groups work by associating each group with a consumer.   SimpleMessageGroupMap keeps track of every group but suffers from unbounded memory use.   MessageGroupHashBucked keeps track of every group and has bounded memory use.   CachedMessageGroupMap has bounded memory use, but only keeps track of up to 1024 (or the maximum configured size) groups, then loses track of any groups older than the newest 1024.   In this way, if there are more groups than the maximum, ordering will be lost for the oldest groups.   Typically users would close groups such that the in memory set can be retained below the configured limits. Some usefull discussion at [  
 
 
 
 JIRA 
 
 
 
 
 
 
 
 
server 
ASF JIRA 
 
 
serverId 
5aa69414-a9e9-3523-82ec-879b028fb15b 
 
 
key 
AMQ-6851 
 
 
  
 
 
 ]  See 
 
 How do Message Groups compare to Selectors  
  
 
 
  
 
 
 
 
 
 
 
 
 
 

View page
• 
 
 
 
 
 
 

Like 
 
 
  
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
Stop watching space
• 
 
 
 
 
 
 
Manage notifications 
 
 
 
 
 
 
 
 
 
 
  
 
 
This message was sent by Atlassian Confluence 5.8.17

Jenkins build is unstable: ActiveMQ-Java8-All-UnitTests #757

2017-10-27 Thread Apache Jenkins Server 
See