Build failed in Jenkins: ActiveMQ-Java8 #141
See https://builds.apache.org/job/ActiveMQ-Java8/141/ -- [...truncated 2839 lines...] Took 0.13 sec [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-itests-spring31/pom.xml to org.apache.activemq/activemq-itests-spring31/5.11-SNAPSHOT/activemq-itests-spring31-5.11-SNAPSHOT.pom Sending artifact delta relative to ActiveMQ-Java8 » ActiveMQ :: Integration Test :: Spring 3.1 #140 Archived 1 artifacts Archive block size is 32768 Received 0 blocks and 3005 bytes Compression is 0.0% Took 60 ms [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/assembly/pom.xml to org.apache.activemq/apache-activemq/5.11-SNAPSHOT/apache-activemq-5.11-SNAPSHOT.pom Sending artifact delta relative to ActiveMQ-Java8 » ActiveMQ :: Assembly #140 Archived 1 artifacts Archive block size is 32768 Received 0 blocks and 18450 bytes Compression is 0.0% Took 8.7 sec [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-jms-pool/pom.xml to org.apache.activemq/activemq-jms-pool/5.11-SNAPSHOT/activemq-jms-pool-5.11-SNAPSHOT.pom [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-jms-pool/target/activemq-jms-pool-5.11-SNAPSHOT.jar to org.apache.activemq/activemq-jms-pool/5.11-SNAPSHOT/activemq-jms-pool-5.11-SNAPSHOT.jar [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-jms-pool/target/activemq-jms-pool-5.11-SNAPSHOT-sources.jar to org.apache.activemq/activemq-jms-pool/5.11-SNAPSHOT/activemq-jms-pool-5.11-SNAPSHOT-sources.jar Sending artifact delta relative to ActiveMQ-Java8 » ActiveMQ :: Generic JMS Pool #140 Archived 3 artifacts Archive block size is 32768 Received 0 blocks and 93796 bytes Compression is 0.0% Took 0.24 sec [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-log4j-appender/pom.xml to org.apache.activemq/activemq-log4j-appender/5.11-SNAPSHOT/activemq-log4j-appender-5.11-SNAPSHOT.pom [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-log4j-appender/target/activemq-log4j-appender-5.11-SNAPSHOT.jar to org.apache.activemq/activemq-log4j-appender/5.11-SNAPSHOT/activemq-log4j-appender-5.11-SNAPSHOT.jar [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-log4j-appender/target/activemq-log4j-appender-5.11-SNAPSHOT-sources.jar to org.apache.activemq/activemq-log4j-appender/5.11-SNAPSHOT/activemq-log4j-appender-5.11-SNAPSHOT-sources.jar Sending artifact delta relative to ActiveMQ-Java8 » ActiveMQ :: Log4j Appender #140 Archived 3 artifacts Archive block size is 32768 Received 0 blocks and 28393 bytes Compression is 0.0% Took 41 ms [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-runtime-config/pom.xml to org.apache.activemq/activemq-runtime-config/5.11-SNAPSHOT/activemq-runtime-config-5.11-SNAPSHOT.pom [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-runtime-config/target/activemq-runtime-config-5.11-SNAPSHOT.jar to org.apache.activemq/activemq-runtime-config/5.11-SNAPSHOT/activemq-runtime-config-5.11-SNAPSHOT.jar [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-runtime-config/target/activemq-runtime-config-5.11-SNAPSHOT-sources.jar to org.apache.activemq/activemq-runtime-config/5.11-SNAPSHOT/activemq-runtime-config-5.11-SNAPSHOT-sources.jar Sending artifact delta relative to ActiveMQ-Java8 » ActiveMQ :: Runtime Configuration #140 Archived 3 artifacts Archive block size is 32768 Received 0 blocks and 2423027 bytes Compression is 0.0% Took 2.8 sec [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-pool/pom.xml to org.apache.activemq/activemq-pool/5.11-SNAPSHOT/activemq-pool-5.11-SNAPSHOT.pom [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-pool/target/activemq-pool-5.11-SNAPSHOT.jar to org.apache.activemq/activemq-pool/5.11-SNAPSHOT/activemq-pool-5.11-SNAPSHOT.jar [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-pool/target/activemq-pool-5.11-SNAPSHOT-sources.jar to org.apache.activemq/activemq-pool/5.11-SNAPSHOT/activemq-pool-5.11-SNAPSHOT-sources.jar Sending artifact delta relative to ActiveMQ-Java8 » ActiveMQ :: Pool #140 Archived 3 artifacts Archive block size is 32768 Received 0 blocks and 36859 bytes Compression is 0.0% Took 2.3 sec [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-stomp/pom.xml to org.apache.activemq/activemq-stomp/5.11-SNAPSHOT/activemq-stomp-5.11-SNAPSHOT.pom [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-stomp/target/activemq-stomp-5.11-SNAPSHOT.jar to org.apache.activemq/activemq-stomp/5.11-SNAPSHOT/activemq-stomp-5.11-SNAPSHOT.jar [JENKINS] Archiving https://builds.apache.org/job/ActiveMQ-Java8/ws/activemq-stomp/target/activemq-stomp-5.11-SNAPSHOT-sources.jar to
Build failed in Jenkins: ActiveMQ-Java8 » ActiveMQ :: AMQP #141
See https://builds.apache.org/job/ActiveMQ-Java8/org.apache.activemq$activemq-amqp/141/ -- [INFO] [INFO] [INFO] Building ActiveMQ :: AMQP 5.11-SNAPSHOT [INFO] Downloading: http://repo.maven.apache.org/maven2/org/eclipse/jetty/maven-jetty-plugin/7.6.9.v20130131/maven-jetty-plugin-7.6.9.v20130131.pom [WARNING] The POM for org.eclipse.jetty:maven-jetty-plugin:jar:7.6.9.v20130131 is missing, no dependency information available [WARNING] Failed to retrieve plugin descriptor for org.eclipse.jetty:maven-jetty-plugin:7.6.9.v20130131: Plugin org.eclipse.jetty:maven-jetty-plugin:7.6.9.v20130131 or one of its dependencies could not be resolved: Failed to read artifact descriptor for org.eclipse.jetty:maven-jetty-plugin:jar:7.6.9.v20130131 [WARNING] The POM for org.apache.qpid:proton-jms:jar:1.0-SNAPSHOT is missing, no dependency information available
[2/2] git commit: Remove unused imports
Remove unused imports Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/27833d02 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/27833d02 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/27833d02 Branch: refs/heads/trunk Commit: 27833d025e220492d5c3494a8d46b6c61ea24ee1 Parents: 78446ad Author: Timothy Bish tabish...@gmail.com Authored: Tue Oct 14 11:47:48 2014 -0400 Committer: Timothy Bish tabish...@gmail.com Committed: Tue Oct 14 11:47:48 2014 -0400 -- .../transport/amqp/JmsClientRequestResponseTest.java | 1 - .../transport/amqp/joram/JoramJmsNioPlusSslTest.java | 4 .../activemq/transport/amqp/joram/JoramJmsNioTest.java | 1 - .../apache/activemq/transport/amqp/joram/JoramSslTest.java | 8 ++-- 4 files changed, 2 insertions(+), 12 deletions(-) -- http://git-wip-us.apache.org/repos/asf/activemq/blob/27833d02/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JmsClientRequestResponseTest.java -- diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JmsClientRequestResponseTest.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JmsClientRequestResponseTest.java index c79493a..87ec883 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JmsClientRequestResponseTest.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JmsClientRequestResponseTest.java @@ -14,7 +14,6 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.apache.activemq.transport.amqp; import static org.junit.Assert.assertEquals; http://git-wip-us.apache.org/repos/asf/activemq/blob/27833d02/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioPlusSslTest.java -- diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioPlusSslTest.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioPlusSslTest.java index 5cd6415..e6b5a91 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioPlusSslTest.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioPlusSslTest.java @@ -16,21 +16,17 @@ */ package org.apache.activemq.transport.amqp.joram; -import java.security.SecureRandom; - import javax.net.ssl.KeyManager; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManager; import org.apache.activemq.transport.amqp.DefaultTrustManager; - import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Rule; import org.junit.rules.Timeout; import org.junit.runner.RunWith; import org.junit.runners.Suite; - import org.objectweb.jtests.jms.conform.connection.ConnectionTest; import org.objectweb.jtests.jms.conform.connection.TopicConnectionTest; import org.objectweb.jtests.jms.conform.message.MessageBodyTest; http://git-wip-us.apache.org/repos/asf/activemq/blob/27833d02/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioTest.java -- diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioTest.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioTest.java index b50bbff..afb6ece 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioTest.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramJmsNioTest.java @@ -17,7 +17,6 @@ package org.apache.activemq.transport.amqp.joram; import org.junit.BeforeClass; -import org.junit.Ignore; import org.junit.Rule; import org.junit.rules.Timeout; import org.junit.runner.RunWith; http://git-wip-us.apache.org/repos/asf/activemq/blob/27833d02/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramSslTest.java -- diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramSslTest.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramSslTest.java index 4070f1f..07fab5c 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramSslTest.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/joram/JoramSslTest.java @@ -16,21 +16,17 @@ */ package org.apache.activemq.transport.amqp.joram; -import java.security.SecureRandom; - import javax.net.ssl.KeyManager; import javax.net.ssl.SSLContext; import
[1/2] git commit: https://issues.apache.org/jira/browse/AMQ-5395
Repository: activemq
Updated Branches:
refs/heads/trunk 0cf7c0bc4 - 27833d025
https://issues.apache.org/jira/browse/AMQ-5395
Check for the presence of a prefix before asking for a substring
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/78446ad1
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/78446ad1
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/78446ad1
Branch: refs/heads/trunk
Commit: 78446ad1759706df7662018571e68bc471a6ac28
Parents: 0cf7c0b
Author: Timothy Bish tabish...@gmail.com
Authored: Tue Oct 14 11:46:49 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Tue Oct 14 11:46:49 2014 -0400
--
.../activemq/transport/amqp/ActiveMQJMSVendor.java | 11 ++-
1 file changed, 10 insertions(+), 1 deletion(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/78446ad1/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/ActiveMQJMSVendor.java
--
diff --git
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/ActiveMQJMSVendor.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/ActiveMQJMSVendor.java
index 59c29e3..b576c6b 100644
---
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/ActiveMQJMSVendor.java
+++
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/ActiveMQJMSVendor.java
@@ -47,6 +47,8 @@ public class ActiveMQJMSVendor extends JMSVendor {
final public static ActiveMQJMSVendor INSTANCE = new ActiveMQJMSVendor();
+private static final String PREFIX_MARKER = ://;
+
private ActiveMQJMSVendor() {
}
@@ -87,7 +89,13 @@ public class ActiveMQJMSVendor extends JMSVendor {
@Override
public T extends Destination T createDestination(String name, ClassT
kind) {
-String destinationName = name.substring(name.lastIndexOf(://) + 3);
+String destinationName = name;
+int prefixEnd = name.lastIndexOf(PREFIX_MARKER);
+
+if (prefixEnd = 0) {
+destinationName = name.substring(prefixEnd +
PREFIX_MARKER.length());
+}
+
if (kind == Queue.class) {
return kind.cast(new ActiveMQQueue(destinationName));
}
@@ -100,6 +108,7 @@ public class ActiveMQJMSVendor extends JMSVendor {
if (kind == TemporaryTopic.class) {
return kind.cast(new ActiveMQTempTopic(destinationName));
}
+
return kind.cast(ActiveMQDestination.createDestination(name,
ActiveMQDestination.QUEUE_TYPE));
}
buildbot failure in ASF Buildbot on activemq-site-production
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/4187 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
buildbot success in ASF Buildbot on activemq-site-production
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/4188 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
git commit: https://issues.apache.org/jira/browse/AMQ-5391
Repository: activemq
Updated Branches:
refs/heads/trunk 27833d025 - 78cb1120b
https://issues.apache.org/jira/browse/AMQ-5391
Allow for an anonymous relay using a configurable node name when
creating the new link, default is $relay. Message's that arrive without
a to field set are rejected as this is required for a relay.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/78cb1120
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/78cb1120
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/78cb1120
Branch: refs/heads/trunk
Commit: 78cb1120b7b93957c36e0abc12e1d22f0f0d7390
Parents: 27833d0
Author: Timothy Bish tabish...@gmail.com
Authored: Tue Oct 14 17:32:23 2014 -0400
Committer: Timothy Bish tabish...@gmail.com
Committed: Tue Oct 14 17:32:23 2014 -0400
--
.../transport/amqp/AmqpProtocolConverter.java | 57 ++--
.../activemq/transport/amqp/AmqpWireFormat.java | 9
2 files changed, 62 insertions(+), 4 deletions(-)
--
http://git-wip-us.apache.org/repos/asf/activemq/blob/78cb1120/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
--
diff --git
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
index fb275b8..472aeb9 100644
---
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
+++
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
@@ -26,6 +26,7 @@ import java.util.LinkedList;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
+import javax.jms.Destination;
import javax.jms.InvalidClientIDException;
import javax.jms.InvalidSelectorException;
@@ -111,10 +112,12 @@ class AmqpProtocolConverter implements
IAmqpProtocolConverter {
private static final Logger TRACE_FRAMES =
AmqpTransportFilter.TRACE_FRAMES;
private static final Logger LOG =
LoggerFactory.getLogger(AmqpProtocolConverter.class);
private static final byte[] EMPTY_BYTE_ARRAY = new byte[] {};
+private static final int CHANNEL_MAX = 32767;
private final AmqpTransport amqpTransport;
private static final Symbol COPY = Symbol.getSymbol(copy);
private static final Symbol JMS_SELECTOR = Symbol.valueOf(jms-selector);
private static final Symbol NO_LOCAL = Symbol.valueOf(no-local);
+private static final Symbol ANONYMOUS_RELAY =
Symbol.valueOf(x-opt-anonymous-relay);
private static final Symbol DURABLE_SUBSCRIPTION_ENDED =
Symbol.getSymbol(DURABLE_SUBSCRIPTION_ENDED);
protected int prefetch;
@@ -132,10 +135,33 @@ class AmqpProtocolConverter implements
IAmqpProtocolConverter {
}
this.protonTransport.bind(this.protonConnection);
+
+// NOTE: QPid JMS client has a bug where the channel max is stored as a
+// short value in the Connection class which means that if we
allow
+// the default channel max of 65535 to be sent then no new
sessions
+// can be created because the value would be -1 when checked.
+this.protonTransport.setChannelMax(CHANNEL_MAX);
+
this.protonConnection.collect(eventCollector);
+this.protonConnection.setProperties(getConnectionProperties());
+
updateTracer();
}
+/**
+ * Load and return a codeMapSymbol, Object/code that contains the
connection
+ * properties which will allow the client to better communicate with this
broker.
+ *
+ * @return the properties that are sent to new clients on connect.
+ */
+protected MapSymbol, Object getConnectionProperties() {
+MapSymbol, Object properties = new HashMapSymbol, Object();
+
+properties.put(ANONYMOUS_RELAY,
amqpTransport.getWireFormat().getAnonymousNodeName());
+
+return properties;
+}
+
@Override
public void updateTracer() {
if (amqpTransport.isTrace()) {
@@ -559,10 +585,12 @@ class AmqpProtocolConverter implements
IAmqpProtocolConverter {
private final LongSequenceGenerator messageIdGenerator = new
LongSequenceGenerator();
private final ActiveMQDestination destination;
private boolean closed;
+private final boolean anonymous;
-public ProducerContext(ProducerId producerId, ActiveMQDestination
destination) {
+public ProducerContext(ProducerId producerId, ActiveMQDestination
destination, boolean anonymous) {
this.producerId = producerId;
this.destination = destination;
+this.anonymous = anonymous;
}
@Override
@@ -581,6 +609,17 @@ class
