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

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build became unstable: ActiveMQ-Java8 » ActiveMQ :: MQTT Protocol #862

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java8 #862

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is back to stable : ActiveMQ-Java7 » ActiveMQ :: HTTP Protocol Support #1166

2016-10-14 Thread Apache Jenkins Server 
See

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

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java7 » ActiveMQ :: MQTT Protocol #1166

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is back to stable : ActiveMQ-Java7 » ActiveMQ :: STOMP Protocol #1166

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build became unstable: ActiveMQ-Java7 » ActiveMQ :: LevelDB Store #1166

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is back to stable : ActiveMQ-Java7 » ActiveMQ :: Camel #1166

2016-10-14 Thread Apache Jenkins Server 
See

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

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: Karaf Integration Tests #861

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build became unstable: ActiveMQ-Java8 » ActiveMQ :: LevelDB Store #861

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java8 #861

2016-10-14 Thread Apache Jenkins Server 
See

svn commit: r999454 - in /websites/production/activemq/content: apache-activemq-board-report-201610-october.html cache/main.pageCache

2016-10-14 Thread buildbot 
Author: buildbot
Date: Fri Oct 14 23:22:36 2016
New Revision: 999454

Log:
Production update by buildbot for activemq

Modified:

websites/production/activemq/content/apache-activemq-board-report-201610-october.html
websites/production/activemq/content/cache/main.pageCache

Modified: 
websites/production/activemq/content/apache-activemq-board-report-201610-october.html
==
--- 
websites/production/activemq/content/apache-activemq-board-report-201610-october.html
 (original)
+++ 
websites/production/activemq/content/apache-activemq-board-report-201610-october.html
 Fri Oct 14 23:22:36 2016
@@ -72,7 +72,7 @@
   
 
 
-DescriptionApache ActiveMQ is a popular and powerful open source 
message-oriented middleware. Apache ActiveMQ is fast, supports many cross 
language clients and protocols, comes with easy to use enterprise integration 
patterns and many advanced features while fully supporting JMS 2.0, Java EE 
1.7, AMQP 1.0, MQTT, Stomp and REST.ActivityOverall, the project health 
is very stable. No disgreements in thecommunity and the folks on the 
project are working together on both ActiveMQand Artemis. The ActiveMQ 
code base continues to grow and improve and it ispushing releases more 
frequently as was the plan. Activity with the Artemiscode base continues 
its successful march toward full compatibility 
withActiveMQ.ActiveMQActive Discussions around a 
new web consoleThe project is a little stuck 
on the docker issues pending infra and legalresolutionActiveMQ ArtemisApache Artemis 1.4.0 ReleasedAMQP 1.0 implement
 ation improvementsLocal 
transaction support improvedMulti-session-per-tx and multi-tx-per-session capabilities 
supportSupport for 
OASIS AMQP JMS mappings for JMS 1.1 over AMQP 1.0 
addedMajor refactor of 
the AMQP implementation making it simpler and easier to 
understand[CVE-2016-4978] 
Apache ActiveMQ Artemis: Deserialization of untrusted input 
vunerability.Fixed in 
Apache Artemis 1.4.0Announcement madeSupport for settin
 g global limits (total memory and disk utilization) 
