buildbot success in ASF Buildbot on activemq-site-production

2016-01-12 Thread buildbot
The Buildbot has detected a restored build on builder activemq-site-production 
while building ASF Buildbot. Full details are available at:
http://ci.apache.org/builders/activemq-site-production/builds/4728

Buildbot URL: http://ci.apache.org/

Buildslave for this Build: bb-cms-slave

Build Reason: The Nightly scheduler named 'activemq-site-production' triggered 
this build
Build Source Stamp: [branch activemq/activemq-website] HEAD
Blamelist: 

Build succeeded!

Sincerely,
 -The Buildbot





svn commit: r977573 [1/3] - in /websites/production/activemq/content: activemq-5122-release.html activemq-5130-release.html cache/main.pageCache cross-language-clients.html objectmessage.html overview

2016-01-12 Thread buildbot
Author: buildbot
Date: Wed Jan 13 03:25:53 2016
New Revision: 977573

Log:
Production update by buildbot for activemq

Added:
websites/production/activemq/content/activemq-5122-release.html
Modified:
websites/production/activemq/content/activemq-5130-release.html
websites/production/activemq/content/cache/main.pageCache
websites/production/activemq/content/cross-language-clients.html
websites/production/activemq/content/objectmessage.html
websites/production/activemq/content/overview.html

Added: websites/production/activemq/content/activemq-5122-release.html
==
--- websites/production/activemq/content/activemq-5122-release.html (added)
+++ websites/production/activemq/content/activemq-5122-release.html Wed Jan 13 
03:25:53 2016
@@ -0,0 +1,194 @@
+http://www.w3.org/TR/html4/loose.dtd;>
+
+
+
+http://activemq.apache.org/styles/site.css; rel="stylesheet" 
type="text/css"/>
+http://activemq.apache.org/styles/type-settings.css; 
rel="stylesheet" type="text/css"/>
+http://activemq.apache.org/styles/prototype.js"; 
type="text/javascript">
+http://activemq.apache.org/styles/rico.js"; 
type="text/javascript">
+http://activemq.apache.org/styles/site.js"; 
type="text/javascript">
+
+  .maincontent { overflow:hidden; }
+
+
+
+   
+   
+   
+   
+   
+ 
+   
+SyntaxHighlighter.defaults['toolbar'] = false; 
+SyntaxHighlighter.all(); 
+   
+
+
+Apache ActiveMQ  -- ActiveMQ 5.12.2 Release
+
+
+
+
+
+  
+
+
+  
+
+
+  
+
+  
+
+
+
+   
+   
+http://activemq.apache.org; 
title="The most popular and powerful open source Message Broker">ActiveMQ 

+http://www.apache.org; title="The 
Apache Software Foundation">ASF
+   
+
+
+
+  
+OverviewDownloadActiveMQ 5.12.2 Release
+  
+  
+Download | http://activemq.apache.org/maven/apidocs/index.html;>JavaDocs More... | Source | Forums | Support
+  
+
+
+  
+  
+
+
+http://activemq.apache.org/activemq-500-release.data/activemq-5.x-box-reflection.png;
 
data-image-src="http://activemq.apache.org/activemq-500-release.data/activemq-5.x-box-reflection.png;>ActiveMQ 5.12.2 
ReleaseApache ActiveMQ 5.12.2 includes several improvements and 
resolvedhttps://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311210version=12333269;>issuesGetting the Binary 
DistributionsDescriptionDownload LinkVerifyWindows 
Distributionhttp://www.apache.org/dyn/closer.cgi?path=/activemq/5.12.2/apache-activemq-5.12.2-bin.zip;>apache-activemq-5.12.2-bin.ziphttps://www.apache.org/dist/activemq/5.12.2/apache-activemq-5.12.2-bin.zip.asc;>ASC,
 https://www.apache.org/dist/activemq/5.12.2/apache-activemq-5.12.2-bin.zip.md5;>MD5,
 https://www.apache.org/dist/activemq/5.12.2/apache-activemq-5.12.2-bin.zip.sha1;>SHA1Unix/Linux/Cygwin
  Distributionhttp://www.apache.org/dyn/closer.cgi?path=/activemq/5.12.2/apache-activemq-5.12.2-bin.tar.gz;>apache-activemq-5.12.2-bin.tar.gzhttps://www.apache.org/dist/activemq/5.12.2/apache-activemq-5.12.2-bin.tar.gz.asc;>ASC,
 https://www.apache.org/dist/activemq/5.12.2/apache-activemq-5.12.2-bin.tar.gz.md5;>MD5,
 https://www.apache.org/dist/activemq/5.12.2/apache-activemq-5.12.2-bin.tar.gz.sha1;>SHA1Verify the Integrity 
of DownloadsIt is essential that you verify the integrity of the 
downloaded files using the PGP or MD5 signatures. The PGP signatures can be 
verif
 ied using PGP or GPG. Begin by following these steps:Download the 
http://www.apache.org/dist/activemq/KEYS;>KEYSDownload the 
asc signature file for the relevant distributionVerify the 
signatures using the following commands, depending on your use of PGP or 
GPG:
+$ pgpk -a KEYS
+$ pgpv apache-activemq-version-bin.tar.gz.asc
+
+or
+$ pgp -ka KEYS
+$ pgp apache-activemq-version-bin.tar.gz.asc
+
+or
+$ gpg --import KEYS
+$ gpg --verify apache-activemq-version-bin.tar.gz.asc
+
+(Where version is replaced with the actual 
version, e.g., 5.1.0, 5.2.0, etc.).Alternatively, you can verify the MD5 
signature on the files. A Unix program called md5 or 
md5sum is included in most Linux and Unix distributions. It is 
also available as part of http://www.gnu.org/software/textutils/textutils.html; rel="nofollow">GNU 
Textutils. Windows users can utilize any of the following md5 
programs:http://www.fourmilab.ch/md5/; rel="nofollow">md5http://www.pc-tools.net/win32/md5sums/; 
rel="nofollow">md5sumshttp://www.slavasoft.com/fsum/; rel="nofollow">SlavaSoft 
FSUMGetting the Binaries 
using Maven 3To use this release in 
 your maven project, the simplest dependency that you can use in yourhttp://maven.apache.org/guides/introduction/introduction-to-the-pom.html;>Maven
 POMis:
+dependency
+  groupIdorg.apache.activemq/groupId
+  artifactIdactivemq-all/artifactId
+  

svn commit: r977573 [3/3] - in /websites/production/activemq/content: activemq-5122-release.html activemq-5130-release.html cache/main.pageCache cross-language-clients.html objectmessage.html overview

2016-01-12 Thread buildbot
Modified: websites/production/activemq/content/objectmessage.html
==
--- websites/production/activemq/content/objectmessage.html (original)
+++ websites/production/activemq/content/objectmessage.html Wed Jan 13 03:25:53 
2016
@@ -81,11 +81,11 @@
   
 
 
