Jenkins build is still unstable: ActiveMQ » ActiveMQ-5-5-16x-JDK8 #102

2020-11-02 Thread Apache Jenkins Server 
See

Jenkins build is back to normal : ActiveMQ » ActiveMQ-Artemis-Master-JDK8 #109

2020-11-02 Thread Apache Jenkins Server 
See

[activemq-artemis] branch master updated: NO-JIRA update on RELEASING.md

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
 new 9896b99  NO-JIRA update on RELEASING.md
9896b99 is described below

commit 9896b994b10d73becece431aa60271bc08465feb
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 20:27:32 2020 -0500

NO-JIRA update on RELEASING.md
---
 RELEASING.md | 11 ---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/RELEASING.md b/RELEASING.md
index a24bac7..3f95dbb 100644
--- a/RELEASING.md
+++ b/RELEASING.md
@@ -178,15 +178,20 @@ Old staged releases can be cleaned out periodically.
 
 Please, include the git-commit-report as part of the release process. To 
generate it, follow these steps:
 
-- Download 
[git-release-report](https://github.com/clebertsuconic/git-release-report/releases)
+- Download [jira-git-report](https://github.com/rh-messaging/jira-git-report)
 - Execute the following command:
 ```bash
-$ java -jar git-release-report.jar /activemq-artemis 
/artemis-website commit-report-.html 
  true
+$ git clone https://github.com/rh-messaging/jira-git-report.git
+$ cd jira-git-report
+$ mvn compile assembly:single
+$ cd target
+$ java -jar jira-git-0.1.SNAPSHOT-jar-with-dependencies.jar artemis 
/activemq-artemis /artemis-website 
commit-report-.html   true
 ```
 
 real example used on 
[2.6.1](http://activemq.apache.org/artemis/commit-report-2.6.1.html):
 ```bash
-$ java -jar git-release-report.jar /work/apache-checkout/activemq-artemis 
commit-report-2.6.1.html 2.6.0 2.6.1 true
+$ java -jar 
+java -jar jira-git-0.1.SNAPSHOT-jar-with-dependencies.jar artemis 
release-work/activemq-artemis 
release-work/activemq-website/src/components/artemis/download/commit-report-2.16.0.html
 2.15.0 2.16.0 true
 ```
 - This will parse all the git commits between the previous release, and 
current release tags while looking at current JIRA status.

Buildbot success in on jekyll_websites

2020-11-02 Thread buildbot 
The Buildbot has detected a passing build on builder jekyll_websites while 
building activemq.
Full details are available at:
https://ci2.apache.org/#builders/7/builds/255

Buildbot URL: https://ci2.apache.org/

Worker for this Build: bb_slave10_ubuntu

Build Reason: Triggered jekyll auto-build via .asf.yaml by clebertsuconic
Blamelist: asfinfra, commits@activemq.apache.org

Build succeeded!

Sincerely,
 -The Buildbot

[activemq-website] branch master updated (68b440b -> 5fdd8c0)

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-website.git.


from 68b440b  Publish CVE-2020-11998
 new 645a48e  update 2.15.0 commit report
 new 5fdd8c0  commit report 2.16.0

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../artemis/download/commit-report-2.15.0.html | 112 +++---
 .../artemis/download/commit-report-2.16.0.html | 387 +
 2 files changed, 443 insertions(+), 56 deletions(-)
 create mode 100644 src/components/artemis/download/commit-report-2.16.0.html

[activemq-website] 01/02: update 2.15.0 commit report

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-website.git

commit 645a48ea4a36a204894230bcd0673f163862ec96
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 20:21:19 2020 -0500

update 2.15.0 commit report
---
 .../artemis/download/commit-report-2.15.0.html | 112 ++---
 1 file changed, 56 insertions(+), 56 deletions(-)

diff --git a/src/components/artemis/download/commit-report-2.15.0.html 
b/src/components/artemis/download/commit-report-2.15.0.html
index fd19305..989b81f 100644
--- a/src/components/artemis/download/commit-report-2.15.0.html
+++ b/src/components/artemis/download/commit-report-2.15.0.html
@@ -27,163 +27,163 @@
 Release report 2.14.0(a76f41a7edd5e6fff948da43c86631a6367e78d2) and 
2.15.0(a549fcedde9d1f465ee92b99440b84436574a228)
 
 
-#CommitDateAuthorShort 
MessageJira 
StatusAddRepDelTottestdocs/examples/
+#CommitDateAuthorShort 
MessageARTEMIS 
JIRAsAddRepDelTottestdocs/examples/
 
 1
-6690ba1
 2020/07/09 18:49:08Clebert 
Suconic[maven-release-plugin] prepare for next development 
iteration
+6690ba12020/07/09
 12:49:08Clebert Suconic[maven-release-plugin] prepare for 
next development iteration
 
 2
-7be7716
 2020/07/09 19:57:20Clebert SuconicNO-JIRA POM on 
extra-tests to 2.15.0-SNAPSHOT
+7be77162020/07/09
 13:57:20Clebert SuconicNO-JIRA POM on extra-tests to 
2.15.0-SNAPSHOT
 
 3
-ccc0fa7
 2020/07/10 18:12:09Clebert SuconicARTEMIS-2843 
non-destructive LVQ not delivering msg to consumerMajor/Bug/Fixed/Resolved
+ccc0fa72020/07/10
 12:12:09Clebert SuconicARTEMIS-2843 
non-destructive LVQ not delivering msg to consumerMajor/Bug/Fixed/Resolved
 (ARTEMIS-2843)
 392041LVQTest.java(+)
 [...]
 4
-e3ed8e8
 2020/07/16 08:56:53Scott WernerARTEMIS-2847 
socks5h supportMinor/New 
Feature/Done/Closed
+e3ed8e82020/07/16
 02:56:53Scott WernerARTEMIS-2847 
socks5h supportMinor/New 
Feature/Done/Closed (ARTEMIS-2847)
 147021NettyConnectorTest.javahttps://github.com/apache/activemq-artemis/commit/e629524b538c4dd93fce9a348e8e140adaf4a59c'>5
-e629524
 2020/07/23 12:44:27gtullyno jira - fix reference to 
the website svn repo
-
+e6295242020/07/23
 06:44:27gtullyno jira - fix reference to the website svn 
repo
+0303
 6
-90273e6
 2020/07/23 15:17:33gtullyno jira - give some love 
to the migration guide
+90273e62020/07/23
 09:17:33gtullyno jira - give some love to the migration 
guide
 README.md(+)
 S
 [...]
 7
-c152f17
 2020/07/23 15:42:50gtullyno jira - exclude .p12 
files from rat check
+c152f172020/07/23
 09:42:50gtullyno jira - exclude .p12 files from rat 
check
 
 8
-7902dd1
 2020/07/17 11:56:15franz1981ARTEMIS-2849 
Optimize zeroing of buffers while writing the ASYNCIO journalMajor/Test/Done/Closed
+7902dd12020/07/17
 05:56:15franz1981ARTEMIS-2849 
Optimize zeroing of buffers while writing the ASYNCIO journalMajor/Test/Done/Closed
 (ARTEMIS-2849)
 34192231
 9
-52d3ed1
 2020/07/16 22:02:23Justin BertramARTEMIS-2848 RA 
fails w/durable sub w/legacy prefixMajor/Bug/Done/Closed
+52d3ed12020/07/16
 16:02:23Justin BertramARTEMIS-2848 RA 
fails w/durable sub w/legacy prefixMajor/Bug/Done/Closed 
(ARTEMIS-2848)
 1203ActiveMQMessageHandlerTest.javahttps://github.com/apache/activemq-artemis/commit/f2d0d300f5d317bd1c41c6efe92b8834c8111b66'>10
-f2d0d30
 2020/07/24 13:04:12franz1981ARTEMIS-2853 
page-max-concurrent-io cannot be disabledMajor/Bug/Done/Closed
+f2d0d302020/07/24
 07:04:12franz1981ARTEMIS-2853 
page-max-concurrent-io cannot be disabledMajor/Bug/Done/Closed 
(ARTEMIS-2853)
 0202JournalStorageManagerTest.javahttps://github.com/apache/activemq-artemis/commit/41efeb26697fa65d9175ca0e71b9d67118017e7d'>11
-41efeb2
 2020/07/14 19:05:47Francesco NigroARTEMIS-2845 
ConcurrentAppendOnlyChunkedList cannot be queried while resizingMajor/Improvement/Done/Closed
+41efeb22020/07/14
 13:05:47Francesco NigroARTEMIS-2845 
ConcurrentAppendOnlyChunkedList cannot be queried while resizingMajor/Improvement/Done/Closed
 (ARTEMIS-2845)
 621423
 12
-3ce9e2e
 2020/07/24 17:01:12brusdevARTEMIS-2846 
Cannot define hawtio.role with whitespaceMajor/Bug/Done/Closed
+3ce9e2e2020/07/24
 11:01:12brusdevARTEMIS-2846 
Cannot define hawtio.role with whitespaceMajor/Bug/Done/Closed 
(ARTEMIS-2846)
 1001ArtemisTest.java(+)
 https://github.com/apache/activemq-artemis/commit/cd7f52d4ba12a03cbac9f4f2d7a34c5cfe023eba'>13
-cd7f52d
 2020/07/28 23:15:22Justin BertramARTEMIS-2856 
consumer can be created on closed sessionMajor/Bug/Fixed/Resolved
+cd7f52d2020/07/28
 17:15:22Justin BertramARTEMIS-2856 
consumer can be created on closed sessionMajor/Bug/Fixed/Resolved
 (ARTEMIS-2856)
 48111
 14
-18b8df0
 2020/07/28 14:57:31brusdevARTEMIS-2855 
Define a new broker plugin to track XA transactionsMajor/New 
Feature/Done/Closed
+18b8df02020/07/28
 08:57:31brusdevARTEMIS-2855 
Define a new broker plugin to track XA transactionsMajor/New 
Feature/Done/Closed (ARTEMIS-2855)

[activemq-website] 02/02: commit report 2.16.0

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-website.git

commit 5fdd8c06376454ed88bb416a92aa302e0bc44ac7
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 20:21:31 2020 -0500

commit report 2.16.0
---
 .../artemis/download/commit-report-2.16.0.html | 387 +
 1 file changed, 387 insertions(+)

diff --git a/src/components/artemis/download/commit-report-2.16.0.html 
b/src/components/artemis/download/commit-report-2.16.0.html
new file mode 100644
index 000..6290097
--- /dev/null
+++ b/src/components/artemis/download/commit-report-2.16.0.html
@@ -0,0 +1,387 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+   
+
+$(document).ready( function () {
+$("#gitreport").DataTable();
+} );
+   
+
+
+
+
+
+Release report 2.15.0(a549fcedde9d1f465ee92b99440b84436574a228) and 
2.16.0(9768017530fdbbefd7c112b55702b5a16b3f058e)
+
+
+#CommitDateAuthorShort 
MessageARTEMIS 
JIRAsAddRepDelTottestdocs/examples/
+
+1
+32bf9682020/08/24
 10:03:24Domenico Francesco Bruscino[maven-release-plugin] 
prepare for next development iteration
+
+2
+b85156c2020/08/24
 10:24:25Domenico Francesco BruscinoNO-JIRA POM on 
extra-tests to 2.16.0-SNAPSHOT
+
+3
+90853402020/08/24
 10:24:25Justin BertramARTEMIS-2886 
optimize security authMajor/Improvement/Fixed/Closed
 (ARTEMIS-2886)
+2309414310ArtemisTest.java(+)
 https://github.com/apache/activemq-artemis/commit/4d45d0cdd2cf10ed35982b768f4bcf19c4aab35b'>4
+4d45d0c2020/08/26
 17:41:16Clebert SuconicARTEMIS-2887 
Adding toString back to AMQPMessageMajor/Improvement/Fixed/Closed
 (ARTEMIS-2887)
+0303
+5
+c3887ed2020/08/26
 17:41:42Clebert SuconicARTEMIS-2887 
Adding back Message.toString on audit loggerMajor/Improvement/Fixed/Closed
 (ARTEMIS-2887)
+0505AuditLoggerTest.java(+)
 6
+729f86e2020/09/01
 08:10:13Domenico Francesco BruscinoNO-JIRA Update the 
releasing document
+1555169
+7
+d934dc62020/09/01
 10:30:42Robbie GemmellNO-JIRA: enable full build output for 
GitHub Actions jobs, split main and example builds to simplift viewing 
output
+
+8
+50874712020/09/01
 17:44:42Luis De BelloARTEMIS-2696 
Releasing ByteBuf after reading content on WebSocketMajor/Bug/Fixed/Closed
 (ARTEMIS-2696)
+2002WebSocketFrameEncoderTest.javahttps://github.com/apache/activemq-artemis/commit/f5a6189e2dcc24b59cd1fc287d0d4cbc65c20efb'>9
+f5a61892020/08/28
 23:24:47Justin BertramARTEMIS-2890 FQQN 
security-settings + JMS not workingMajor/Bug/Fixed/Closed
 (ARTEMIS-2890)
+315018SecurityTest.javahttps://github.com/apache/activemq-artemis/commit/ec1c5a96c74b24f2c9a6f0919a1a180721c5c6b9'>10
+ec1c5a92020/09/07
 11:32:57gtullyARTEMIS-2895 - 
ensure propagated credentials are visible for bind and removed for subsequent 
mapping operationsMajor/Bug/Fixed/Closed
 (ARTEMIS-2895)
+2002LDAPLoginModuleTest.java(+)
 [...]
+11
+1783aa12020/09/04
 03:53:56Stefan KrutzlerARTEMIS-2875 - 
retry to reattach sessions on failed failover for the specified amount of times 
set in reconnectAttempts parameterCritical/Bug/Fixed/Closed
 (ARTEMIS-2875)
+218020ReconnectTest.javahttps://github.com/apache/activemq-artemis/commit/cf92c163394069fdbcd48055920866a22103a29c'>12
+cf92c162020/09/03
 22:29:25Justin BertramARTEMIS-2886 put 
address/FQQN into new security manager interfaceMajor/Improvement/Fixed/Closed
 (ARTEMIS-2886)
+1506JAASSecurityManagerTest.javahttps://github.com/apache/activemq-artemis/commit/7cf5289efa011493a3a69a96d1293609204018d6'>13
+7cf52892020/09/14
 10:07:56Clebert SuconicARTEMIS-2900 
Expose property (getWholeMessageSize) so users can intercept size of messages 
and large messagesMajor/Improvement/Fixed/Closed
 (ARTEMIS-2900)
+430043AMQPLargeMessageSizeTest.javahttps://github.com/apache/activemq-artemis/commit/604b7c2aa6960edf0fe5b3448aa97c6ce78c0b30'>14
+604b7c22020/09/14
 11:28:31Clebert SuconicNO-JIRA fixing CheckTest with a Wait 
assertion
+CheckTest.java(+)
 
+15
+27c73852020/09/15
 08:12:57Clebert SuconicNO-JIRA using correct queue on 
RefOperation::rollback and remove TODO
+0110
+16
+c0c638d2020/09/15
 08:56:07Clebert SuconicNO-JIRA Fixing intermittent failure 
on a REST test
+Wait.java(+)
 https://github.com/apache/activemq-artemis/commit/c29a8cda5c89b0ee6f9c320810f639581a781db4'>17
+c29a8cd2020/09/15
 07:01:23Andy TaylorARTEMIS-2902 - 
expose at queue control messages held in a prepared txMajor/Bug/Fixed/Closed
 (ARTEMIS-2902)
+610061QueueControlTest.javahttps://github.com/apache/activemq-artemis/commit/3e557f107092de14e7cac2e4ac0828d54b72fd7d'>18
+3e557f12020/09/16
 09:56:41Clebert SuconicARTEMIS-2902 
Fixing QueueControlUsingCoreTest Class Cast Exception on Long to 
IntegerMajor/Bug/Fixed/Closed
 (ARTEMIS-2902)
+QueueControlUsingCoreTest.javahttps://github.com/apache/activemq-artemis/commit/fe5b81fd5564bcc1a6c621cee776285297247964'>19
+fe5b81f2020/08/03
 07:47:12Howard GaoARTEMIS-2854 
Non-durable subscribers

svn commit: r42245 - /dev/activemq/activemq-artemis/2.16.0/

2020-11-02 Thread clebertsuconic 
Author: clebertsuconic
Date: Tue Nov  3 01:02:16 2020
New Revision: 42245

Log:
2.16.0 release

Added:
dev/activemq/activemq-artemis/2.16.0/
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz   
(with props)
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.asc
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.sha512
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip   (with 
props)
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.asc
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.sha512

dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.tar.gz
   (with props)

dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.tar.gz.asc

dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.tar.gz.sha512

dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.zip   
(with props)

dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.zip.asc

dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.zip.sha512

Added: dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz
==
Binary file - no diff available.

Propchange: 
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz
--
svn:mime-type = application/octet-stream

Added: dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.asc
==
--- dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.asc 
(added)
+++ dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.asc 
Tue Nov  3 01:02:16 2020
@@ -0,0 +1,12 @@
+-BEGIN PGP SIGNATURE-
+Comment: GPGTools - https://gpgtools.org
+
+iQEzBAABCgAdFiEEKEF8leiQbRCDkoIjVKQ/MlSGhBAFAl+gnIEACgkQVKQ/MlSG
+hBBJ6wf/WR4qwxJkptpPNgDF+Wh3TC+DwW0gUFjsmQncW6hsrPmPXuDo7Yjz2+Mm
+sUCq1LoCcK/MjxQebGRhgFrmnmgwwEu1ZmjUFjm5IkSWFn8vo2z22/JtNHF03tMl
+qpPJJnq8BrFHkzNSkOMk+oLGbXpJ6tPxV3I5cB2B/QVeMDA5uAIhmPTmiOso6qGu
+xFbhRViCwv8QHV9SobrJY2QFRp5EF1heXLtITT9hnxbDzmP6EKqz/S7bGThn99pW
+sUusgEbxJ63Kl3oPhF9peG6wmgNiOyzAjnZ/qhcZTa7gZHr6B33FGGkAN9idw/Vr
+NyMjADl9I39ZMWHqdzfuLKOkFsoY8Q==
+=lcED
+-END PGP SIGNATURE-

Added: 
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.sha512
==
--- 
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.sha512 
(added)
+++ 
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.tar.gz.sha512 
Tue Nov  3 01:02:16 2020
@@ -0,0 +1 @@
+4990a6b742b08bff6a4c7b310d2610565b08a2a02e1a7aec065460d16f8a6fe3d4fe91a8040839f93d7c2eab09fd6a79848fb130f9820559ee3e81dcf8d51ead
  apache-artemis-2.16.0-bin.tar.gz

Added: dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip
==
Binary file - no diff available.

Propchange: dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip
--
svn:mime-type = application/octet-stream

Added: dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.asc
==
--- dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.asc 
(added)
+++ dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.asc Tue 
Nov  3 01:02:16 2020
@@ -0,0 +1,12 @@
+-BEGIN PGP SIGNATURE-
+Comment: GPGTools - https://gpgtools.org
+
+iQEzBAABCgAdFiEEKEF8leiQbRCDkoIjVKQ/MlSGhBAFAl+gnIEACgkQVKQ/MlSG
+hBD9uAf+IzDZFm6ZWlX/+lx8stQvxpq+HMaoiVumewiUDLgs6wP9Phmy5kcEme5p
+57n3teP+Mdy8JHXd68gmYbT65zUn918iQcRJBoKd6tDuJmA2OBLlRpcF1Pa3FZ8b
+ty4FcmpTDMLwOP6YVeJu3fGGOhvpQi8iiGLxA1NP9CGlQhxqEx7RqQXrznwiVPpl
+KM5u3pfGU/FzL0Z5IXjeGIxCBOAoXCUBHu3M+T7Vbfz9+a4TuIhqWr4f5cqAHQZl
+zdodpO9QRWsrWI/LUXuXbBVtIaG+iT/cCc7pLPyo/BKFvhFwkyIzcabNPxiDgSwK
+Z1wCGm2OvwL0DrqhkpRiD9HL53X8WQ==
+=tpXo
+-END PGP SIGNATURE-

Added: dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.sha512
==
--- dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.sha512 
(added)
+++ dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-bin.zip.sha512 
Tue Nov  3 01:02:16 2020
@@ -0,0 +1 @@
+5dd07773f0fdd885cacbcd6a3b805b598ae532b8d8aeb7952ca563a363639cae94266de89e096f58f61832a10aa509a8a9855b76367d58fb72d5c36dad2b06f9
  apache-artemis-2.16.0-bin.zip

Added: 
dev/activemq/activemq-artemis/2.16.0/apache-artemis-2.16.0-source-release.tar.gz

[activemq-artemis] annotated tag 2.16.0 created (now 8879d6b)

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a change to annotated tag 2.16.0
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.


  at 8879d6b  (tag)
 tagging 9768017530fdbbefd7c112b55702b5a16b3f058e (commit)
 replaces 2.15.0
  by Clebert Suconic
  on Mon Nov 2 17:45:49 2020 -0500

- Log -
[maven-release-plugin] copy for tag 2.16.0
---

No new revisions were added by this update.

[activemq-artemis] 01/02: [maven-release-plugin] prepare release 2.16.0

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit 9768017530fdbbefd7c112b55702b5a16b3f058e
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 17:45:38 2020 -0500

[maven-release-plugin] prepare release 2.16.0
---
 artemis-boot/pom.xml  | 2 +-
 artemis-cdi-client/pom.xml| 2 +-
 artemis-cli/pom.xml   | 2 +-
 artemis-commons/pom.xml   | 2 +-
 artemis-core-client-all/pom.xml   | 2 +-
 artemis-core-client-osgi/pom.xml  | 2 +-
 artemis-core-client/pom.xml   | 2 +-
 artemis-distribution/pom.xml  | 2 +-
 artemis-dto/pom.xml   | 2 +-
 artemis-features/pom.xml  | 2 +-
 artemis-hawtio/activemq-branding/pom.xml  | 2 +-
 artemis-hawtio/artemis-console/pom.xml| 2 +-
 artemis-hawtio/artemis-plugin/pom.xml | 2 +-
 artemis-hawtio/pom.xml| 2 +-
 artemis-jdbc-store/pom.xml| 2 +-
 artemis-jms-client-all/pom.xml| 2 +-
 artemis-jms-client-osgi/pom.xml   | 2 +-
 artemis-jms-client/pom.xml| 2 +-
 artemis-jms-server/pom.xml| 2 +-
 artemis-journal/pom.xml   | 2 +-
 artemis-junit/pom.xml | 2 +-
 artemis-maven-plugin/pom.xml  | 2 +-
 artemis-protocols/artemis-amqp-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-hornetq-protocol/pom.xml| 2 +-
 artemis-protocols/artemis-hqclient-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-mqtt-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-openwire-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-stomp-protocol/pom.xml  | 2 +-
 artemis-protocols/pom.xml | 2 +-
 artemis-ra/pom.xml| 2 +-
 artemis-rest/pom.xml  | 2 +-
 artemis-selector/pom.xml  | 2 +-
 artemis-server-osgi/pom.xml   | 2 +-
 artemis-server/pom.xml| 2 +-
 artemis-service-extensions/pom.xml| 2 +-
 artemis-tools/pom.xml | 2 +-
 artemis-web/pom.xml   | 2 +-
 artemis-website/pom.xml   | 2 +-
 examples/features/broker-connection/amqp-receiving-messages/pom.xml   | 2 +-
 examples/features/broker-connection/amqp-sending-messages/pom.xml | 2 +-
 examples/features/broker-connection/amqp-sending-overssl/pom.xml  | 2 +-
 examples/features/broker-connection/pom.xml   | 2 +-
 examples/features/clustered/client-side-load-balancing/pom.xml| 2 +-
 examples/features/clustered/clustered-durable-subscription/pom.xml| 2 +-
 examples/features/clustered/clustered-grouping/pom.xml| 2 +-
 examples/features/clustered/clustered-jgroups/pom.xml | 2 +-
 examples/features/clustered/clustered-queue/pom.xml   | 2 +-
 examples/features/clustered/clustered-static-discovery-uri/pom.xml| 2 +-
 examples/features/clustered/clustered-static-discovery/pom.xml| 2 +-
 examples/features/clustered/clustered-static-oneway/pom.xml   | 2 +-
 examples/features/clustered/clustered-topic-uri/pom.xml   | 2 +-
 examples/features/clustered/clustered-topic/pom.xml   | 2 +-
 examples/features/clustered/pom.xml   | 2 +-
 examples/features/clustered/queue-message-redistribution/pom.xml  | 2 +-
 examples/features/clustered/shared-storage-static-cluster/pom.xml | 2 +-
 examples/features/clustered/symmetric-cluster/pom.xml | 2 +-
 examples/features/federation/federated-address-divert/pom.xml | 2 +-
 .../features/federation/federated-address-downstream-upstream/pom.xml | 2 +-
 examples/features/federation/federated-address-downstream/pom.xml | 2 +-

[activemq-artemis] branch master updated (648340a -> 4e7bb97)

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.


from 648340a  ARTEMIS-2969 / ARTEMIS-2937 Making sure consumers are cleaned 
after failures and reconnects
 new 9768017  [maven-release-plugin] prepare release 2.16.0
 new 4e7bb97  [maven-release-plugin] prepare for next development iteration

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:

[activemq-artemis] 02/02: [maven-release-plugin] prepare for next development iteration

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit 4e7bb97df7083f1444f149184e17ef434e59bbee
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 17:45:51 2020 -0500

[maven-release-plugin] prepare for next development iteration
---
 artemis-boot/pom.xml  | 2 +-
 artemis-cdi-client/pom.xml| 2 +-
 artemis-cli/pom.xml   | 2 +-
 artemis-commons/pom.xml   | 2 +-
 artemis-core-client-all/pom.xml   | 2 +-
 artemis-core-client-osgi/pom.xml  | 2 +-
 artemis-core-client/pom.xml   | 2 +-
 artemis-distribution/pom.xml  | 2 +-
 artemis-dto/pom.xml   | 2 +-
 artemis-features/pom.xml  | 2 +-
 artemis-hawtio/activemq-branding/pom.xml  | 2 +-
 artemis-hawtio/artemis-console/pom.xml| 2 +-
 artemis-hawtio/artemis-plugin/pom.xml | 2 +-
 artemis-hawtio/pom.xml| 2 +-
 artemis-jdbc-store/pom.xml| 2 +-
 artemis-jms-client-all/pom.xml| 2 +-
 artemis-jms-client-osgi/pom.xml   | 2 +-
 artemis-jms-client/pom.xml| 2 +-
 artemis-jms-server/pom.xml| 2 +-
 artemis-journal/pom.xml   | 2 +-
 artemis-junit/pom.xml | 2 +-
 artemis-maven-plugin/pom.xml  | 2 +-
 artemis-protocols/artemis-amqp-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-hornetq-protocol/pom.xml| 2 +-
 artemis-protocols/artemis-hqclient-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-mqtt-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-openwire-protocol/pom.xml   | 2 +-
 artemis-protocols/artemis-stomp-protocol/pom.xml  | 2 +-
 artemis-protocols/pom.xml | 2 +-
 artemis-ra/pom.xml| 2 +-
 artemis-rest/pom.xml  | 2 +-
 artemis-selector/pom.xml  | 2 +-
 artemis-server-osgi/pom.xml   | 2 +-
 artemis-server/pom.xml| 2 +-
 artemis-service-extensions/pom.xml| 2 +-
 artemis-tools/pom.xml | 2 +-
 artemis-web/pom.xml   | 2 +-
 artemis-website/pom.xml   | 2 +-
 examples/features/broker-connection/amqp-receiving-messages/pom.xml   | 2 +-
 examples/features/broker-connection/amqp-sending-messages/pom.xml | 2 +-
 examples/features/broker-connection/amqp-sending-overssl/pom.xml  | 2 +-
 examples/features/broker-connection/pom.xml   | 2 +-
 examples/features/clustered/client-side-load-balancing/pom.xml| 2 +-
 examples/features/clustered/clustered-durable-subscription/pom.xml| 2 +-
 examples/features/clustered/clustered-grouping/pom.xml| 2 +-
 examples/features/clustered/clustered-jgroups/pom.xml | 2 +-
 examples/features/clustered/clustered-queue/pom.xml   | 2 +-
 examples/features/clustered/clustered-static-discovery-uri/pom.xml| 2 +-
 examples/features/clustered/clustered-static-discovery/pom.xml| 2 +-
 examples/features/clustered/clustered-static-oneway/pom.xml   | 2 +-
 examples/features/clustered/clustered-topic-uri/pom.xml   | 2 +-
 examples/features/clustered/clustered-topic/pom.xml   | 2 +-
 examples/features/clustered/pom.xml   | 2 +-
 examples/features/clustered/queue-message-redistribution/pom.xml  | 2 +-
 examples/features/clustered/shared-storage-static-cluster/pom.xml | 2 +-
 examples/features/clustered/symmetric-cluster/pom.xml | 2 +-
 examples/features/federation/federated-address-divert/pom.xml | 2 +-
 .../features/federation/federated-address-downstream-upstream/pom.xml | 2 +-
 examples/features/federation/federated-address-downstream/pom.xml | 2 +-

[activemq-artemis] branch master updated: ARTEMIS-2969 / ARTEMIS-2937 Making sure consumers are cleaned after failures and reconnects

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
 new 648340a  ARTEMIS-2969 / ARTEMIS-2937 Making sure consumers are cleaned 
after failures and reconnects
648340a is described below

commit 648340a864d95652c0e8fe030705f51114116962
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 17:13:46 2020 -0500

ARTEMIS-2969 / ARTEMIS-2937 Making sure consumers are cleaned after 
failures and reconnects
---
 .../amqp/connect/AMQPBrokerConnection.java | 50 ---
 .../mirror/AMQPMirrorControllerAggregation.java|  4 ++
 .../connect/mirror/AMQPMirrorControllerSource.java | 13 +++-
 .../connect/mirror/AMQPMirrorControllerTarget.java |  4 ++
 .../integration/amqp/connect/AMQPBridgeTest.java   | 22 ++-
 .../integration/amqp/connect/AMQPReplicaTest.java  | 72 +-
 .../amqp/connect/QpidDispatchPeerTest.java | 44 ++---
 7 files changed, 171 insertions(+), 38 deletions(-)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
index 27289f1..dcac1be 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
@@ -138,9 +138,12 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
 
@Override
public void stop() {
+  if (!started) return;
   started = false;
-  if (connection != null) {
- connection.close();
+  if (protonRemotingConnection != null) {
+ protonRemotingConnection.fail(new ActiveMQException("Stopping Broker 
Connection"));
+ protonRemotingConnection = null;
+ connection = null;
   }
   ScheduledFuture scheduledFuture = reconnectFuture;
   reconnectFuture = null;
@@ -151,6 +154,7 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
 
@Override
public void start() throws Exception {
+  if (started) return;
   started = true;
   server.getConfiguration().registerBrokerPlugin(this);
   try {
@@ -158,7 +162,7 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
  if (brokerConnectConfiguration != null && 
brokerConnectConfiguration.getConnectionElements() != null) {
 for (AMQPBrokerConnectionElement connectionElement : 
brokerConnectConfiguration.getConnectionElements()) {
if (connectionElement.getType() == 
AMQPBrokerConnectionAddressType.MIRROR) {
-  installMirrorController((AMQPMirrorBrokerConnectionElement) 
connectionElement, server);
+  installMirrorController(this, 
(AMQPMirrorBrokerConnectionElement) connectionElement, server);
}
 }
  }
@@ -321,7 +325,28 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
 *  It is returning the snfQueue to the replica, and I needed isolation 
from the actual instance.
 *  During development I had a mistake where I used a property from the 
Object,
 *  so, I needed this isolation for my organization and making sure nothing 
would be shared. */
-   private static QueueBinding 
installMirrorController(AMQPMirrorBrokerConnectionElement replicaConfig, 
ActiveMQServer server) throws Exception {
+   private static Queue installMirrorController(AMQPBrokerConnection 
brokerConnection, AMQPMirrorBrokerConnectionElement replicaConfig, 
ActiveMQServer server) throws Exception {
+
+  MirrorController currentMirrorController = server.getMirrorController();
+
+  // This following block is to avoid a duplicate on mirror controller
+  if (currentMirrorController != null && currentMirrorController 
instanceof AMQPMirrorControllerSource) {
+ Queue queue = checkCurrentMirror(brokerConnection, 
(AMQPMirrorControllerSource)currentMirrorController);
+ // on this case we already had a mirror installed before, we won't 
duplicate it
+ if (queue != null) {
+return queue;
+ }
+  } else if (currentMirrorController != null && currentMirrorController 
instanceof AMQPMirrorControllerAggregation) {
+ AMQPMirrorControllerAggregation aggregation = 
(AMQPMirrorControllerAggregation) currentMirrorController;
+
+ for (AMQPMirrorControllerSource source : aggregation.getPartitions()) 
{
+Queue queue = checkCurrentMirror(brokerConnection, source);
+// on this case we already had a mirror

[activemq-artemis] branch master updated: ARTEMIS-2969 / ARTEMIS-2937 should set connecting = false when maxRetry is reached

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
 new 7a435a9  ARTEMIS-2969 / ARTEMIS-2937 should set connecting = false 
when maxRetry is reached
7a435a9 is described below

commit 7a435a944c12dfa6cab1fab3f9f1faed47a2859f
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 13:13:11 2020 -0500

ARTEMIS-2969 / ARTEMIS-2937 should set connecting = false when maxRetry is 
reached
---
 .../activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
index b4b336d..27289f1 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
@@ -303,6 +303,7 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
 }
 reconnectFuture = scheduledExecutorService.schedule(() -> 
connectExecutor.execute(() -> doConnect()), 
brokerConnectConfiguration.getRetryInterval(), TimeUnit.MILLISECONDS);
  } else {
+connecting = false;
 
ActiveMQAMQPProtocolLogger.LOGGER.retryConnectionFailed(brokerConnectConfiguration.getName(),
 host + ":" +  port, retryCounter);
 if (logger.isDebugEnabled()) {
logger.debug("no more reconnections as the retry counter 
reached " + retryCounter + " out of " + 
brokerConnectConfiguration.getReconnectAttempts());

[activemq-artemis] branch master updated: Revert "NO-JIRA avoiding having rogue process when running test"

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
 new 16e8db3  Revert "NO-JIRA avoiding having rogue process when running 
test"
16e8db3 is described below

commit 16e8db3aeba7f6466b963cd2df530ef1bd82d0e6
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 12:42:30 2020 -0500

Revert "NO-JIRA avoiding having rogue process when running test"

This reverts commit a2d6d1d89d67d469a1e3ea7857b325d57728ea60.
---
 .../artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
index 54e5397..0ab1e45 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
@@ -74,7 +74,6 @@ public class QpidDispatchPeerTest extends 
AmqpClientTestSupport {
 
@Before
public void startQpidRouter() throws Exception {
-  ExecuteUtil.runCommand(false, "killall", "-9", "qdrouterd"); // killing 
any previous running qdrouterd that may have been left from the execution
   URL qpidConfig = 
this.getClass().getClassLoader().getResource("QpidRouterPeerTest-qpidr.conf");
   qpidProcess = ExecuteUtil.run(true, "qdrouterd", "-c", 
qpidConfig.getFile());
}

[activemq-artemis] branch master updated (c320d8b -> fa4064c)

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.


from c320d8b  This closes #3325
 new a2d6d1d  NO-JIRA avoiding having rogue process when running test
 new fa4064c  ARTEMIS-2969 / ARTEMIS-2937 RedoConnection should call 
protonRemotingConnection.destroy

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../artemis/protocol/amqp/connect/AMQPBrokerConnection.java  | 9 ++---
 .../tests/integration/amqp/connect/QpidDispatchPeerTest.java | 1 +
 2 files changed, 7 insertions(+), 3 deletions(-)

[activemq-artemis] 01/02: NO-JIRA avoiding having rogue process when running test

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit a2d6d1d89d67d469a1e3ea7857b325d57728ea60
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 11:23:52 2020 -0500

NO-JIRA avoiding having rogue process when running test
---
 .../artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
index 0ab1e45..54e5397 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/connect/QpidDispatchPeerTest.java
@@ -74,6 +74,7 @@ public class QpidDispatchPeerTest extends 
AmqpClientTestSupport {
 
@Before
public void startQpidRouter() throws Exception {
+  ExecuteUtil.runCommand(false, "killall", "-9", "qdrouterd"); // killing 
any previous running qdrouterd that may have been left from the execution
   URL qpidConfig = 
this.getClass().getClassLoader().getResource("QpidRouterPeerTest-qpidr.conf");
   qpidProcess = ExecuteUtil.run(true, "qdrouterd", "-c", 
qpidConfig.getFile());
}

[activemq-artemis] 02/02: ARTEMIS-2969 / ARTEMIS-2937 RedoConnection should call protonRemotingConnection.destroy

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit fa4064cfd784e93a02a3905b16b8c9302fe105fc
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 11:16:36 2020 -0500

ARTEMIS-2969 / ARTEMIS-2937 RedoConnection should call 
protonRemotingConnection.destroy

Instead of calling destroy, redo was closing the Netty connection directly 
leaving the job of destroy delayed until TTL
---
 .../artemis/protocol/amqp/connect/AMQPBrokerConnection.java  | 9 ++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
index 1e6d52b..b4b336d 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
@@ -524,15 +524,18 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
   // keeping a single executor thread to this purpose would simplify things
   connectExecutor.execute(() -> {
  if (connecting) {
-logger.debug("Broker connection " + this.getName() + " was already 
in retry mode, exception or retry no captured");
+if (logger.isDebugEnabled()) {
+   logger.debug("Broker connection " + this.getName() + " was 
already in retry mode, exception or retry not captured");
+}
 return;
  }
  connecting = true;
 
  try {
-if (connection != null) {
-   connection.close();
+if (protonRemotingConnection != null) {
+   protonRemotingConnection.destroy();
connection = null;
+   protonRemotingConnection = null;
 }
  } catch (Throwable e) {
 logger.warn(e.getMessage(), e);

[activemq-artemis] annotated tag 2.16.0 deleted (was 419fab0)

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a change to annotated tag 2.16.0
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.


*** WARNING: tag 2.16.0 was deleted! ***

   tag was  419fab0

The revisions that were on this annotated tag are still contained in
other references; therefore, this change does not discard any commits
from the repository.

[activemq-artemis] branch master updated: ARTEMIS-2973 - JMS AMQP Shared global subscriber queue not deleted on unsubscribe

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
 new dafef2b  ARTEMIS-2973 - JMS AMQP Shared global subscriber queue not 
deleted on unsubscribe
 new c320d8b  This closes #3325
dafef2b is described below

commit dafef2b2674286e23b1e9bb47a2b79f6d16c25d0
Author: Andy Taylor 
AuthorDate: Mon Nov 2 12:02:11 2020 +

ARTEMIS-2973 - JMS AMQP Shared global subscriber queue not deleted on 
unsubscribe

https://issues.apache.org/jira/browse/ARTEMIS-2973
---
 .../amqp/proton/ProtonServerSenderContext.java |  1 +
 .../integration/amqp/JMSTopicConsumerTest.java | 94 ++
 2 files changed, 95 insertions(+)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
index 63af703..2ec4742 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerSenderContext.java
@@ -843,6 +843,7 @@ public class ProtonServerSenderContext extends 
ProtonInitializable implements Pr
 String clientId = getClientId();
 String pubId = sender.getName();
 global = hasRemoteDesiredCapability(sender, GLOBAL);
+shared = hasRemoteDesiredCapability(sender, SHARED);
 queue = createQueueName(connection.isUseCoreSubscriptionNaming(), 
clientId, pubId, true, global, false);
 QueueQueryResult result = sessionSPI.queueQuery(queue, 
RoutingType.MULTICAST, false);
 multicast = true;
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
index 5f7490f..977e13f 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSTopicConsumerTest.java
@@ -27,6 +27,7 @@ import javax.jms.JMSConsumer;
 import javax.jms.JMSContext;
 import javax.jms.JMSException;
 import javax.jms.JMSProducer;
+import javax.jms.MessageConsumer;
 import javax.jms.MessageProducer;
 import javax.jms.Session;
 import javax.jms.TextMessage;
@@ -210,6 +211,99 @@ public class JMSTopicConsumerTest extends 
JMSClientTestSupport {
}
 
@Test(timeout = 6)
+   public void testDurableSharedSubscriptionUnsubscribe() throws Exception {
+  Connection connection = createConnection("myClientId");
+
+  try {
+ Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+ Topic topic = session.createTopic(getTopicName());
+ MessageConsumer myDurSub = session.createSharedDurableConsumer(topic, 
"myDurSub");
+ Assert.assertTrue(server.getPostOffice().getBinding(new 
SimpleString("myClientId.myDurSub")) != null);
+ myDurSub.close();
+ session.unsubscribe("myDurSub");
+ session.close();
+ connection.close();
+ Assert.assertTrue(server.getPostOffice().getBinding(new 
SimpleString("myClientId.myDurSub")) == null);
+  } finally {
+ connection.close();
+  }
+   }
+
+   @Test(timeout = 6)
+   public void testDurableMultipleSharedSubscriptionUnsubscribe() throws 
Exception {
+  Connection connection = createConnection("myClientId");
+
+  try {
+ Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+ Session session2 = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+ Topic topic = session.createTopic(getTopicName());
+ MessageConsumer myDurSub = session.createSharedDurableConsumer(topic, 
"myDurSub");
+ MessageConsumer myDurSub2 = 
session2.createSharedDurableConsumer(topic, "myDurSub");
+ Assert.assertTrue(server.getPostOffice().getBinding(new 
SimpleString("myClientId.myDurSub")) != null);
+ myDurSub.close();
+ try {
+session.unsubscribe("myDurSub");
+Assert.fail("should throw exception on active durable subs");
+ } catch (JMSException e) {
+//pass
+ }
+ myDurSub2.close();
+ session.unsubscribe("myDurSub");
+ session.close();
+ connection.close();
+ Assert.assertTrue(server.getPostOffice().getBinding(new 
SimpleString("myClientId.myDurSub")) == null);
+  } finally

[activemq-artemis] branch master updated: ARTEMIS-2969 / ARTEMIS-2937 Controlling connecting state on AMQP Broker Connection

2020-11-02 Thread clebertsuconic 
This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
 new c0b12b1  ARTEMIS-2969 / ARTEMIS-2937 Controlling connecting state on 
AMQP Broker Connection
c0b12b1 is described below

commit c0b12b14c88995a1ca2d3e2c2220aeca220d94b7
Author: Clebert Suconic 
AuthorDate: Mon Nov 2 07:34:35 2020 -0500

ARTEMIS-2969 / ARTEMIS-2937 Controlling connecting state on AMQP Broker 
Connection

- Fixed an issue where I needed to set connection to null after closing it
- Added more tests on QpidDispatchPeerTest (tests i would have done 
manually, and reproduced a few issues along the way)
---
 .../apache/activemq/artemis/utils/ExecuteUtil.java |  7 +
 .../amqp/connect/AMQPBrokerConnection.java | 33 +++-
 .../amqp/connect/QpidDispatchPeerTest.java | 35 +-
 3 files changed, 61 insertions(+), 14 deletions(-)

diff --git 
a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ExecuteUtil.java
 
b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ExecuteUtil.java
index 3a36425..19a046a 100644
--- 
a/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ExecuteUtil.java
+++ 
b/artemis-commons/src/test/java/org/apache/activemq/artemis/utils/ExecuteUtil.java
@@ -22,6 +22,7 @@ import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
+import java.lang.reflect.Field;
 import java.util.concurrent.TimeUnit;
 
 public class ExecuteUtil {
@@ -38,6 +39,12 @@ public class ExecuteUtil {
  inputStreamReader.join();
   }
 
+  public int pid() throws Exception {
+ Field pidField = process.getClass().getDeclaredField("pid");
+ pidField.setAccessible(true);
+ return (int)pidField.get(process);
+  }
+
   public int waitFor(long timeout, TimeUnit unit) throws 
InterruptedException {
  if (!process.waitFor(timeout, unit)) {
 logger.warn("could not complete execution in time");
diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
index 181d8ed..1e6d52b 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/connect/AMQPBrokerConnection.java
@@ -92,6 +92,7 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
private volatile boolean started = false;
private final AMQPBrokerConnectionManager bridgeManager;
private int retryCounter = 0;
+   private boolean connecting = false;
private volatile ScheduledFuture reconnectFuture;
private Set senders = new HashSet<>();
private Set receivers = new HashSet<>();
@@ -209,6 +210,8 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
 
private void doConnect() {
   try {
+ connecting = true;
+
  List configurationList = 
brokerConnectConfiguration.getTransportConfigurations();
 
  TransportConfiguration tpConfig = configurationList.get(0);
@@ -283,6 +286,8 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
  protonRemotingConnection.getAmqpConnection().flush();
 
  bridgeManager.connected(connection, this);
+
+ connecting = false;
   } catch (Throwable e) {
  error(e);
   }
@@ -464,6 +469,7 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
}
 
protected void error(Throwable e) {
+  connecting = false;
   logger.warn(e.getMessage(), e);
   redoConnection();
}
@@ -511,16 +517,29 @@ public class AMQPBrokerConnection implements 
ClientConnectionLifeCycleListener,
}
 
private void redoConnection() {
-  try {
- if (connection != null) {
-connection.close();
+
+  // we need to use the connectExecutor to initiate a redoConnection
+  // otherwise we would need to add synchronized blocks along this class
+  // to control when connecting becomes true and when it becomes false
+  // keeping a single executor thread to this purpose would simplify things
+  connectExecutor.execute(() -> {
+ if (connecting) {
+logger.debug("Broker connection " + this.getName() + " was already 
in retry mode, exception or retry no captured");
+return;
  }
-  } catch (Throwable e) {
- logger.warn(e.getMessage(), e);
-  }
+ connecting =