addedBasic Java EE 
CDI integration addedPMC 
changesCurrently 23 PMC membersNo new PMC members 
added in the last 3 monthsLast PMC addition was Martyn Taylor on Fri 
Jul 08 2016Committer base 
changesCurrently 57 committersJohn D. Ament was 
added as a committer on Mon Aug 08 
2016Releases5.13.4 was released on 
Mon Jul 18 20165.14.0 was released on Thu Aug 04 20165.14.1 
was released on Thu Sep 29 2016ActiveMQ Artemis 1.4.0 was released on 
Mon Sep 12 2016(Most of this information is pulled from https://reporter.apache.org/;>reporter.apache.org)
+DescriptionApache ActiveMQ is a popular and powerful open source 
message-oriented middleware. Apache ActiveMQ is fast, supports many cross 
language clients and protocols, comes with easy to use enterprise integration 
patterns and many advanced features while fully supporting JMS 2.0, AMQP 1.0, 
MQTT, Stomp and REST.ActivityOverall, the project health 
is very stable. No disgreements in thecommunity and the folks on the 
project are working together on both ActiveMQand Artemis. The ActiveMQ 
code base continues to grow and improve and it ispushing releases more 
frequently as was the plan. Activity with the Artemiscode base continues 
its successful march toward full compatibility 
withActiveMQ.ActiveMQActive 
Discussions around a new web consoleThe project is a 
little stuck on the docker issues pending infra and legalresolutionActiveMQ ArtemisApache Artemis 1.4.0 ReleasedAMQP 1.0 implementation improve
 mentsLocal transaction 
support improvedMulti-session-per-tx and multi-tx-per-session capabilities 
supportSupport for 
OASIS AMQP JMS mappings for JMS 1.1 over AMQP 1.0 
addedMajor refactor of 
the AMQP implementation making it simpler and easier to 
understand[CVE-2016-4978] 
Apache ActiveMQ Artemis: Deserialization of untrusted input 
vunerability.Fixed in 
Apache Artemis 1.4.0Announcement madeSupport for setting global limi
 ts (total memory and disk utilization) addedBasic Java EE CDI integration 
addedPMC 
changesCurrently 23 PMC membersNo new PMC members 
added in the last 3 monthsLast PMC addition was Martyn Taylor on Fri 
Jul 08 2016Committer base 
changesCurrently 57 committersJohn D. Ament was 
added as a committer on Mon Aug 08 
2016Releases5.13.4 was released on 
Mon Jul 18 20165.14.0 was released on Thu Aug 04 20165.14.1 
was released on Thu Sep 29 2016ActiveMQ Artemis 1.4.0 was released on 
Mon Sep 12 2016(Most of this information is pulled from https://reporter.apache.org/;>reporter.apache.org)
 
 
   

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

[CONF] Apache ActiveMQ > Apache ActiveMQ Board Report - 2016.10 (October)

2016-10-14 Thread Bruce Snyder (Confluence) 
Title: Message Title



 
 
 
 
 
 
 

Bruce Snyder edited a page 
 
 
  
 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
Apache ActiveMQ Board Report - 2016.10 (October) 
 
 
  
 
 
 
 
 
 
 ...  Apache ActiveMQ is a popular and powerful open source message-oriented middleware. Apache ActiveMQ is fast, supports many cross language clients and protocols, comes with easy to use enterprise integration patterns and many advanced features while fully supporting JMS 2.0, Java EE 1.7, AMQP 1.0, MQTT, Stomp and REST.  ...  
 
 
  
 
 
 
 
 
 
 
 
 
 

View page
• 
 
 
 
 
 
 

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

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

2016-10-14 Thread tabish 
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.14.x cf72e7214 -> 335a490ea


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

Fill in the source / target created for the requested dynamic node with
the actual attributes we are going to support.
(cherry picked from commit 10fc397ab72bcd3c111b517af687ccf4c9372ced)


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

Branch: refs/heads/activemq-5.14.x
Commit: 335a490eac84680bab50350a2bb5894c0248f18c
Parents: cf72e72
Author: Timothy Bish 
Authored: Fri Oct 14 15:00:49 2016 -0400
Committer: Timothy Bish 
Committed: Fri Oct 14 15:01:25 2016 -0400

--
 .../activemq/transport/amqp/AmqpSupport.java| 28 +++-
 .../transport/amqp/protocol/AmqpConnection.java |  2 +-
 .../transport/amqp/protocol/AmqpSession.java| 22 +--
 .../amqp/interop/AmqpTempDestinationTest.java   | 26 +-
 4 files changed, 73 insertions(+), 5 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/335a490e/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
index 9087cf1..43cecc8 100644
--- 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
+++ 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
@@ -1,4 +1,4 @@
-/**
+/*
  * 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.
@@ -44,6 +44,8 @@ public class AmqpSupport {
 // Capabilities used to identify destination type in some requests.
 public static final Symbol TEMP_QUEUE_CAPABILITY = 
Symbol.valueOf("temporary-queue");
 public static final Symbol TEMP_TOPIC_CAPABILITY = 
Symbol.valueOf("temporary-topic");
+public static final Symbol QUEUE_CAPABILITY = Symbol.valueOf("queue");
+public static final Symbol TOPIC_CAPABILITY = Symbol.valueOf("topic");
 
 // Symbols used to announce connection information to remote peer.
 public static final Symbol INVALID_FIELD = Symbol.valueOf("invalid-field");
@@ -214,4 +216,28 @@ public class AmqpSupport {
 throw new RuntimeException("Unexpected terminus type: " + 
endpoint);
 }
 }
+
+/**
+ * Given an ActiveMQDestination return the proper Capability value for the 
concrete destination type.
+ *
+ * @param destination
+ *  The ActiveMQDestination whose capability is being requested.
+ *
+ * @return a Symbol that matches the defined Capability value for the 
ActiveMQDestiantion.
+ */
+public static Symbol getDestinationTypeSymbol(ActiveMQDestination 
destination) {
+if (destination.isQueue()) {
+if (destination.isTemporary()) {
+return TEMP_QUEUE_CAPABILITY;
+} else {
+return QUEUE_CAPABILITY;
+}
+} else {
+if (destination.isTemporary()) {
+return TEMP_TOPIC_CAPABILITY;
+} else {
+return TOPIC_CAPABILITY;
+}
+}
+}
 }

http://git-wip-us.apache.org/repos/asf/activemq/blob/335a490e/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
index 5a402ba..3696a68 100644
--- 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
+++ 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
@@ -1,4 +1,4 @@
-/**
+/*
  * 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.

http://git-wip-us.apache.org/repos/asf/activemq/blob/335a490e/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
--
diff --git

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

2016-10-14 Thread tabish 
Repository: activemq
Updated Branches:
  refs/heads/master d9d1ae73e -> 10fc397ab


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

Fill in the source / target created for the requested dynamic node with
the actual attributes we are going to support.

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

Branch: refs/heads/master
Commit: 10fc397ab72bcd3c111b517af687ccf4c9372ced
Parents: d9d1ae7
Author: Timothy Bish 
Authored: Fri Oct 14 15:00:49 2016 -0400
Committer: Timothy Bish 
Committed: Fri Oct 14 15:00:49 2016 -0400

--
 .../activemq/transport/amqp/AmqpSupport.java| 28 +++-
 .../transport/amqp/protocol/AmqpConnection.java |  2 +-
 .../transport/amqp/protocol/AmqpSession.java| 22 +--
 .../amqp/interop/AmqpTempDestinationTest.java   | 26 +-
 4 files changed, 73 insertions(+), 5 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/10fc397a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
index 9087cf1..43cecc8 100644
--- 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
+++ 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpSupport.java
@@ -1,4 +1,4 @@
-/**
+/*
  * 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.
@@ -44,6 +44,8 @@ public class AmqpSupport {
 // Capabilities used to identify destination type in some requests.
 public static final Symbol TEMP_QUEUE_CAPABILITY = 
Symbol.valueOf("temporary-queue");
 public static final Symbol TEMP_TOPIC_CAPABILITY = 
Symbol.valueOf("temporary-topic");
+public static final Symbol QUEUE_CAPABILITY = Symbol.valueOf("queue");
+public static final Symbol TOPIC_CAPABILITY = Symbol.valueOf("topic");
 
 // Symbols used to announce connection information to remote peer.
 public static final Symbol INVALID_FIELD = Symbol.valueOf("invalid-field");
@@ -214,4 +216,28 @@ public class AmqpSupport {
 throw new RuntimeException("Unexpected terminus type: " + 
endpoint);
 }
 }
+
+/**
+ * Given an ActiveMQDestination return the proper Capability value for the 
concrete destination type.
+ *
+ * @param destination
+ *  The ActiveMQDestination whose capability is being requested.
+ *
+ * @return a Symbol that matches the defined Capability value for the 
ActiveMQDestiantion.
+ */
+public static Symbol getDestinationTypeSymbol(ActiveMQDestination 
destination) {
+if (destination.isQueue()) {
+if (destination.isTemporary()) {
+return TEMP_QUEUE_CAPABILITY;
+} else {
+return QUEUE_CAPABILITY;
+}
+} else {
+if (destination.isTemporary()) {
+return TEMP_TOPIC_CAPABILITY;
+} else {
+return TOPIC_CAPABILITY;
+}
+}
+}
 }