-Although ObjectMessage usage is 
generally discouraged, as it introduces coupling of class paths between 
producers and consumers, ActiveMQ supports them as part of the JMS 
specification.SecurityObjectMessage 
objects depend on Java serialization of marshal/unmarshal object payload. This 
process is generally considered unsafe as malicious payload can exploit the 
host system. That's why starting with version 5.13.0, ActiveMQ 
enforce users to explicitly whitelist packages that can be exchanged using 
ObjectMessages.If you need to exchange object messages, you need to add 
packages your applications are using. You can do that with by 
usingorg.apache.activemq.SERIALIZABLE_PACKAGESsystem 
property of the broker. You can add this system property to 
ACTIVEMQ_OPTS variable in ${ACTIVEMQ_HOME}/bin/env 
script.For example:
+Although ObjectMessage usage is 
generally discouraged, as it introduces coupling of class paths between 
producers and consumers, ActiveMQ supports them as part of the JMS 
specification.SecurityObjectMessage 
objects depend on Java serialization of marshal/unmarshal object payload. This 
process is generally considered unsafe as malicious payload can exploit the 
host system. That's why starting with versions 5.12.2 
and5.13.0, ActiveMQ enforces users to explicitly 
whitelist packages that can be exchanged using ObjectMessages.If you 
need to exchange object messages, you need to add packages your applications 
are using. You can do that with by 
usingorg.apache.activemq.SERIALIZABLE_PACKAGESsystem 
property of the broker. You can add this system property to 
ACTIVEMQ_OPTS variable in ${ACTIVEMQ_HOME}/bin/env 
scri
 pt.For example:
 -Dorg.apache.activemq.SERIALIZABLE_PACKAGES="java.lang,java.util,org.apache.activemq,org.fusesource.hawtbuf,com.thoughtworks.xstream.mapper,com.mycompany.myapp"
 will add com.mycompany.myapp package to the list 
of trusted packages. Note that other packages listed here are enabled by 
default as they are necessary for the regular broker work. In case you want to 
shortcut this mechanism, you can allow all packages to be trusted by using 
* wildcard, like
 -Dorg.apache.activemq.SERIALIZABLE_PACKAGES="*"
-ClientsOn the client side, 
you need to have this same mechanism as malicious code can be deserialized on 
ObjectMessage.getObject() call, compromising your application's 
environment. You can use the same configuration mechanism on the broker and 
configure trusted classes using system properties. However, this is usually not 
convenient in the client applications, so in 5.13.1 we 
introduced additional configuration mechanism using 
ActiveMQConnectionFactory. There are two additional methods 
defined:The setTrustedPackages() method allows you to 
set the list of trusted packages you want to be to unserialize, 
like
+ClientsOn the client side, 
you need to have this same mechanism as malicious code can be deserialized on 
ObjectMessage.getObject() call, compromising your application's 
environment. You can use the same configuration mechanism on the broker and 
configure trusted classes using system properties. However, this is usually not 
convenient in the client applications, so in 5.12.2 
and5.13.1 we introduced additional configuration 
mechanism using ActiveMQConnectionFactory. There are two 
additional methods defined:The setTrustedPackages() 
method allows you to set the list of trusted packages you want to be to 
unserialize, like
 ActiveMQConnectionFactory factory = new 
ActiveMQConnectionFactory("tcp://localhost:61616");
 factory.setTrustedPackages(new 
ArrayList(Arrays.asList("org.apache.activemq.test,org.apache.camel.test")));
 ThesetTrustAllPackages() allows you to 
turn off security check and trust all classes. It's useful for testing 
purposes.

Modified: websites/production/activemq/content/overview.html
==
--- websites/production/activemq/content/overview.html (original)
+++ websites/production/activemq/content/overview.html Wed Jan 13 03:25:53 2016
@@ -72,7 +72,7 @@
   
 
 
-DownloadActiveMQ 1.1 ReleaseActiveMQ 1.2 
ReleaseActiveMQ 
1.3 ReleaseActiveMQ 1.4 ReleaseActiveMQ 1.5 
ReleaseActiveMQ 
2.0 ReleaseActiveMQ 2.1 ReleaseActiveMQ 3.0 
ReleaseActiveMQ 
3.1 ReleaseActiveMQ 3.2.1 ReleaseActiveMQ 3.2.2 ReleaseActiveMQ 3.2 ReleaseActiveMQ 4.0.1 
ReleaseActiveMQ 
4.0.2 ReleaseActiveMQ 4.0 M4 ReleaseActiveMQ 4.0 RC2 
ReleaseActiveMQ 
4.0 ReleaseActiveMQ 4.1.0 ReleaseActiveMQ 4.1.1 
ReleaseActiveMQ 
4.1.2 ReleaseActiveMQ 5.0.0 ReleaseActiveMQ 5.1.0 
ReleaseActiveMQ 5.2.0 ReleaseActiveMQ 5.3.0 
ReleaseActiveMQ 

buildbot failure in ASF Buildbot on activemq-site-production

2016-01-12 Thread buildbot
The Buildbot has detected a new failure on builder activemq-site-production 
while building ASF Buildbot. Full details are available at:
http://ci.apache.org/builders/activemq-site-production/builds/4729

Buildbot URL: http://ci.apache.org/

Buildslave for this Build: bb-cms-slave

Build Reason: The Nightly scheduler named 'activemq-site-production' triggered 
this build
Build Source Stamp: [branch activemq/activemq-website] HEAD
Blamelist: 

BUILD FAILED: failed compile

Sincerely,
 -The Buildbot





svn commit: r977573 [2/3] - in /websites/production/activemq/content: activemq-5122-release.html activemq-5130-release.html cache/main.pageCache cross-language-clients.html objectmessage.html overview

2016-01-12 Thread buildbot
Modified: websites/production/activemq/content/cross-language-clients.html
==
--- websites/production/activemq/content/cross-language-clients.html (original)
+++ websites/production/activemq/content/cross-language-clients.html Wed Jan 13 
03:25:53 2016
@@ -72,7 +72,7 @@
   
 
 