http://git-wip-us.apache.org/repos/asf/activemq/blob/10fc397a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
index 5a402ba..3696a68 100644
--- 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
+++ 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpConnection.java
@@ -1,4 +1,4 @@
-/**
+/*
  * 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.

http://git-wip-us.apache.org/repos/asf/activemq/blob/10fc397a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSession.java

Jenkins build is still unstable: ActiveMQ-Java8 #860

2016-10-14 Thread Apache Jenkins Server 
See

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

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is back to stable : ActiveMQ-Java8 » ActiveMQ :: STOMP Protocol #860

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is back to stable : ActiveMQ-Java8 » ActiveMQ :: MQTT Protocol #860

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: Karaf Integration Tests #860

2016-10-14 Thread Apache Jenkins Server 
See

svn commit: r999437 - in /websites/production/activemq/content: activemq-inactivitymonitor.html cache/main.pageCache

2016-10-14 Thread buildbot 
Author: buildbot
Date: Fri Oct 14 17:22:34 2016
New Revision: 999437

Log:
Production update by buildbot for activemq

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

Modified: websites/production/activemq/content/activemq-inactivitymonitor.html
==
--- websites/production/activemq/content/activemq-inactivitymonitor.html 
(original)
+++ websites/production/activemq/content/activemq-inactivitymonitor.html Fri 
Oct 14 17:22:34 2016
@@ -70,7 +70,7 @@
 
 
   
-Using ActiveMQ 4Configuring TransportsActiveMQ InactivityMonitor
+Using ActiveMQConfiguring TransportsActiveMQ InactivityMonitor
   
   
 Download | http://activemq.apache.org/maven/apidocs/index.html;>JavaDocs More... | Source | Forums | Support
@@ -81,7 +81,7 @@
   
 
 
-ActiveMQ 
InactivityMonitorThe ActiveMQ InactivityMonitor is an active thread 
that checks the connection is still active and if it suspects the connection is 
not functioning correctly, it closes the connection.Connections are 
monitored by:ensuring data is read from the connection during the 
specified time period (Max Inactivity Duration)writing 
aKeepAliveInfo message to the connection if 
no normal activemq traffic is sent across the connection 
during the specified time periodEach connection has two 
InactivityMonitors associated, one on each end of the connection. The 
InactivityMonitor expects to receive data on the connection during a specified 
time period. If normal activemq traffic has not been sent 
across the connection during that period, it expects to receive a
 0;KeepAliveInfo message sent by the 
InactivityMonitor on the other end of the connection.Using the default 
values; if no data has been written or read from the connection for 30 seconds, 
the InactivityMonitor kicks in. The InactivityMonitor throws 
anInactivityIOException and shuts down the 
transport associated with the connection. This results in the 
followingDEBUG logging:
+ActiveMQ 
InactivityMonitorThe ActiveMQ InactivityMonitor is an active thread 
that checks the connection is still active and if it suspects the connection is 
not functioning correctly, it closes the connection.Connections are 
monitored by:Ensuring data is read from the connection during the 
specified time period (Max Inactivity Duration).Writing 
aKeepAliveInfo message to the connection if 
no normal activemq traffic is sent across the connection 
during the specified time period.Each connection has two 
InactivityMonitors associated, one on each end of the connection. The 
InactivityMonitor expects to receive data on the connection during a specified 
time period. If normal ActiveMQ traffic has not been sent 
across the connection during that period, it expects to receive a

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

2016-10-14 Thread tabish 
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.14.x b49df4848 -> cf72e7214


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

Update to Proton 0.15.0
(cherry picked from commit d9d1ae73eb5d9301df47afff0fd3ebcc0f592ff5)


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

Branch: refs/heads/activemq-5.14.x
Commit: cf72e7214d13cd28f1e8d2058053d79dcf1e194d
Parents: b49df48
Author: Timothy Bish 
Authored: Fri Oct 14 13:11:30 2016 -0400
Committer: Timothy Bish 
Committed: Fri Oct 14 13:21:40 2016 -0400

--
 pom.xml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/cf72e721/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 4a999fd..8e617f4 100755
--- a/pom.xml
+++ b/pom.xml
@@ -101,7 +101,7 @@
 1.1.2
 1.4.0
 3.4.6
-0.14.0
+0.15.0
 0.11.1
 4.0.41.Final
 1.3
@@ -1661,7 +1661,7 @@
 ${jetty9-version}
 
 
-
+
 
 
   jdk8-disable-doclint

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

2016-10-14 Thread tabish 
Repository: activemq
Updated Branches:
  refs/heads/master 406a34294 -> d9d1ae73e


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

Update to Proton 0.15.0

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

Branch: refs/heads/master
Commit: d9d1ae73eb5d9301df47afff0fd3ebcc0f592ff5
Parents: 406a342
Author: Timothy Bish 
Authored: Fri Oct 14 13:11:30 2016 -0400
Committer: Timothy Bish 
Committed: Fri Oct 14 13:21:05 2016 -0400

--
 pom.xml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/d9d1ae73/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 8a735ea..61a2b8d 100755
--- a/pom.xml
+++ b/pom.xml
@@ -102,7 +102,7 @@
 1.1.2
 1.4.0
 3.4.6
-0.14.0
+0.15.0
 0.11.1
 4.0.41.Final
 1.3
@@ -1662,7 +1662,7 @@
 ${jetty9-version}
 
 
-
+
 
 
   jdk8-disable-doclint

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

2016-10-14 Thread cshannon 
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.14.x d126afc8f -> b49df4848


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

Properly decrementing the message reference count in
DemandForwardingBridgeSupport when messages supression is checked for
durable subscriptions

(cherry picked from commit 406a34294befca4ba2de4b728c86f64b96a94945)


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

Branch: refs/heads/activemq-5.14.x
Commit: b49df4848e81b58484644ab32f424b9c6bcb7243
Parents: d126afc
Author: Christopher L. Shannon (cshannon) 
Authored: Fri Oct 14 12:15:06 2016 -0400
Committer: Christopher L. Shannon (cshannon) 
Committed: Fri Oct 14 12:16:36 2016 -0400

--
 .../network/DemandForwardingBridgeSupport.java  |  3 +
 .../activemq/network/SimpleNetworkTest.java | 89 
 2 files changed, 92 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/b49df484/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
--
diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
 
b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
index 70449f0..b58259d 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
@@ -1158,6 +1158,9 @@ public abstract class DemandForwardingBridgeSupport 
implements NetworkBridge, Br
 messageEvalContext.setMessageReference(md.getMessage());
 messageEvalContext.setDestination(md.getDestination());
 suppress = 
!sub.getNetworkBridgeFilter().matches(messageEvalContext);
+//AMQ-6465 - Need to decrement the reference count after checking 
matches() as
+//the call above will increment the reference count by 1
+messageEvalContext.getMessageReference().decrementReferenceCount();
 }
 return suppress;
 }

http://git-wip-us.apache.org/repos/asf/activemq/blob/b49df484/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
index 5d3376b..5c6b35a 100755
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
@@ -43,9 +43,11 @@ import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.command.ActiveMQTopic;
 import org.apache.activemq.command.ConsumerId;
 import org.apache.activemq.util.Wait;
+import org.apache.activemq.util.Wait.Condition;
 import org.apache.activemq.xbean.BrokerFactoryBean;
 import org.junit.After;
 import org.junit.Before;
@@ -198,6 +200,93 @@ public class SimpleNetworkTest {
 }));
 }
 
+//Added for AMQ-6465 to make sure memory usage decreased back to 0 after 
messages are forwarded
+//to the other broker
+@Test(timeout = 60 * 1000)
+public void testDurableTopicSubForwardMemoryUsage() throws Exception {
+// create a remote durable consumer to create demand
+MessageConsumer remoteConsumer = 
remoteSession.createDurableSubscriber(included, consumerName);
+Thread.sleep(1000);
+
+MessageProducer producer = localSession.createProducer(included);
+for (int i = 0; i < MESSAGE_COUNT; i++) {
+Message test = localSession.createTextMessage("test-" + i);
+producer.send(test);
+}
+Thread.sleep(1000);
+
+//Make sure stats are set
+assertEquals(MESSAGE_COUNT,
+
localBroker.getDestination(included).getDestinationStatistics().getForwards().getCount());
+
+assertTrue(Wait.waitFor(new Condition() {
+
+@Override
+public boolean isSatisified() throws Exception {
+return 
localBroker.getSystemUsage().getMemoryUsage().getUsage() == 0;
+}
+}, 1, 500));
+

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

2016-10-14 Thread cshannon 
Repository: activemq
Updated Branches:
  refs/heads/master a9f9d4a4d -> 406a34294


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

Properly decrementing the message reference count in
DemandForwardingBridgeSupport when messages supression is checked for
durable subscriptions


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

Branch: refs/heads/master
Commit: 406a34294befca4ba2de4b728c86f64b96a94945
Parents: a9f9d4a
Author: Christopher L. Shannon (cshannon) 
Authored: Fri Oct 14 12:15:06 2016 -0400
Committer: Christopher L. Shannon (cshannon) 
Committed: Fri Oct 14 12:16:07 2016 -0400

--
 .../network/DemandForwardingBridgeSupport.java  |  3 +
 .../activemq/network/SimpleNetworkTest.java | 89 
 2 files changed, 92 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/406a3429/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
--
diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
 
b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
index 70449f0..b58259d 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java
@@ -1158,6 +1158,9 @@ public abstract class DemandForwardingBridgeSupport 
implements NetworkBridge, Br
 messageEvalContext.setMessageReference(md.getMessage());
 messageEvalContext.setDestination(md.getDestination());
 suppress = 
!sub.getNetworkBridgeFilter().matches(messageEvalContext);
+//AMQ-6465 - Need to decrement the reference count after checking 
matches() as
+//the call above will increment the reference count by 1
+messageEvalContext.getMessageReference().decrementReferenceCount();
 }
 return suppress;
 }

http://git-wip-us.apache.org/repos/asf/activemq/blob/406a3429/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
index 5d3376b..5c6b35a 100755
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java
@@ -43,9 +43,11 @@ import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.command.ActiveMQTopic;
 import org.apache.activemq.command.ConsumerId;
 import org.apache.activemq.util.Wait;
+import org.apache.activemq.util.Wait.Condition;
 import org.apache.activemq.xbean.BrokerFactoryBean;
 import org.junit.After;
 import org.junit.Before;
@@ -198,6 +200,93 @@ public class SimpleNetworkTest {
 }));
 }
 
+//Added for AMQ-6465 to make sure memory usage decreased back to 0 after 
messages are forwarded
+//to the other broker
+@Test(timeout = 60 * 1000)
+public void testDurableTopicSubForwardMemoryUsage() throws Exception {
+// create a remote durable consumer to create demand
+MessageConsumer remoteConsumer = 
remoteSession.createDurableSubscriber(included, consumerName);
+Thread.sleep(1000);
+
+MessageProducer producer = localSession.createProducer(included);
+for (int i = 0; i < MESSAGE_COUNT; i++) {
+Message test = localSession.createTextMessage("test-" + i);
+producer.send(test);
+}
+Thread.sleep(1000);
+
+//Make sure stats are set
+assertEquals(MESSAGE_COUNT,
+
localBroker.getDestination(included).getDestinationStatistics().getForwards().getCount());
+
+assertTrue(Wait.waitFor(new Condition() {
+
+@Override
+public boolean isSatisified() throws Exception {
+return 
localBroker.getSystemUsage().getMemoryUsage().getUsage() == 0;
+}
+}, 1, 500));
+remoteConsumer.close();
+}
+
+//Added for AMQ-6465 to make sure memory usage

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

2016-10-14 Thread tabish 
Repository: activemq
Updated Branches:
  refs/heads/activemq-5.14.x 70728e97d -> d126afc8f


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

Correct handling of rejected outcome to archive the message in the DLQ
(cherry picked from commit a9f9d4a4d2ede752afa74b22394b80822052543d)


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

Branch: refs/heads/activemq-5.14.x
Commit: d126afc8fe39cd4d0117790ce08bb543476bf601
Parents: 70728e9
Author: Timothy Bish 
Authored: Fri Oct 14 09:35:17 2016 -0400
Committer: Timothy Bish 
Committed: Fri Oct 14 09:36:03 2016 -0400

--
 .../activemq/transport/amqp/protocol/AmqpSender.java   |  9 +
 .../transport/amqp/interop/AmqpReceiverTest.java   | 13 +++--
 2 files changed, 8 insertions(+), 14 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/d126afc8/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
index 149b2e8..23f8597 100644
--- 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
+++ 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
@@ -270,10 +270,11 @@ public class AmqpSender extends AmqpAbstractLink {
 }
 settle(delivery, MessageAck.INDIVIDUAL_ACK_TYPE);
 } else if (state instanceof Rejected) {
-// re-deliver /w incremented delivery counter.
-md.setRedeliveryCounter(md.getRedeliveryCounter() + 1);
-LOG.trace("onDelivery: Rejected state = {}, delivery count now 
{}", state, md.getRedeliveryCounter());
-settle(delivery, -1);
+// Rejection is a terminal outcome, we poison the message for 
dispatch to
+// the DLQ.  If a custom redelivery policy is used on the 
broker the message
+// can still be redelivered based on the configation of that 
policy.
+LOG.trace("onDelivery: Rejected state = {}, message 
poisoned.", state, md.getRedeliveryCounter());
+settle(delivery, MessageAck.POSION_ACK_TYPE);
 } else if (state instanceof Released) {
 LOG.trace("onDelivery: Released state = {}", state);
 // re-deliver && don't increment the counter.

http://git-wip-us.apache.org/repos/asf/activemq/blob/d126afc8/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
--
diff --git 
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
 
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
index 2a06561..3cda78d 100644
--- 
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
+++ 
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
@@ -514,16 +514,9 @@ public class AmqpReceiverTest extends 
AmqpClientTestSupport {
 
 message.reject();
 
-// Read the message again and validate its state
-
-message = receiver.receive(10, TimeUnit.SECONDS);
-assertNotNull("did not receive message again", message);
-
-message.accept();
-
-protonMessage = message.getWrappedMessage();
-assertNotNull(protonMessage);
-assertEquals("Unexpected updated value for AMQP delivery-count", 1, 
protonMessage.getDeliveryCount());
+// Attempt to read the message again but should not get it.
+message = receiver.receive(2, TimeUnit.SECONDS);
+assertNull("shoudl not receive message again", message);
 
 connection.close();
 }

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

2016-10-14 Thread tabish 
Repository: activemq
Updated Branches:
  refs/heads/master 3e237ca73 -> a9f9d4a4d


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

Correct handling of rejected outcome to archive the message in the DLQ

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

Branch: refs/heads/master
Commit: a9f9d4a4d2ede752afa74b22394b80822052543d
Parents: 3e237ca
Author: Timothy Bish 
Authored: Fri Oct 14 09:35:17 2016 -0400
Committer: Timothy Bish 
Committed: Fri Oct 14 09:35:17 2016 -0400

--
 .../activemq/transport/amqp/protocol/AmqpSender.java   |  9 +
 .../transport/amqp/interop/AmqpReceiverTest.java   | 13 +++--
 2 files changed, 8 insertions(+), 14 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/a9f9d4a4/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
--
diff --git 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
index 149b2e8..23f8597 100644
--- 
a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
+++ 
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpSender.java
@@ -270,10 +270,11 @@ public class AmqpSender extends AmqpAbstractLink {
 }
 settle(delivery, MessageAck.INDIVIDUAL_ACK_TYPE);
 } else if (state instanceof Rejected) {
-// re-deliver /w incremented delivery counter.
-md.setRedeliveryCounter(md.getRedeliveryCounter() + 1);
-LOG.trace("onDelivery: Rejected state = {}, delivery count now 
{}", state, md.getRedeliveryCounter());
-settle(delivery, -1);
+// Rejection is a terminal outcome, we poison the message for 
dispatch to
+// the DLQ.  If a custom redelivery policy is used on the 
broker the message
+// can still be redelivered based on the configation of that 
policy.
+LOG.trace("onDelivery: Rejected state = {}, message 
poisoned.", state, md.getRedeliveryCounter());
+settle(delivery, MessageAck.POSION_ACK_TYPE);
 } else if (state instanceof Released) {
 LOG.trace("onDelivery: Released state = {}", state);
 // re-deliver && don't increment the counter.

http://git-wip-us.apache.org/repos/asf/activemq/blob/a9f9d4a4/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
--
diff --git 
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
 
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
index 2a06561..3cda78d 100644
--- 
a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
+++ 
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/interop/AmqpReceiverTest.java
@@ -514,16 +514,9 @@ public class AmqpReceiverTest extends 
AmqpClientTestSupport {
 
 message.reject();
 
-// Read the message again and validate its state
-
-message = receiver.receive(10, TimeUnit.SECONDS);
-assertNotNull("did not receive message again", message);
-
-message.accept();
-
-protonMessage = message.getWrappedMessage();
-assertNotNull(protonMessage);
-assertEquals("Unexpected updated value for AMQP delivery-count", 1, 
protonMessage.getDeliveryCount());
+// Attempt to read the message again but should not get it.
+message = receiver.receive(2, TimeUnit.SECONDS);
+assertNull("shoudl not receive message again", message);
 
 connection.close();
 }

Jenkins build is unstable: ActiveMQ-Java7-All-UnitTests #551

2016-10-14 Thread Apache Jenkins Server 
See

Jenkins build became unstable: ActiveMQ-Artemis-Master #701

2016-10-14 Thread Apache Jenkins Server 
See

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

2016-10-14 Thread martyntaylor 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 6052f7a25 -> e53aaf398


This closes #841


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

Branch: refs/heads/master
Commit: e53aaf398e81be4dd02bd6addfdf04780baf2a2b
Parents: 6052f7a f1728ab
Author: Martyn Taylor 
Authored: Fri Oct 14 10:24:13 2016 +0100
Committer: Martyn Taylor 
Committed: Fri Oct 14 10:24:13 2016 +0100

--
 .../amqp/AmqpTempDestinationTest.java   | 329 +++
 1 file changed, 329 insertions(+)
--

[2/2] activemq-artemis git commit: ARTEMIS-795 Tests for temporary destinations using dynamic nodes

2016-10-14 Thread martyntaylor 
ARTEMIS-795 Tests for temporary destinations using dynamic nodes

Tests for the management of temporary destinations using the dynamic
node feature.  Failing case, the broker return a source or target that
indicates it will honor the lifetime policy of delete on close but the
temporary destination remains in existence after the link it closed.

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

Branch: refs/heads/master
Commit: f1728abb5f04bef29f464011060c4ff95f24
Parents: 6052f7a
Author: Timothy Bish 
Authored: Tue Oct 11 18:51:07 2016 -0400
Committer: Martyn Taylor 
Committed: Fri Oct 14 10:24:13 2016 +0100

--
 .../amqp/AmqpTempDestinationTest.java   | 329 +++
 1 file changed, 329 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/f1728abb/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpTempDestinationTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpTempDestinationTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpTempDestinationTest.java
new file mode 100644
index 000..4dbe21e
--- /dev/null
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpTempDestinationTest.java
@@ -0,0 +1,329 @@
+/*
+ * 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.tests.integration.amqp;
+
+import static org.apache.activemq.transport.amqp.AmqpSupport.LIFETIME_POLICY;
+import static 
org.apache.activemq.transport.amqp.AmqpSupport.TEMP_QUEUE_CAPABILITY;
+import static 
org.apache.activemq.transport.amqp.AmqpSupport.TEMP_TOPIC_CAPABILITY;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.activemq.artemis.core.server.Queue;
+import org.apache.activemq.transport.amqp.client.AmqpClient;
+import org.apache.activemq.transport.amqp.client.AmqpConnection;
+import org.apache.activemq.transport.amqp.client.AmqpMessage;
+import org.apache.activemq.transport.amqp.client.AmqpReceiver;
+import org.apache.activemq.transport.amqp.client.AmqpSender;
+import org.apache.activemq.transport.amqp.client.AmqpSession;
+import org.apache.qpid.proton.amqp.Symbol;
+import org.apache.qpid.proton.amqp.messaging.DeleteOnClose;
+import org.apache.qpid.proton.amqp.messaging.Source;
+import org.apache.qpid.proton.amqp.messaging.Target;
+import org.apache.qpid.proton.amqp.messaging.TerminusDurability;
+import org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy;
+import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Tests for temporary destination handling over AMQP
+ */
+public class AmqpTempDestinationTest extends AmqpClientTestSupport {
+
+   protected static final Logger LOG = 
LoggerFactory.getLogger(AmqpTempDestinationTest.class);
+
+   @Test(timeout = 6)
+   public void testCreateDynamicSenderToTopic() throws Exception {
+  doTestCreateDynamicSender(true);
+   }
+
+   @Test(timeout = 6)
+   public void testCreateDynamicSenderToQueue() throws Exception {
+  doTestCreateDynamicSender(false);
+   }
+
+   @SuppressWarnings("unchecked")
+   protected void doTestCreateDynamicSender(boolean topic) throws Exception {
+  Target target = createDynamicTarget(topic);
+
+  AmqpClient client = createAmqpClient();
+  AmqpConnection connection = addConnection(client.connect());
+  AmqpSession session = connection.createSession();
+
+  AmqpSender sender = session.createSender(target);
+  assertNotNull(sender);
+
+  Target remoteTarget = (Target)

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

2016-10-14 Thread martyntaylor 
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 7d03bcf43 -> 6052f7a25


This closes #843


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

Branch: refs/heads/master
Commit: 6052f7a25deb599df0f934fe8a7de30034496093
Parents: 7d03bcf 6a9e4c0
Author: Martyn Taylor 
Authored: Fri Oct 14 10:23:22 2016 +0100
Committer: Martyn Taylor 
Committed: Fri Oct 14 10:23:22 2016 +0100

--
 examples/protocols/mqtt/basic-pubsub/readme.html| 16 ++--
 .../mqtt/example/MQTTBasicPubSubExample.java|  8 ++--
 2 files changed, 16 insertions(+), 8 deletions(-)
--

[2/2] activemq-artemis git commit: Example showing how to use + in topics

2016-10-14 Thread martyntaylor 
Example showing how to use + in topics


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

Branch: refs/heads/master
Commit: 6a9e4c05e8a99f472f175f1e2f1e4c8072e968d0
Parents: 7d03bcf
Author: Antoine Toulme 
Authored: Wed Oct 12 18:36:29 2016 -0700
Committer: Martyn Taylor 
Committed: Fri Oct 14 10:23:22 2016 +0100

--
 examples/protocols/mqtt/basic-pubsub/readme.html| 16 ++--
 .../mqtt/example/MQTTBasicPubSubExample.java|  8 ++--
 2 files changed, 16 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6a9e4c05/examples/protocols/mqtt/basic-pubsub/readme.html
--
diff --git a/examples/protocols/mqtt/basic-pubsub/readme.html 
b/examples/protocols/mqtt/basic-pubsub/readme.html
index d9abc9a..ca7dbff 100644
--- a/examples/protocols/mqtt/basic-pubsub/readme.html
+++ b/examples/protocols/mqtt/basic-pubsub/readme.html
@@ -87,26 +87,28 @@ under the License.
 
  Subscriptions in MQTT are realised by subscribing to a particular 
Topic.  Each Topic has an address
  and a quality of service level (QoS level).  Subscriptions also 
support wildcards.  In the code below we
- subscribe to a Topic with address "mqtt/example/publish" and also a 
wildcard address "mqtt/#" which will
- match anything starting with "mqtt/".
+ subscribe to a Topic with address "mqtt/example/publish", a wildcard 
address "test/#" which will
+ match anything starting with "test/" and also a wildcard "foo/+/bar", 
where + matches a single level of the hierarchy (foo/something/bar)
 
  
- Topic[] topics = { new Topic("mqtt/example/publish", 
QoS.AT_LEAST_ONCE), new Topic("mqtt/#", QoS.EXACTLY_ONCE) };
+ Topic[] topics = { new Topic("mqtt/example/publish", 
QoS.AT_LEAST_ONCE), new Topic("test/#", QoS.EXACTLY_ONCE), new 
Topic("foo/+/bar", QoS.AT_LEAST_ONCE) };
  connection.subscribe(topics);
  
 
  3. Sending messages
 
- There is no type system in MQTT, messages simply consist of a 
number of bytes.  Below we send two messages with
- UTF8 encoded strings (as a byte array).  Notice the second message is 
sent to "mqtt/test" which should match
- our wildcard subscription we defined previously.
+ There is no type system in MQTT, messages simply consist of a 
number of bytes.  Below we send three messages with
+ UTF8 encoded strings (as a byte array).  Notice the second message is 
sent to "test/test" which should match
+ the first wildcard subscription we defined previously. The third 
message is sent to "foo/1/bar", which matches the second wildcard 
subscription.
 
  
  String payload1 = "This is message 1";
  String payload2 = "This is message 2";
+ String payload3 = "This is message 3";
 
  connection.publish("mqtt/example/publish", payload1.getBytes(), 
QoS.AT_LEAST_ONCE, false);
  connection.publish("mqtt/test", payload2.getBytes(), 
QoS.AT_MOST_ONCE, false);
+ connection.publish("foo/1/bar", payload3.getBytes(), 
QoS.AT_MOST_ONCE, false);
  
 
  4. Receiving messages
@@ -119,9 +121,11 @@ under the License.
  
  Message message1 = connection.receive(5, TimeUnit.SECONDS);
  Message message2 = connection.receive(5, TimeUnit.SECONDS);
+ Message message3 = connection.receive(5, TimeUnit.SECONDS);
 
  System.out.println(new String(message1.getPayload()));
  System.out.println(new String(message2.getPayload()));
+ System.out.println(new String(message3.getPayload()));
  
  
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6a9e4c05/examples/protocols/mqtt/basic-pubsub/src/main/java/org/apache/activemq/artemis/mqtt/example/MQTTBasicPubSubExample.java
--
diff --git 
a/examples/protocols/mqtt/basic-pubsub/src/main/java/org/apache/activemq/artemis/mqtt/example/MQTTBasicPubSubExample.java
 
b/examples/protocols/mqtt/basic-pubsub/src/main/java/org/apache/activemq/artemis/mqtt/example/MQTTBasicPubSubExample.java
index 93fb946..dd64731 100644
--- 
a/examples/protocols/mqtt/basic-pubsub/src/main/java/org/apache/activemq/artemis/mqtt/example/MQTTBasicPubSubExample.java
+++