-Apache ActiveMQ is a message broker 
written in Java together with a full JMS client, however it supports protocols 
likeOpenWireandSTOMPthat can be used by applications 
in other languages.Client 
Librarieshttp://activemq.apache.org/nms/;>.NEThttp://docs.codehaus.org/display/STOMP/C; 
style="line-height: 1.42857;" rel="nofollow">C(defunct)http://activemq.apache.org/cms/;>C++https://github.com/igb/Erlang-STOMP-Client; 
style="line-height: 1.42857;" rel="nofollow">ErlangGohttps://github.com/toschoo/mom/; rel="nofollow">Haskellhttps://code.google.com/p/hxstomp/; 
rel="nofollow">Haxe (defunct)https://github.com/fribeiro1/jekpro-activemq-library; style="line-height: 
1.42857;" rel="nofollow">Jekejeke Prologhttps://github.com/fribeiro1/ActiveMQ-Extension; 
style="line-height: 1.42857;" rel="nofollow">NetLogohttp://search.cpan.org/~lcons/Net-STOMP-Client/; style="line-height: 
1.42857;" rel="nofollow">Perl 5https://github.com/hww3/pike_modules-public_protocols_stomp; 
style="line-height: 1.42857;" rel="nofollow">Pikehttps://github.com/jasonrbriggs/stomp.py/; 
rel="nofollow">Pythonhttps://github.com/tonyg/racket-stomp; style="line-height: 1.42857;" 
rel="nofollow">Rackethttps://github.com/kookster/activemessaging; rel="nofollow">Ruby on 
Railshttps://github.com/siemens/tstomp; style="line-height: 1.42857;" 
rel="nofollow">Tcl/TkProtocolsThe following protocols 
may be used for interoperability:AMQPMQTTOpenWireRESTSTOMPWebSocketSamplesLanguageVariantVMInterfaceProtocolCodeAwkGawkNoneSocketsSTOMPhttps://simplesassim.wordpress.com/2014/03/06/how-to-send-a-message-to-an-apache-activemq-queue-with-gawk/;
 rel="nofollow">Send to Queuehref="https://simplesassim.wordpress.com/2014/03/06/how-to-send-a-message-to-an-apache-activemq-topic-with-gawk/;
 > rel="nofollow">Send to Topicclass="external-link" 
 >href="https://simplesassim.wordpress.com/2014/03/06/how-to-receive-a-message-from-an-apache-activemq-queue-with-gawk/;
 > rel="nofollow">Receive from Queueclass="external-link" 
 >href="https://simplesassim.wordpress.com/2014/03/06/how-to-receive-a-message-from-an-apache-activemq-topic-with-gawk/;
 > rel="nofollow">Receive from Topicrowspan="1" class="confluenceTd">Cclass="confluenceTd">Noneclass="confluenceTd">Noneclass="confluenceTd">Client Libraryrowspan="1" class="confluenceTd">STOMPclass="confluenceTd">https://simplesassim.wordpress.com/2014/02/23/how-to-send-a-message-to-an-apache-activemq-queue-with-c/;
 rel="nofollow">Send to Queuehttps://simplesassim.wordpress.com/2014/02/23/how-to-send-a-message-to-an-apache-activemq-topic-with-c/;
 rel="nofollow">Send to Topichttps://simplesassim.wordpress.com/2014/02/23/how-to-receive-a-message-from-an-apache-activemq-queue-with-c/;
 rel="nofollow">Receive from Queuehttps://simplesassim.wordpress.com/2014/02/23/how-to-receive-a-message-from-an-apache-activemq-topic-with-c/;
 rel="nofollow">Receive from TopicCOBOLGNU COBOLNoneSocketsSTOMPhttps://simplesassim.wordpress.com/2014/04/15/how-to-send-a-message-to-an-apache-activemq-queue-with-gnu-cobol/;
 rel="nofollow">Send to Queuehttps://simplesassim.wordpress.com/2014/04/15/how-to-send-a-message-to-an-apache-activemq-topic-with-gnu-cobol/;
 rel="nofollow">Send to Topichttps://simplesassim.wordpress.com/2014/04/17/how-to-receive-a-message-from-an-apache-activemq-queue-with-gnu-cobol/;
 rel="nofollow">Receive from Queuehttps://simplesassim.wordpress.com/2014/04/17/how-to-receive-a-message-from-an-apache-activemq-topic-with-gnu-cobol/;
 rel="nofollow">Receive from TopicCOBOLVisual COBOLJVMClient LibraryOpenWirehttps://simplesassim.wordpress.com/2013/11/12/how-to-send-a-message-to-an-apache-activemq-queue-with-visual-cobol/;
 rel="nofollow">Send to Queuehttps://simplesassim.wordpress.com/2013/11/12/how-to-send-a-message-to-an-apache-activemq-topic-with-visual-cobol/;
 rel="nofollow">Send to Topichttps://simplesassim.wordpress.com/2013/11/13/how-to-receive-a-message-from-an-apache-activemq-queue-with-visual-cobol/;
 rel="nofollow">Receive from Queuehttps://simplesassim.wordpress.com/2013/11/13/how-to-receive-a-message-from-an-apache-activemq-topic-with-visual-cobol/;
 rel="nofollow">Receive from TopicCeylonNoneJVMClient LibraryOpenWirehttps://simplesassim.wordpress.com/2013/12/28/how-to-send-a-message-to-an-apache-activemq-queue-with-ceylon/;
 rel="nofollow">Send to Queuehttps://simplesassim.wordpress.com/2013/12/28/how-to-send-a-message-to-an-apache-activemq-topic-with-ceylon/;
 rel="nofollow">Send to Topichttps://si
 
mplesassim.wordpress.com/2013/12/28/how-to-receive-a-message-from-an-apache-activemq-queue-with-ceylon/"
 rel="nofollow">Receive from 

Jenkins build is unstable: ActiveMQ-Java8 » ActiveMQ :: Unit Tests #580

2016-01-12 Thread Apache Jenkins Server
See 




buildbot failure in ASF Buildbot on activemq-site-production

2016-01-12 Thread buildbot
The Buildbot has detected a new failure on builder activemq-site-production 
while building ASF Buildbot. Full details are available at:
http://ci.apache.org/builders/activemq-site-production/builds/4711

Buildbot URL: http://ci.apache.org/

Buildslave for this Build: bb-cms-slave

Build Reason: The Nightly scheduler named 'activemq-site-production' triggered 
this build
Build Source Stamp: [branch activemq/activemq-website] HEAD
Blamelist: 

BUILD FAILED: failed compile

Sincerely,
 -The Buildbot





activemq-artemis git commit: fixing thread leakage from test

2016-01-12 Thread clebertsuconic
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 5fe1fa653 -> 5df57234d


fixing thread leakage from test


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

Branch: refs/heads/master
Commit: 5df57234d19bee8b4415edf37339a916f0323e4c
Parents: 5fe1fa6
Author: Clebert Suconic 
Authored: Tue Jan 12 08:16:17 2016 -0500
Committer: Clebert Suconic 
Committed: Tue Jan 12 08:16:21 2016 -0500

--
 .../artemis/tests/integration/server/SuppliedThreadPoolTest.java  | 3 +++
 1 file changed, 3 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/5df57234/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
index 2e9accf..8dda215 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/SuppliedThreadPoolTest.java
@@ -55,6 +55,9 @@ public class SuppliedThreadPoolTest extends ActiveMQTestBase {
   if (server.isActive()) {
  server.stop();
   }
+  serviceRegistry.getExecutorService().shutdown();
+  serviceRegistry.getScheduledExecutorService().shutdown();
+  super.tearDown();
}
 
@Test



activemq git commit: https://issues.apache.org/jira/browse/AMQ-6124 - fix and test - propagate broker info from prestarted backup transport

2016-01-12 Thread gtully
Repository: activemq
Updated Branches:
  refs/heads/master 66cfc7bab -> db1506a59


https://issues.apache.org/jira/browse/AMQ-6124 - fix and test - propagate 
broker info from prestarted backup transport


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

Branch: refs/heads/master
Commit: db1506a5921f70134c3b647cec51204f0e1c1416
Parents: 66cfc7b
Author: gtully 
Authored: Tue Jan 12 14:00:13 2016 +
Committer: gtully 
Committed: Tue Jan 12 14:00:13 2016 +

--
 .../transport/failover/BackupTransport.java | 16 +++-
 .../transport/failover/FailoverTransport.java   |  1 +
 .../failover/FailoverClusterTestSupport.java|  6 ++
 .../transport/failover/FailoverPriorityTest.java|  5 -
 .../failover/FailoverTransportBackupsTest.java  | 15 +--
 5 files changed, 39 insertions(+), 4 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/db1506a5/activemq-client/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java
--
diff --git 
a/activemq-client/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java
 
b/activemq-client/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java
index f6df0a4..9c591e2 100644
--- 
a/activemq-client/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java
+++ 
b/activemq-client/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java
@@ -18,6 +18,7 @@
 
 package org.apache.activemq.transport.failover;
 
+import org.apache.activemq.command.BrokerInfo;
 import org.apache.activemq.transport.DefaultTransportListener;
 import org.apache.activemq.transport.Transport;
 
@@ -29,10 +30,12 @@ class BackupTransport extends DefaultTransportListener{
private Transport transport;
private URI uri;
private boolean disposed;
-   
+   private BrokerInfo brokerInfo;
+
BackupTransport(FailoverTransport ft){
this.failoverTransport=ft;
}
+
@Override
 public void onException(IOException error) {
this.disposed=true;
@@ -41,6 +44,17 @@ class BackupTransport extends DefaultTransportListener{
}
}
 
+   @Override
+   public void onCommand(Object command) {
+   if (command instanceof BrokerInfo) {
+   brokerInfo = (BrokerInfo) command;
+   }
+   }
+
+   public BrokerInfo getBrokerInfo() {
+   return brokerInfo;
+   }
+
public Transport getTransport() {
return transport;
}

http://git-wip-us.apache.org/repos/asf/activemq/blob/db1506a5/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
--
diff --git 
a/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
 
b/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
index 7f7d7c6..dcb0867 100755
--- 
a/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
+++ 
b/activemq-client/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
@@ -991,6 +991,7 @@ public class FailoverTransport implements 
CompositeTransport {
 backups.remove(bt);
 transport = bt.getTransport();
 uri = bt.getUri();
+myTransportListener.onCommand(bt.getBrokerInfo());
 if (priorityBackup && priorityBackupAvailable) {
 Transport old = 
this.connectedTransport.getAndSet(null);
 if (old != null) {

http://git-wip-us.apache.org/repos/asf/activemq/blob/db1506a5/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTestSupport.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTestSupport.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTestSupport.java
index c5e9665..01dcce4 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTestSupport.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/failover/FailoverClusterTestSupport.java
@@ -110,6 +110,12 

[CONF] Apache ActiveMQ > ActiveMQ 5.12.2 Release

2016-01-12 Thread Christopher L. Shannon (Confluence)
Title: Message Title



 
 
 
 
 
 
 

Christopher L. Shannon created a page 
 
 
  
 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
ActiveMQ 5.12.2 Release 
 
 
  
 
 
 
 
 
 
 
 
   
   ActiveMQ 5.12.2 Release Apache ActiveMQ 5.12.2 includes several improvements and resolved issues  Getting the Binary Distributions 
 
 
 
 
 Description  
 Download Link  
  Verify   
 
 
 Windows Distribution  
  apache-activemq-5.12.2-bin.zip   
  ASC, MD5, SHA1   
 
 
 Unix/Linux/Cygwin Distribution  
  apache-activemq-5.12.2-bin.tar.gz   
  ASC, MD5, SHA1   
 
 
 
  Verify the Integrity of Downloads It is essential that you verify the integrity of the downloaded files using the PGP or MD5 signatures. The PGP signatures can be verified using PGP or GPG. Begin by following these steps: 
 
Download the KEYS  
Download the asc signature file for the relevant distribution 
 Verify the signatures using the following commands, depending on your use of PGP or GPG: 
 
 
$ pgpk -a KEYS
$ pgpv apache-activemq--bin.tar.gz.asc
 
 
 or 
 
 
$ pgp -ka KEYS
$ pgp apache-activemq--bin.tar.gz.asc
 
 
 or 
 
 
$ gpg --import KEYS
$ gpg --verify apache-activemq--bin.tar.gz.asc
 
 
  
 (Where  is replaced with the actual version, e.g., 5.1.0, 5.2.0, etc.). Alternatively, you can verify the MD5 signature on the files. A Unix program called md5 or md5sum is included in most Linux and Unix distributions. It is also available as part of GNU Textutils. Windows users can utilize any of the following md5 programs: 
 
 md5  
 md5sums  
 SlavaSoft FSUM  
  Getting the Binaries using Maven 3 To use this release in your maven project, the simplest dependency that you can use in your Maven POM is: 
 
 

  org.apache.activemq
  activemq-all
  5.12.2

 
 
 If you need more fine grained control of your dependencies (activemq-all is an uber jar) pick and choose from the various components activemq-client, activemq-broker, activemq-xx-store etc. 

   
 Getting the Source Code Source Distributions 
 
 
 
 
 Description  
 Download Link  
 Verify  
 
 
 Source Release  
  activemq-parent-5.12.2-source-release.zip   
  ASC, MD5, SHA1   
 
 
 
 Git Tag  https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=tag;h=refs/tags/activemq-5.12.2  Change Log For a more detailed view of new features and bug fixes, see the release notes  Also see the previous ActiveMQ 5.12.1 Release   
 
 
  
 
 
 
 
 
 
 
 
 
 

View page
• 
 
 
 
 
 
 

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




Jenkins build is still unstable: ActiveMQ-Java7 #913

2016-01-12 Thread Apache Jenkins Server
See 



Jenkins build is still unstable: ActiveMQ-Java7 » ActiveMQ :: Unit Tests #913

2016-01-12 Thread Apache Jenkins Server
See 




[CONF] Apache ActiveMQ > ActiveMQ 5.12.2 Release

2016-01-12 Thread Christopher L. Shannon (Confluence)
Title: Message Title



 
 
 
 
 
 
 

Christopher L. Shannon edited a page 
 
 
  
 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
ActiveMQ 5.12.2 Release 
 
 
  
 
 
 
 
 
 
 ... For a more detailed view of new features and bug fixes, see the release notes  
 
 
 
 Warning 
 
 
 
 
  This release affects applications using ObjectMessages. Please refer to http://activemq.apache.org/objectmessage.html and   
 
 
 
 JIRA 
 
 
 
 
 
 
 
 
server 
ASF JIRA 
 
 
serverId 
5aa69414-a9e9-3523-82ec-879b028fb15b 
 
 
key 
AMQ-6013 
 
 
  
 
 
  for more information.   
 
 
     Also see the previous ActiveMQ 5.12.1 Release   
 
 
  
 
 
 
 
 
 
 
 
 
 

View page
• 
 
 
 
 
 
 

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




[CONF] Apache ActiveMQ > ActiveMQ 5.13.0 Release

2016-01-12 Thread Christopher L. Shannon (Confluence)
Title: Message Title



 
 
 
 
 
 
 

Christopher L. Shannon edited a page 
 
 
  
 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
ActiveMQ 5.13.0 Release 
 
 
  
 
 
 
 
 
 
 ... For a more detailed view of new features and bug fixes, see the release notes  
 
 
 
 Warning 
 
 
 
 
 This releases affect release affects applications using ObjectMessages. Please refer to http://activemq.apache.org/objectmessage.html and  
 
 
 
 JIRA 
 
 
 
 
 
 
 
 
server 
ASF JIRA 
 
 
serverId 
5aa69414-a9e9-3523-82ec-879b028fb15b 
 
 
key 
AMQ-6013 
 
 
  
 
 
 for more information.  
 
 
 ...  
 
 
  
 
 
 
 
 
 
 
 
 
 

View page
• 
 
 
 
 
 
 

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




Jenkins build is back to stable : ActiveMQ-Java7 » ActiveMQ :: Generic JMS Pool #913

2016-01-12 Thread Apache Jenkins Server
See 




activemq git commit: NO-JIRA Update test to ACK in transacted batches to group Ack values to avoid the test failure based on the even spread of acks across journal files preventing file GC which cause

2016-01-12 Thread tabish
Repository: activemq
Updated Branches:
  refs/heads/master 505a76a8b -> b9805f7ac


NO-JIRA Update test to ACK in transacted batches to group Ack values to
avoid the test failure based on the even spread of acks across journal
files preventing file GC which causes the test to fail.  

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

Branch: refs/heads/master
Commit: b9805f7ac09e2cd601de99ca8c09a1f367a9687d
Parents: 505a76a
Author: Timothy Bish 
Authored: Tue Jan 12 13:51:56 2016 -0500
Committer: Timothy Bish 
Committed: Tue Jan 12 13:51:56 2016 -0500

--
 .../bugs/TransactedStoreUsageSuspendResumeTest.java | 12 
 1 file changed, 8 insertions(+), 4 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/b9805f7a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
index ebc3e37..99a3e9e 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/TransactedStoreUsageSuspendResumeTest.java
@@ -16,10 +16,13 @@
  */
 package org.apache.activemq.bugs;
 
+import static org.junit.Assert.assertTrue;
+
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
+
 import javax.jms.BytesMessage;
 import javax.jms.Connection;
 import javax.jms.ConnectionFactory;
@@ -29,6 +32,7 @@ import javax.jms.Message;
 import javax.jms.MessageConsumer;
 import javax.jms.MessageProducer;
 import javax.jms.Session;
+
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.TestSupport;
 import org.apache.activemq.broker.BrokerService;
@@ -42,9 +46,6 @@ import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
-import static org.junit.Assert.assertTrue;
-
 // https://issues.apache.org/jira/browse/AMQ-4262
 public class TransactedStoreUsageSuspendResumeTest {
 private static final Logger LOG = 
LoggerFactory.getLogger(TransactedStoreUsageSuspendResumeTest.class);
@@ -86,13 +87,16 @@ public class TransactedStoreUsageSuspendResumeTest {
 do {
 Message message = consumer.receive(5000);
 if (message != null) {
-session.commit();
+if ((messagesReceivedCountDown.getCount() % 
(MAX_MESSAGES / 5)) == 0) {
+session.commit();
+}
 messagesReceivedCountDown.countDown();
 }
 if (messagesReceivedCountDown.getCount() % 500 == 0) {
 LOG.info("remaining to receive: " + 
messagesReceivedCountDown.getCount());
 }
 } while (messagesReceivedCountDown.getCount() != 0);
+session.commit();
 consumer.close();
 session.close();
 connection.close();



[CONF] Apache ActiveMQ > ObjectMessage

2016-01-12 Thread Christopher L. Shannon (Confluence)
Title: Message Title



 
 
 
 
 
 
 

Christopher L. Shannon edited a page 
 
 
  
 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
ObjectMessage 
 
 
  
 
 
 
 
 
 
 ... ObjectMessage objects depend on Java serialization of marshal/unmarshal object payload. This process is generally considered unsafe as malicious payload can exploit the host system. That's why starting with version versions 5.12.2 and 5.13.0, ActiveMQ enforce enforces users to explicitly whitelist packages that can be exchanged using ObjectMessages. ... On the client side, you need to have this same mechanism as malicious code can be deserialized on ObjectMessage.getObject() call, compromising your application's environment. You can use the same configuration mechanism on the broker and configure trusted classes using system properties. However, this is usually not convenient in the client applications, so in 5.12.2 and 5.13.1 we introduced additional configuration mechanism using ActiveMQConnectionFactory. There are two additional methods defined: ...  
 
 
  
 
 
 
 
 
 
 
 
 
 

View page
• 
 
 
 
 
 
 

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




[1/2] activemq-artemis git commit: ARTEMIS-334 - Add Management browse functionality similar to ActiveMQ

2016-01-12 Thread clebertsuconic
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 5df57234d -> bb40472f9


ARTEMIS-334 - Add Management browse functionality similar to ActiveMQ

https://issues.apache.org/jira/browse/ARTEMIS-334


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

Branch: refs/heads/master
Commit: ea3c3e0aef9336a233e31d1872743f1ba1f61bca
Parents: 5df5723
Author: Andy Taylor 
Authored: Thu Jan 7 14:42:03 2016 +
Committer: Andy Taylor 
Committed: Tue Jan 12 14:26:57 2016 +

--
 .../activemq/artemis/api/core/Message.java  |   6 +
 .../api/core/management/ManagementHelper.java   |  31 +-
 .../api/core/management/QueueControl.java   |   7 +
 .../artemis/core/message/impl/MessageImpl.java  |   7 +
 .../api/jms/management/JMSQueueControl.java |  14 +
 .../artemis/jms/client/ActiveMQMessage.java |   9 +
 .../management/impl/JMSQueueControlImpl.java|  34 ++
 .../openmbean/JMSCompositeDataConstants.java|  58 +++
 .../impl/openmbean/JMSOpenTypeSupport.java  | 353 +++
 .../deployers/impl/FileConfigurationParser.java |   5 +
 .../core/management/impl/QueueControlImpl.java  |  38 ++
 .../impl/openmbean/CompositeDataConstants.java  |  66 
 .../impl/openmbean/OpenTypeSupport.java | 256 ++
 .../core/settings/impl/AddressSettings.java |  35 +-
 .../resources/schema/artemis-configuration.xsd  |  10 +
 .../impl/ScheduledDeliveryHandlerTest.java  |   5 +
 .../integration/client/AcknowledgeTest.java |   5 +
 .../server/management/JMSQueueControlTest.java  | 210 +++
 .../management/JMSQueueControlUsingJMSTest.java |  16 +
 .../jms/server/management/JMSUtil.java  |  43 +++
 .../management/QueueControlUsingCoreTest.java   |   7 +
 21 files changed, 1213 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ea3c3e0a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
--
diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
index 77bb7cb..f5cb55b 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/Message.java
@@ -579,4 +579,10 @@ public interface Message {
 * @return Returns the message in Map form, useful when encoding to JSON
 */
Map toMap();
+
+
+   /**
+* @return Returns the message properties in Map form, useful when encoding 
to JSON
+*/
+   Map toPropertyMap();
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/ea3c3e0a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
--
diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
index fb7d88b..98fafc4 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/management/ManagementHelper.java
@@ -16,6 +16,8 @@
  */
 package org.apache.activemq.artemis.api.core.management;
 
+import java.io.ByteArrayInputStream;
+import java.io.ObjectInputStream;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Iterator;
@@ -24,9 +26,13 @@ import java.util.Map;
 import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.api.core.Message;
 import org.apache.activemq.artemis.core.client.ActiveMQClientMessageBundle;
+import org.apache.activemq.artemis.utils.Base64;
 import org.apache.activemq.artemis.utils.json.JSONArray;
 import org.apache.activemq.artemis.utils.json.JSONObject;
 
+import javax.management.openmbean.CompositeData;
+import javax.management.openmbean.CompositeDataSupport;
+
 /**
  * Helper class to use ActiveMQ Artemis Core messages to manage server 
resources.
  */
@@ -178,7 +184,20 @@ public final class ManagementHelper {
if (clz.isArray()) {
   Object[] innerArray = (Object[]) parameter;
 
-  jsonArray.put(ManagementHelper.toJSONArray(innerArray));
+ 

[2/2] activemq-artemis git commit: ARTEMIS-337 - [Artemis Testsuite] LiveToLiveFailoverTest.testNonTransactedWithZeroConsumerWindowSize fails

2016-01-12 Thread clebertsuconic
ARTEMIS-337 - [Artemis Testsuite] 
LiveToLiveFailoverTest.testNonTransactedWithZeroConsumerWindowSize fails


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

Branch: refs/heads/master
Commit: 2c0f1df827b8f255a5f76f9105cf95b2e6b28e72
Parents: bb40472
Author: Erich Duda 
Authored: Tue Jan 12 16:52:06 2016 +0100
Committer: Clebert Suconic 
Committed: Tue Jan 12 16:24:34 2016 -0500

--
 .../artemis/tests/integration/cluster/failover/FailoverTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/2c0f1df8/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
index 857176f..28012eb 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
@@ -466,7 +466,7 @@ public class FailoverTest extends FailoverTestBase {
 
   crash(session);
 
-  Assert.assertTrue(latch.await(1, TimeUnit.SECONDS));
+  Assert.assertTrue(latch.await(10, TimeUnit.SECONDS));
 
}
 



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

2016-01-12 Thread clebertsuconic
Repository: activemq-artemis
Updated Branches:
  refs/heads/master bb40472f9 -> 8b6d3a65b


This closes #311


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

Branch: refs/heads/master
Commit: 8b6d3a65be60674299b09b65dbb53ca422323ab7
Parents: bb40472 2c0f1df
Author: Clebert Suconic 
Authored: Tue Jan 12 16:24:34 2016 -0500
Committer: Clebert Suconic 
Committed: Tue Jan 12 16:24:34 2016 -0500

--
 .../artemis/tests/integration/cluster/failover/FailoverTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--




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

2016-01-12 Thread clebertsuconic
This closes #310


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

Branch: refs/heads/master
Commit: bb40472f97964812a45b50846831f63214f1553c
Parents: 5df5723 ea3c3e0
Author: Clebert Suconic 
Authored: Tue Jan 12 16:23:25 2016 -0500
Committer: Clebert Suconic 
Committed: Tue Jan 12 16:23:25 2016 -0500

--
 .../activemq/artemis/api/core/Message.java  |   6 +
 .../api/core/management/ManagementHelper.java   |  31 +-
 .../api/core/management/QueueControl.java   |   7 +
 .../artemis/core/message/impl/MessageImpl.java  |   7 +
 .../api/jms/management/JMSQueueControl.java |  14 +
 .../artemis/jms/client/ActiveMQMessage.java |   9 +
 .../management/impl/JMSQueueControlImpl.java|  34 ++
 .../openmbean/JMSCompositeDataConstants.java|  58 +++
 .../impl/openmbean/JMSOpenTypeSupport.java  | 353 +++
 .../deployers/impl/FileConfigurationParser.java |   5 +
 .../core/management/impl/QueueControlImpl.java  |  38 ++
 .../impl/openmbean/CompositeDataConstants.java  |  66 
 .../impl/openmbean/OpenTypeSupport.java | 256 ++
 .../core/settings/impl/AddressSettings.java |  35 +-
 .../resources/schema/artemis-configuration.xsd  |  10 +
 .../impl/ScheduledDeliveryHandlerTest.java  |   5 +
 .../integration/client/AcknowledgeTest.java |   5 +
 .../server/management/JMSQueueControlTest.java  | 210 +++
 .../management/JMSQueueControlUsingJMSTest.java |  16 +
 .../jms/server/management/JMSUtil.java  |  43 +++
 .../management/QueueControlUsingCoreTest.java   |   7 +
 21 files changed, 1213 insertions(+), 2 deletions(-)
--




Jenkins build became unstable: ActiveMQ-Java8 » ActiveMQ :: Broker #580

2016-01-12 Thread Apache Jenkins Server
See 




Jenkins build is unstable: ActiveMQ-Java8 #580

2016-01-12 Thread Apache Jenkins Server
See 



[3/3] activemq-artemis git commit: This closes #312

2016-01-12 Thread clebertsuconic
This closes #312


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

Branch: refs/heads/master
Commit: a8443512b0476170b0f18dcd043d2ed881e625de
Parents: 8b6d3a6 2e973c4
Author: Clebert Suconic 
Authored: Tue Jan 12 17:24:10 2016 -0500
Committer: Clebert Suconic 
Committed: Tue Jan 12 17:24:10 2016 -0500

--
 .../wireformat/SessionReceiveLargeMessage.java  |  4 +-
 .../artemis/core/server/impl/QueueImpl.java |  5 +-
 .../core/server/impl/ServerConsumerImpl.java|  7 +-
 .../artemis/tests/util/ThreadLeakCheckRule.java | 94 +---
 .../cluster/failover/FailoverTest.java  |  1 -
 .../failover/LiveToLiveFailoverTest.java|  1 -
 6 files changed, 53 insertions(+), 59 deletions(-)
--




[2/3] activemq-artemis git commit: Improvements on Thread check

2016-01-12 Thread clebertsuconic
Improvements on Thread check


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

Branch: refs/heads/master
Commit: 2d3061d9b69de61cb89ea9cc3e5898e32caf7198
Parents: 8b6d3a6
Author: Clebert Suconic 
Authored: Tue Jan 12 15:10:48 2016 -0500
Committer: Clebert Suconic 
Committed: Tue Jan 12 17:22:56 2016 -0500

--
 .../artemis/tests/util/ThreadLeakCheckRule.java | 94 +---
 .../cluster/failover/FailoverTest.java  |  1 -
 .../failover/LiveToLiveFailoverTest.java|  1 -
 3 files changed, 44 insertions(+), 52 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/2d3061d9/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ThreadLeakCheckRule.java
--
diff --git 
a/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ThreadLeakCheckRule.java
 
b/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ThreadLeakCheckRule.java
index 3f371a8..e3ef4c7 100644
--- 
a/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ThreadLeakCheckRule.java
+++ 
b/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ThreadLeakCheckRule.java
@@ -51,84 +51,78 @@ public class ThreadLeakCheckRule extends ExternalResource {
 * Override to tear down your specific external resource.
 */
protected void after() {
-  if (enabled) {
- StringBuffer buffer = null;
-
- boolean failed = true;
-
- boolean failedOnce = false;
-
- long timeout = System.currentTimeMillis() + 6;
- while (failed && timeout > System.currentTimeMillis()) {
-buffer = new StringBuffer();
-
-failed = checkThread(buffer);
-
-if (failed) {
-   failedOnce = true;
-   ActiveMQTestBase.forceGC();
-   try {
-  Thread.sleep(500);
+  try {
+ if (enabled) {
+boolean failed = true;
+
+boolean failedOnce = false;
+
+long timeout = System.currentTimeMillis() + 6;
+while (failed && timeout > System.currentTimeMillis()) {
+   failed = checkThread();
+
+   if (failed) {
+  failedOnce = true;
+  ActiveMQTestBase.forceGC();
+  try {
+ Thread.sleep(500);
+  }
+  catch (Throwable e) {
+  }
}
-   catch (Throwable e) {
-   }
-
-   System.out.println("There are still threads running, trying 
again");
-   System.out.println(buffer);
 }
- }
 
- if (failed) {
-System.out.println("Thread leaked on test \n" +
-   buffer);
-System.out.println("Thread leakage! Failure!!!");
+if (failed) {
+   Assert.fail("Thread leaked");
+}
+else if (failedOnce) {
+   System.out.println(" Threads cleared after 
retries ");
+   System.out.println();
+}
 
-Assert.fail("Thread leaked");
  }
- else if (failedOnce) {
-System.out.println(" Threads cleared after 
retries ");
-System.out.println();
+ else {
+enabled = true;
  }
-
-
   }
-  else {
- enabled = true;
+  finally {
+ // clearing just to help GC
+ previousThreads = null;
   }
 
}
 
 
-
-   /**
-* @param buffer
-* @return
-*/
-   private boolean checkThread(StringBuffer buffer) {
+   private boolean checkThread() {
   boolean failedThread = false;
 
   Map postThreads = 
Thread.getAllStackTraces();
 
   if (postThreads != null && previousThreads != null && postThreads.size() 
> previousThreads.size()) {
 
- 
buffer.append("*\n");
- buffer.append("LEAKING THREADS\n");
 
  for (Thread aliveThread : postThreads.keySet()) {
-if (!isExpectedThread(aliveThread) && 
!previousThreads.containsKey(aliveThread)) {
+if (aliveThread.isAlive() && !isExpectedThread(aliveThread) && 
!previousThreads.containsKey(aliveThread)) {
+   if (!failedThread) {
+  

[1/3] activemq-artemis git commit: fixing BackupSyncJournalTest

2016-01-12 Thread clebertsuconic
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 8b6d3a65b -> a8443512b


fixing BackupSyncJournalTest


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

Branch: refs/heads/master
Commit: 2e973c4bff6911ed2a0a6f86b41531e7a7a212cb
Parents: 2d3061d
Author: Clebert Suconic 
Authored: Tue Jan 12 15:39:31 2016 -0500
Committer: Clebert Suconic 
Committed: Tue Jan 12 17:22:56 2016 -0500

--
 .../core/impl/wireformat/SessionReceiveLargeMessage.java  | 4 +++-
 .../apache/activemq/artemis/core/server/impl/QueueImpl.java   | 5 ++---
 .../activemq/artemis/core/server/impl/ServerConsumerImpl.java | 7 ---
 3 files changed, 9 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/2e973c4b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java
--
diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java
index 8b32256..aa5d98f 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionReceiveLargeMessage.java
@@ -84,7 +84,9 @@ public class SessionReceiveLargeMessage extends PacketImpl 
implements MessagePac
   buffer.writeLong(consumerID);
   buffer.writeInt(deliveryCount);
   buffer.writeLong(largeMessageSize);
-  message.encodeHeadersAndProperties(buffer);
+  if (message != null) {
+ message.encodeHeadersAndProperties(buffer);
+  }
}
 
@Override

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/2e973c4b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
--
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
index 12b5231..6f3cc6f 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
@@ -2493,8 +2493,10 @@ public class QueueImpl implements Queue {
private void proceedDeliver(Consumer consumer, MessageReference reference) {
   try {
  consumer.proceedDeliver(reference);
+ deliveriesInTransit.countDown();
   }
   catch (Throwable t) {
+ deliveriesInTransit.countDown();
  ActiveMQServerLogger.LOGGER.removingBadConsumer(t, consumer, 
reference);
 
  synchronized (this) {
@@ -2510,9 +2512,6 @@ public class QueueImpl implements Queue {
 addHead(reference);
  }
   }
-  finally {
- deliveriesInTransit.countDown();
-  }
}
 
private boolean checkExpired(final MessageReference reference) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/2e973c4b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
--
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
index 9468819..1cfc4f8 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
@@ -970,7 +970,8 @@ public class ServerConsumerImpl implements ServerConsumer, 
ReadyListener {
   public boolean deliver() throws Exception {
  lockDelivery.readLock().lock();
  try {
-if (largeMessage == null) {
+LargeServerMessage currentLargeMessage = largeMessage;
+if (currentLargeMessage == null) {
return true;
 }
 
@@ -984,7 +985,7 @@ public class ServerConsumerImpl implements ServerConsumer, 
ReadyListener {
 }
 
 if (!sentInitialPacket) {
-   context = 

[2/2] activemq git commit: https://issues.apache.org/jira/browse/AMQ-6059

2016-01-12 Thread tabish
https://issues.apache.org/jira/browse/AMQ-6059

Ensure that a message sent to the store for the DLQ is rewritten so that
its updated values are written to prevent exirpation loops and loss of
reollback cause etc.
(cherry picked from commit 505a76a8bb7180debbd36637dce1b9101150d0b4)


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

Branch: refs/heads/activemq-5.13.x
Commit: b04cfeb8af2cdf7d9ccbcd65a309478d4e01db9f
Parents: b4405be
Author: Timothy Bish 
Authored: Tue Jan 12 11:51:35 2016 -0500
Committer: Timothy Bish 
Committed: Tue Jan 12 12:00:41 2016 -0500

--
 .../org/apache/activemq/util/BrokerSupport.java |  13 +-
 .../org/apache/activemq/bugs/AMQ6059Test.java   | 199 +++
 2 files changed, 206 insertions(+), 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/b04cfeb8/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
--
diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java 
b/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
index f3f3b78..df3b658 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
@@ -31,24 +31,24 @@ import org.apache.activemq.state.ProducerState;
  */
 public final class BrokerSupport {
 
-private BrokerSupport() {
+private BrokerSupport() {
 }
-
+
 public static void resendNoCopy(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination) throws Exception {
 doResend(context, originalMessage, deadLetterDestination, false);
 }
-
+
 /**
  * @param context
- * @param originalMessage 
+ * @param originalMessage
  * @param deadLetterDestination
  * @throws Exception
  */
 public static void resend(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination) throws Exception {
 doResend(context, originalMessage, deadLetterDestination, true);
 }
-
-public static void doResend(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination, boolean copy) 
throws Exception {   
+
+public static void doResend(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination, boolean copy) 
throws Exception {
 Message message = copy ? originalMessage.copy() : originalMessage;
 message.setOriginalDestination(message.getDestination());
 message.setOriginalTransactionId(message.getTransactionId());
@@ -56,6 +56,7 @@ public final class BrokerSupport {
 message.setTransactionId(null);
 message.setMemoryUsage(null);
 message.setRedeliveryCounter(0);
+message.getMessageId().setDataLocator(null);
 boolean originalFlowControl = context.isProducerFlowControl();
 try {
 context.setProducerFlowControl(false);

http://git-wip-us.apache.org/repos/asf/activemq/blob/b04cfeb8/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java 
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java
new file mode 100644
index 000..049d683
--- /dev/null
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java
@@ -0,0 +1,199 @@
+/**
+ * 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.bugs;
+
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import 

[1/2] activemq git commit: AMQ-6121 AMQ-6122

2016-01-12 Thread tabish
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.13.x a558f8d4f -> b04cfeb8a


AMQ-6121
AMQ-6122

Prevent messages on DLQ for looping back onto the same DLQ.  Prevents
expired messages from bouncing back and duplicate messages from the
store from causing a deadlock.
(cherry picked from commit 66cfc7bab3dfa2e079bbc5276312c97ab02cae4f)


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

Branch: refs/heads/activemq-5.13.x
Commit: b4405bed5ea999e0ea6ce0ea61ee0d6871b7ac63
Parents: a558f8d
Author: Timothy Bish 
Authored: Mon Jan 11 10:57:38 2016 -0500
Committer: Timothy Bish 
Committed: Tue Jan 12 12:00:26 2016 -0500

--
 .../activemq/broker/region/RegionBroker.java|   8 +-
 .../broker/policy/DeadLetterTestSupport.java|   8 +-
 .../org/apache/activemq/bugs/AMQ6121Test.java   | 149 +
 .../org/apache/activemq/bugs/AMQ6122Test.java   | 158 +++
 4 files changed, 319 insertions(+), 4 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/b4405bed/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
--
diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
 
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
index e975b4c..961618d 100755
--- 
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
@@ -775,6 +775,13 @@ public class RegionBroker extends EmptyBroker {
 DeadLetterStrategy deadLetterStrategy = ((Destination) 
node.getRegionDestination()).getDeadLetterStrategy();
 if (deadLetterStrategy != null) {
 if 
(deadLetterStrategy.isSendToDeadLetterQueue(message)) {
+ActiveMQDestination deadLetterDestination = 
deadLetterStrategy.getDeadLetterQueueFor(message, subscription);
+// Prevent a DLQ loop where same message is sent 
from a DLQ back to itself
+if 
(deadLetterDestination.equals(message.getDestination())) {
+LOG.debug("Not re-adding to DLQ: {}, dest: 
{}", message.getMessageId(), message.getDestination());
+return false;
+}
+
 // message may be inflight to other subscriptions 
so do not modify
 message = message.copy();
 long dlqExpiration = 
deadLetterStrategy.getExpiration();
@@ -796,7 +803,6 @@ public class RegionBroker extends EmptyBroker {
 // not get filled when the message is first sent,
 // it is only populated if the message is routed to
 // another destination like the DLQ
-ActiveMQDestination deadLetterDestination = 
deadLetterStrategy.getDeadLetterQueueFor(message, subscription);
 ConnectionContext adminContext = context;
 if (context.getSecurityContext() == null || 
!context.getSecurityContext().isBrokerContext()) {
 adminContext = 
BrokerSupport.getConnectionContext(this);

http://git-wip-us.apache.org/repos/asf/activemq/blob/b4405bed/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java
index a0a8cc6..8f9c3ba 100755
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/policy/DeadLetterTestSupport.java
@@ -133,13 +133,15 @@ public abstract class DeadLetterTestSupport extends 
TestSupport {
 
 @Override
 public boolean isSatisified() throws Exception {
-QueueViewMBean dlqView = null;
+boolean satisfied = false;
+
 try {
-dlqView = getProxyToQueue(dlqQ.getQueueName());
+QueueViewMBean dlqView = 
getProxyToQueue(dlqQ.getQueueName());
+satisfied = dlqView != null ? dlqView.isDLQ() : 

activemq git commit: https://issues.apache.org/jira/browse/AMQ-6059

2016-01-12 Thread tabish
Repository: activemq
Updated Branches:
  refs/heads/master db1506a59 -> 505a76a8b


https://issues.apache.org/jira/browse/AMQ-6059

Ensure that a message sent to the store for the DLQ is rewritten so that
its updated values are written to prevent exirpation loops and loss of
reollback cause etc.

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

Branch: refs/heads/master
Commit: 505a76a8bb7180debbd36637dce1b9101150d0b4
Parents: db1506a
Author: Timothy Bish 
Authored: Tue Jan 12 11:51:35 2016 -0500
Committer: Timothy Bish 
Committed: Tue Jan 12 11:51:48 2016 -0500

--
 .../org/apache/activemq/util/BrokerSupport.java |  13 +-
 .../org/apache/activemq/bugs/AMQ6059Test.java   | 199 +++
 2 files changed, 206 insertions(+), 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/505a76a8/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
--
diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java 
b/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
index f3f3b78..df3b658 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/util/BrokerSupport.java
@@ -31,24 +31,24 @@ import org.apache.activemq.state.ProducerState;
  */
 public final class BrokerSupport {
 
-private BrokerSupport() {
+private BrokerSupport() {
 }
-
+
 public static void resendNoCopy(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination) throws Exception {
 doResend(context, originalMessage, deadLetterDestination, false);
 }
-
+
 /**
  * @param context
- * @param originalMessage 
+ * @param originalMessage
  * @param deadLetterDestination
  * @throws Exception
  */
 public static void resend(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination) throws Exception {
 doResend(context, originalMessage, deadLetterDestination, true);
 }
-
-public static void doResend(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination, boolean copy) 
throws Exception {   
+
+public static void doResend(final ConnectionContext context, Message 
originalMessage, ActiveMQDestination deadLetterDestination, boolean copy) 
throws Exception {
 Message message = copy ? originalMessage.copy() : originalMessage;
 message.setOriginalDestination(message.getDestination());
 message.setOriginalTransactionId(message.getTransactionId());
@@ -56,6 +56,7 @@ public final class BrokerSupport {
 message.setTransactionId(null);
 message.setMemoryUsage(null);
 message.setRedeliveryCounter(0);
+message.getMessageId().setDataLocator(null);
 boolean originalFlowControl = context.isProducerFlowControl();
 try {
 context.setProducerFlowControl(false);

http://git-wip-us.apache.org/repos/asf/activemq/blob/505a76a8/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java 
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java
new file mode 100644
index 000..049d683
--- /dev/null
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/bugs/AMQ6059Test.java
@@ -0,0 +1,199 @@
+/**
+ * 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.bugs;
+
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+

svn commit: r977554 - in /websites/production/activemq/content/maven/5.12.2: ./ apidocs/ apidocs/org/ apidocs/org/apache/ apidocs/org/apache/activemq/ apidocs/org/apache/activemq/advisory/ apidocs/org

2016-01-12 Thread cshannon
Author: cshannon
Date: Tue Jan 12 17:34:25 2016
New Revision: 977554

Log:
Adding 5.12.2 apidocs


[This commit notification would consist of 2907 parts, 
which exceeds the limit of 50 ones, so it was shortened to the summary.]