Build failed in Jenkins: ActiveMQ-Artemis-Master #2319

[Apache Jenkins Server]

See 


Changes:

[howard.gao] ARTEMIS-2289 SUBSCRIBE w/receipt returns 2 receipt-ids

--
[...truncated 1.20 MB...]
*¾Ñ~Ñ(
vϪuIšYE?§¨?ÚÈDŽN6زe?oj??ŸÛÿnü&Nœº?Hì 
d¨Ð4F´A[ƒž:«?g·¬Ÿ?DvÄ÷*V?eéÐxê?øz¹Œ5Fâü£= 
?aýÔ©?0åÑ5%ó?N—+h¤?¶`.0¡›~0??§Â??ç%Î?O?_—ãGŒU³t-͎•8¦’_;qóºv+jz%’¨ïèÚadpQAŽóo²€ýÎ8uû‚Kz?\À??ÐiX²0—›b?ØޛXb
 ÐȀC´,·¢ë¾ÙJãšub}Ø*ò?jÅ$¤µË+ÚýÊáhÐ??)R>º¶¦(À 
ê‰Ë$¿Š2w«?Äe“€?29¥?½žõ¸¨ô?,giï]ÄÎþ6`üD$?x;$Y†v¨½ë?o?­]Rk‹²—Qɶ®=ÂP0>0!0 
??+¶Wgfh?ô??f?ÊD?Äd,?Ĉ??ËCB Îî):†f&ɗƒú>üÿ!´???† 

=
== File: 

=
0‚
)???0‚  â?  *†H†÷
??? ‚   Ó?‚ Ï0‚ Ë0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???½/ 
DÛüo¶7?E\"Øê?Ò¶???ÃP?‚?ÈèÐF玀8§©òct¦$X„öCCâ?yï5?Q?‡?ÀcKÖ??§ÐLù²ÅŸûÑ??˜eÛ~w†ÛÆk?Yîwuú#°KSï:8¨ß¾uv9CGö?FV5bŸ?\’°Õ¨e$VCŸÜÄ??¼Àç?®SÝ{ž?|à?7AÈ4±?éÃCi?°¯n¾µŒÖÍP
 oßá=`0t&zœuê9?ó®rê÷ˆFÞ?%äþV7ÁîKüHíí—ÀP?ï
å?CŽ¶f?ÿØÌúށu¤ÖAéuèoXç˜Í1?9UE}·€ù:·O™‰ó»ÊKž¸?‘?ÀBG?{X@kòËÕº;O?Y|WA†Î§?° 
‰ŽÀBsî`"d?„öŒ³?þ^–·ÂÁò?ý?¥ñJ쉝1êÅ°´žë¥`Ĭ‰št€3÷õ‹Þ€½Û®zfœòbÅ¡«7O•¥BÚ×#ÑÙÑ?êÇ?“.¿??&?÷L'ó/Þ?,?W¹+Ÿ`?Ï{֒S¸3Ÿç?ÝÐ@?Õ¿U¸=î?#Y†AÁu-zãúµn¥¸??75µ?7mûíG)1À?X?!n>)¶¿b#n—$QòŠùÙ-⽕¸Œ:èñ?¹(OÖ?Ž`:ýñÏ_
…ÅŽ?.Öú½Y4N…
¥çÍ?p¼6g»ÉKzå?Ö?q?ƒ'L>çï?=Ovx™¦™ºX¨ŸÎèx©¤Gä—?W(ãX®€¼Fð$/Š—?Ý>??„¼ˆ?z"ùø‚ÙzæRAâV?9j‘÷µš?¯)?B4(ý:ä÷Pƒ'‡ÛéTLBtš^GuõX?‡?Æ»Š?E¸5s–éôh¾0??*†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270966159850‚?\?*†H†÷
??? ‚?M0‚?I???0‚?B? *†H†÷
???0)?
*†H†÷
0???9?`fPˆ¬IM›Å
Ä?Ê÷Q”‡Ç???ÃP€‚??m¾WÇ
^’[â8?l€0_z¸0TÐԝò9o?£H?€÷öªÚ?ºÉ?ÆÇ+˘½?=ðcå%Q#~0ääþiwOÿvgAïæú?sò†1;`U(?cñøñ+>üùD?Sk?Ëöä?ËSöp?”±¼$÷qd?kÂ?0?8`?Êe?V?ËÛ²ÄP?æÕ???›ðîñµ½`?ˆ,hþj¦û[”T?5ü“öØ·n7äNŸþÁ»ÀF5NÉlZáŨñ©¬?€ÁSë'œ?6yX?z"£àüÑñeÞ÷m???¯wSü®g©?DX?5Ê]?¥?1y?n
²¶÷0!0
??+u?é?É?áڅ¨ú?¢4ºÝbκ??¯?ƒƒÄ?õ?›2?¿–3[Ž?Ú»#???† 

=
== File: 

=
0‚?†???0‚???*†H†÷
??? ‚?0?‚?,0‚?(0‚?$?*†H†÷
??? ‚??0‚?0‚?
?   *†H†÷
???0)?
*†H†÷
0???8,?¿¹lÓ;°hXš.j·¡Û.À7???ÃP€‚?Ъ24zÅi‚ H±?u¡zåûH>pæÇôj?¦? 
Š"Èò(?Á|Ê&$rö1~ñ ì×W?÷
»??N½^@éÙvVEËÓwÍ?'?éÛbpãu?ÿ‚X?z¡xܝ€‘4=6?5'´6X%ŽÇ?™¦“S4¼òKhüèή×ÀÝ%m`×òí¦dŠ?Ì9
…`,4gêÆk늶ÐRˆ?lyݜF÷#š´ 
"YvîÌ`äùñ4?­®ñúL™ÛÊ!æV{v?2>ÛBL?tÖUŸpÁœøž*+fDÖ?iŠ?ÄI«Mп'W&:§??Ðt÷?v¢í…
½?†ã>Ã?Y×ómüO?¥)³êEŽ¸ê»Ø?
gìZs}.»‰'6ò¡àU?و?ªtÀÖù²?Þ÷??@«õ«¸@§?RòçÎ9(çQ?þv?'ê?¼–Yú?'Ðû×ê§ÀáÉv6¹êM‘å¥O·—2Ñ]™4ß+ëŒ?OŸAwŒ?ö)‚Xt
 ?›éf’]É?!.&ÁTS𙠳&¡Y 
ÕgLƒˆm?™—¢q×m8I?þ—¢ÏØm??oå]ÙÉѾ=ª]d›?tpçëˆ#©ÚÑàH+Æã¥éhaÁ‘$ñ?¬=??e—Ÿ?…Ms 
àÓ¤X›K#0>0!0 ??+?8ÔôÑ?ÉÚºûëÕ¤ HTê?Ÿ??¡Þ…
ßü…HÜ&BŒàËð„„>† 

=
== File: 

=
0‚
0‚  Ò?  *†H†÷
??? ‚   Ã?‚ ¿0‚ »0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???5?“s?Lù‹nbáQ%ÔÍ?£?á???ÃP?‚?È}‡N%M/5fє?D¹-™ÝîUÈy©? QÔÜ
lÿçtÂãn@u‚ùÁù×2V{ ™Þ–ÅÉÁò,áf6…î´ðÞ!á?ƒ>íô Þ>‡ïßv’Î?<)ˆû>?i&§Æ¡„ÐÆU}O?‡É¡©„
Æôɐ*®‹Õß?U?ÛÓ´"UûMØ–?i¼$þ@Õe®?±m?kâAFW>¦þIº??¬õè?h"Ü?ƒb¥&»%yÈúÔ?Q?ë2Ñ%¦Ô†Çµ\?&
ò@è¤÷mfjÏÒ«]=‰É
?—?–÷ìµxůxkB?û™¥?2?‹¤?GØÞu_
-tëL±BO³,?Àé¥??ˤ`î˜í2Ôu‹?]a!u
o?Fø\ÂÐÏ?e³
·+¨??¸dn?6“?ƒxÄ??­0½x??.Um?Ø"Â
8?Ë4_??è@??:³ßühdðº¶6æ±?‹‰RÐ^Ÿîò˦g–3ñÌ,»aô녰œúpé4Tq²I‡i<â\?2?˜?˜??”ªdxþàb
iRc•|Œ¸wšV?©úœµf
9]?p¸?橀ß#¿î|&›¸2BCÒ%!¡??dK½î™»­??0ûP?³¼?„´3Ñ"?wR¤Ek[Ô脚.¤‰(Ä|]?ô?’^­ÏèWñ&Üxç´:´”?Õ
   
Í"ŽI–"ô|ýéÞ·;µ•Ô}¹??2F?(à²z[Ž‰Pcͼ?z¸`?Cž¡àKn?Lተ¢Í?~Ä?z×6÷áW¶??³?މ&afø"fm3û(?K*ÏcWÅÒwÍé´Wؖ?-§uL?¥b_à@s&؛eÞ?G?04ÿ'°œ?aÄgq!¥È?à¸ñ¡?'`÷¢-*?d÷‹½ßÒ¦"Š‹AoÛ»¢)l+ýº’?•:mÓ¶d’»??º7i±´º¢¯N¯u,??äÓfw?¸ûÉ?8d毿uÿ4?®Šr­/X?;wø²Í'W÷SM4æчԥÍÏTG¦‚’w[?"•mÁm¸îŠB°Œs\¢^ë?Äk?Ì}?3'Ô°“˜¤§{ÑMX©ŒY0Y8·ÙÏmÞñ
 þ???¿·
Ê?4`ÒĹH±X«„‘ÀãíŽóóÚçe•õ4õ¥
XÊÔ?֗Wx?x-¨š[@·ù°Õ{T k>&˜˜‚n"?ďÇƼ’N„üD=¸wÊ才Ç?•} ý݅
vzœ{?$K@M?Þßî¾Á?‚Rž?É»tý2m´A²eÀ$.F?þ›._-?ï“?f†?%cZšY?þ9%)b…k¢g™ß1>0?? *†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270978378910‚?L?*†H†÷
??? ‚?=0‚?9???0‚?2? *†H†÷
???0)?
*†H†÷
0???’M©o©?›k?³?ÂщÀ?xc?ü¥f1??+4†^Á×¥?ã³?Â\ò?áý³ÓÅ?Ìãþ„u'é??㫝õ¹ÉO¹¥
 }êÅð×?Nq.ìÃØËф¡öÊ@FÅ4û^ï“Q8Õ­½Cř©æ?
?JÝ(Df¦?Êóm·3Ûäã ùµyÌ@
Ƕ0!?>qΨH‚N?…Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IəD ??õÓân„û?¤©}P}@,*op4
”?ç;·¯‚Ü?zþÉoo…?àäVmà?{?&º#ŠB’gùòx?ËnC7×x—ÁúÜúÆh1A2ˆÔ§·?ÈJð ObßMÖëP
?‹ˆ_`?Úz-$z<¯?ƒ¨ˆ?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uE‰kræρ?1±ÀÄÓ?K±ˆ:?ƒ_Z7-J9l0ýò<8Ò«??š9€Ñ«“?þ46´W?!pC´“ûãŒ?rwjõ?–˜r¬ërþ?÷ÆSŸ½vבDrü±Oà$‡€?ôûÿò„?ó‰
 "Ðó0Læ; 
˜×R›?Çäþ£¸·“ªÓoòÙÌúÕt7$Ä??Õ??õ?‘?“È™ò[†û

[activemq-artemis] branch master updated: ARTEMIS-2289 SUBSCRIBE w/receipt returns 2 receipt-ids

[gaohoward]

This is an automated email from the ASF dual-hosted git repository.

gaohoward 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 304ff79  ARTEMIS-2289 SUBSCRIBE w/receipt returns 2 receipt-ids
 new 279f655  This closes #2600
304ff79 is described below

commit 304ff797123be2f79db1abfdccd9b2374202a371
Author: Justin Bertram 
AuthorDate: Sat Mar 30 14:36:02 2019 -0500

ARTEMIS-2289 SUBSCRIBE w/receipt returns 2 receipt-ids
---
 .../core/protocol/stomp/VersionedStompFrameHandler.java   |  3 ---
 .../artemis/tests/integration/stomp/v12/StompV12Test.java | 11 +++
 2 files changed, 11 insertions(+), 3 deletions(-)

diff --git 
a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/VersionedStompFrameHandler.java
 
b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/VersionedStompFrameHandler.java
index 75c1ea3..bac1c24 100644
--- 
a/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/VersionedStompFrameHandler.java
+++ 
b/artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/VersionedStompFrameHandler.java
@@ -126,9 +126,6 @@ public abstract class VersionedStompFrameHandler {
   try {
  StompPostReceiptFunction postProcessFunction = onSubscribe(request);
  response = postprocess(request);
- if (request.hasHeader(Stomp.Headers.RECEIPT_REQUESTED)) {
-response.addHeader(Stomp.Headers.Response.RECEIPT_ID, 
request.getHeader(Stomp.Headers.RECEIPT_REQUESTED));
- }
  connection.sendFrame(response, postProcessFunction);
  return null;
   } catch (ActiveMQStompException e) {
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
index e3b61b3..3e6e46c 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v12/StompV12Test.java
@@ -33,6 +33,7 @@ import java.util.UUID;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.regex.Pattern;
 
 import org.apache.activemq.artemis.api.core.RoutingType;
 import org.apache.activemq.artemis.api.core.SimpleString;
@@ -98,6 +99,16 @@ public class StompV12Test extends StompTestBase {
}
 
@Test
+   public void testSubscribeWithReceipt() throws Exception {
+  conn.connect(defUser, defPass);
+
+  Pattern p = Pattern.compile("receipt-id:.*\\nreceipt-id");
+  assertFalse(p.matcher(subscribe(conn, null).toString()).find());
+
+  conn.disconnect();
+   }
+
+   @Test
public void testConnection() throws Exception {
   server.getSecurityStore().setSecurityEnabled(true);
   StompClientConnection connection = 
StompClientConnectionFactory.createClientConnection(v10Uri);

buildbot success in on activemq-site-production

[buildbot]

The Buildbot has detected a restored build on builder activemq-site-production 
while building . Full details are available at:
https://ci.apache.org/builders/activemq-site-production/builds/32854

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

Buildslave for this Build: bb-cms-slave

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

Build succeeded!

Sincerely,
 -The Buildbot

buildbot failure in on activemq-site-production

[buildbot]

The Buildbot has detected a new failure on builder activemq-site-production 
while building . Full details are available at:
https://ci.apache.org/builders/activemq-site-production/builds/32853

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

Buildslave for this Build: bb-cms-slave

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

BUILD FAILED: failed compile

Sincerely,
 -The Buildbot

Build failed in Jenkins: ActiveMQ-Artemis-Master #2318

[Apache Jenkins Server]

See 


Changes:

[jbertram] ARTEMIS-2283 Bad WARN message "AMQ11: Storage is back to stable 
now"

--
[...truncated 1.15 MB...]
*¾Ñ~Ñ(
vϪuIšYE?§¨?ÚÈDŽN6زe?oj??ŸÛÿnü&Nœº?Hì 
d¨Ð4F´A[ƒž:«?g·¬Ÿ?DvÄ÷*V?eéÐxê?øz¹Œ5Fâü£= 
?aýÔ©?0åÑ5%ó?N—+h¤?¶`.0¡›~0??§Â??ç%Î?O?_—ãGŒU³t-͎•8¦’_;qóºv+jz%’¨ïèÚadpQAŽóo²€ýÎ8uû‚Kz?\À??ÐiX²0—›b?ØޛXb
 ÐȀC´,·¢ë¾ÙJãšub}Ø*ò?jÅ$¤µË+ÚýÊáhÐ??)R>º¶¦(À 
ê‰Ë$¿Š2w«?Äe“€?29¥?½žõ¸¨ô?,giï]ÄÎþ6`üD$?x;$Y†v¨½ë?o?­]Rk‹²—Qɶ®=ÂP0>0!0 
??+¶Wgfh?ô??f?ÊD?Äd,?Ĉ??ËCB Îî):†f&ɗƒú>üÿ!´???† 

=
== File: 

=
0‚
)???0‚  â?  *†H†÷
??? ‚   Ó?‚ Ï0‚ Ë0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???½/ 
DÛüo¶7?E\"Øê?Ò¶???ÃP?‚?ÈèÐF玀8§©òct¦$X„öCCâ?yï5?Q?‡?ÀcKÖ??§ÐLù²ÅŸûÑ??˜eÛ~w†ÛÆk?Yîwuú#°KSï:8¨ß¾uv9CGö?FV5bŸ?\’°Õ¨e$VCŸÜÄ??¼Àç?®SÝ{ž?|à?7AÈ4±?éÃCi?°¯n¾µŒÖÍP
 oßá=`0t&zœuê9?ó®rê÷ˆFÞ?%äþV7ÁîKüHíí—ÀP?ï
å?CŽ¶f?ÿØÌúށu¤ÖAéuèoXç˜Í1?9UE}·€ù:·O™‰ó»ÊKž¸?‘?ÀBG?{X@kòËÕº;O?Y|WA†Î§?° 
‰ŽÀBsî`"d?„öŒ³?þ^–·ÂÁò?ý?¥ñJ쉝1êÅ°´žë¥`Ĭ‰št€3÷õ‹Þ€½Û®zfœòbÅ¡«7O•¥BÚ×#ÑÙÑ?êÇ?“.¿??&?÷L'ó/Þ?,?W¹+Ÿ`?Ï{֒S¸3Ÿç?ÝÐ@?Õ¿U¸=î?#Y†AÁu-zãúµn¥¸??75µ?7mûíG)1À?X?!n>)¶¿b#n—$QòŠùÙ-⽕¸Œ:èñ?¹(OÖ?Ž`:ýñÏ_
…ÅŽ?.Öú½Y4N…
¥çÍ?p¼6g»ÉKzå?Ö?q?ƒ'L>çï?=Ovx™¦™ºX¨ŸÎèx©¤Gä—?W(ãX®€¼Fð$/Š—?Ý>??„¼ˆ?z"ùø‚ÙzæRAâV?9j‘÷µš?¯)?B4(ý:ä÷Pƒ'‡ÛéTLBtš^GuõX?‡?Æ»Š?E¸5s–éôh¾0??*†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270966159850‚?\?*†H†÷
??? ‚?M0‚?I???0‚?B? *†H†÷
???0)?
*†H†÷
0???9?`fPˆ¬IM›Å
Ä?Ê÷Q”‡Ç???ÃP€‚??m¾WÇ
^’[â8?l€0_z¸0TÐԝò9o?£H?€÷öªÚ?ºÉ?ÆÇ+˘½?=ðcå%Q#~0ääþiwOÿvgAïæú?sò†1;`U(?cñøñ+>üùD?Sk?Ëöä?ËSöp?”±¼$÷qd?kÂ?0?8`?Êe?V?ËÛ²ÄP?æÕ???›ðîñµ½`?ˆ,hþj¦û[”T?5ü“öØ·n7äNŸþÁ»ÀF5NÉlZáŨñ©¬?€ÁSë'œ?6yX?z"£àüÑñeÞ÷m???¯wSü®g©?DX?5Ê]?¥?1y?n
²¶÷0!0
??+u?é?É?áڅ¨ú?¢4ºÝbκ??¯?ƒƒÄ?õ?›2?¿–3[Ž?Ú»#???† 

=
== File: 

=
0‚?†???0‚???*†H†÷
??? ‚?0?‚?,0‚?(0‚?$?*†H†÷
??? ‚??0‚?0‚?
?   *†H†÷
???0)?
*†H†÷
0???8,?¿¹lÓ;°hXš.j·¡Û.À7???ÃP€‚?Ъ24zÅi‚ H±?u¡zåûH>pæÇôj?¦? 
Š"Èò(?Á|Ê&$rö1~ñ ì×W?÷
»??N½^@éÙvVEËÓwÍ?'?éÛbpãu?ÿ‚X?z¡xܝ€‘4=6?5'´6X%ŽÇ?™¦“S4¼òKhüèή×ÀÝ%m`×òí¦dŠ?Ì9
…`,4gêÆk늶ÐRˆ?lyݜF÷#š´ 
"YvîÌ`äùñ4?­®ñúL™ÛÊ!æV{v?2>ÛBL?tÖUŸpÁœøž*+fDÖ?iŠ?ÄI«Mп'W&:§??Ðt÷?v¢í…
½?†ã>Ã?Y×ómüO?¥)³êEŽ¸ê»Ø?
gìZs}.»‰'6ò¡àU?و?ªtÀÖù²?Þ÷??@«õ«¸@§?RòçÎ9(çQ?þv?'ê?¼–Yú?'Ðû×ê§ÀáÉv6¹êM‘å¥O·—2Ñ]™4ß+ëŒ?OŸAwŒ?ö)‚Xt
 ?›éf’]É?!.&ÁTS𙠳&¡Y 
ÕgLƒˆm?™—¢q×m8I?þ—¢ÏØm??oå]ÙÉѾ=ª]d›?tpçëˆ#©ÚÑàH+Æã¥éhaÁ‘$ñ?¬=??e—Ÿ?…Ms 
àÓ¤X›K#0>0!0 ??+?8ÔôÑ?ÉÚºûëÕ¤ HTê?Ÿ??¡Þ…
ßü…HÜ&BŒàËð„„>† 

=
== File: 

=
0‚
0‚  Ò?  *†H†÷
??? ‚   Ã?‚ ¿0‚ »0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???5?“s?Lù‹nbáQ%ÔÍ?£?á???ÃP?‚?È}‡N%M/5fє?D¹-™ÝîUÈy©? QÔÜ
lÿçtÂãn@u‚ùÁù×2V{ ™Þ–ÅÉÁò,áf6…î´ðÞ!á?ƒ>íô Þ>‡ïßv’Î?<)ˆû>?i&§Æ¡„ÐÆU}O?‡É¡©„
Æôɐ*®‹Õß?U?ÛÓ´"UûMØ–?i¼$þ@Õe®?±m?kâAFW>¦þIº??¬õè?h"Ü?ƒb¥&»%yÈúÔ?Q?ë2Ñ%¦Ô†Çµ\?&
ò@è¤÷mfjÏÒ«]=‰É
?—?–÷ìµxůxkB?û™¥?2?‹¤?GØÞu_
-tëL±BO³,?Àé¥??ˤ`î˜í2Ôu‹?]a!u
o?Fø\ÂÐÏ?e³
·+¨??¸dn?6“?ƒxÄ??­0½x??.Um?Ø"Â
8?Ë4_??è@??:³ßühdðº¶6æ±?‹‰RÐ^Ÿîò˦g–3ñÌ,»aô녰œúpé4Tq²I‡i<â\?2?˜?˜??”ªdxþàb
iRc•|Œ¸wšV?©úœµf
9]?p¸?橀ß#¿î|&›¸2BCÒ%!¡??dK½î™»­??0ûP?³¼?„´3Ñ"?wR¤Ek[Ô脚.¤‰(Ä|]?ô?’^­ÏèWñ&Üxç´:´”?Õ
   
Í"ŽI–"ô|ýéÞ·;µ•Ô}¹??2F?(à²z[Ž‰Pcͼ?z¸`?Cž¡àKn?Lተ¢Í?~Ä?z×6÷áW¶??³?މ&afø"fm3û(?K*ÏcWÅÒwÍé´Wؖ?-§uL?¥b_à@s&؛eÞ?G?04ÿ'°œ?aÄgq!¥È?à¸ñ¡?'`÷¢-*?d÷‹½ßÒ¦"Š‹AoÛ»¢)l+ýº’?•:mÓ¶d’»??º7i±´º¢¯N¯u,??äÓfw?¸ûÉ?8d毿uÿ4?®Šr­/X?;wø²Í'W÷SM4æчԥÍÏTG¦‚’w[?"•mÁm¸îŠB°Œs\¢^ë?Äk?Ì}?3'Ô°“˜¤§{ÑMX©ŒY0Y8·ÙÏmÞñ
 þ???¿·
Ê?4`ÒĹH±X«„‘ÀãíŽóóÚçe•õ4õ¥
XÊÔ?֗Wx?x-¨š[@·ù°Õ{T k>&˜˜‚n"?ďÇƼ’N„üD=¸wÊ才Ç?•} ý݅
vzœ{?$K@M?Þßî¾Á?‚Rž?É»tý2m´A²eÀ$.F?þ›._-?ï“?f†?%cZšY?þ9%)b…k¢g™ß1>0?? *†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270978378910‚?L?*†H†÷
??? ‚?=0‚?9???0‚?2? *†H†÷
???0)?
*†H†÷
0???’M©o©?›k?³?ÂщÀ?xc?ü¥f1??+4†^Á×¥?ã³?Â\ò?áý³ÓÅ?Ìãþ„u'é??㫝õ¹ÉO¹¥
 }êÅð×?Nq.ìÃØËф¡öÊ@FÅ4û^ï“Q8Õ­½Cř©æ?
?JÝ(Df¦?Êóm·3Ûäã ùµyÌ@
Ƕ0!?>qΨH‚N?…Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IəD ??õÓân„û?¤©}P}@,*op4
”?ç;·¯‚Ü?zþÉoo…?àäVmà?{?&º#ŠB’gùòx?ËnC7×x—ÁúÜúÆh1A2ˆÔ§·?ÈJð ObßMÖëP
?‹ˆ_`?Úz-$z<¯?ƒ¨ˆ?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uE‰kræρ?1±ÀÄÓ?K±ˆ:?ƒ_Z7-J9l0ýò<8Ò«??š9€Ñ«“?þ46´W?!pC´“ûãŒ?rwjõ?–˜r¬ërþ?÷ÆSŸ½vבDrü±Oà$‡€?ôûÿò„?ó‰
 "Ðó0Læ; 
˜×R›?Çäþ£¸·“ªÓoòÙÌúÕt7$

Build failed in Jenkins: ActiveMQ-Artemis-Master #2317

[Apache Jenkins Server]

See 


Changes:

[jbertram] ARTEMIS-2290 JMSBridgeImpl::stop is failing when called from

--
[...truncated 1.15 MB...]
*¾Ñ~Ñ(
vϪuIšYE?§¨?ÚÈDŽN6زe?oj??ŸÛÿnü&Nœº?Hì 
d¨Ð4F´A[ƒž:«?g·¬Ÿ?DvÄ÷*V?eéÐxê?øz¹Œ5Fâü£= 
?aýÔ©?0åÑ5%ó?N—+h¤?¶`.0¡›~0??§Â??ç%Î?O?_—ãGŒU³t-͎•8¦’_;qóºv+jz%’¨ïèÚadpQAŽóo²€ýÎ8uû‚Kz?\À??ÐiX²0—›b?ØޛXb
 ÐȀC´,·¢ë¾ÙJãšub}Ø*ò?jÅ$¤µË+ÚýÊáhÐ??)R>º¶¦(À 
ê‰Ë$¿Š2w«?Äe“€?29¥?½žõ¸¨ô?,giï]ÄÎþ6`üD$?x;$Y†v¨½ë?o?­]Rk‹²—Qɶ®=ÂP0>0!0 
??+¶Wgfh?ô??f?ÊD?Äd,?Ĉ??ËCB Îî):†f&ɗƒú>üÿ!´???† 

=
== File: 

=
0‚
)???0‚  â?  *†H†÷
??? ‚   Ó?‚ Ï0‚ Ë0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???½/ 
DÛüo¶7?E\"Øê?Ò¶???ÃP?‚?ÈèÐF玀8§©òct¦$X„öCCâ?yï5?Q?‡?ÀcKÖ??§ÐLù²ÅŸûÑ??˜eÛ~w†ÛÆk?Yîwuú#°KSï:8¨ß¾uv9CGö?FV5bŸ?\’°Õ¨e$VCŸÜÄ??¼Àç?®SÝ{ž?|à?7AÈ4±?éÃCi?°¯n¾µŒÖÍP
 oßá=`0t&zœuê9?ó®rê÷ˆFÞ?%äþV7ÁîKüHíí—ÀP?ï
å?CŽ¶f?ÿØÌúށu¤ÖAéuèoXç˜Í1?9UE}·€ù:·O™‰ó»ÊKž¸?‘?ÀBG?{X@kòËÕº;O?Y|WA†Î§?° 
‰ŽÀBsî`"d?„öŒ³?þ^–·ÂÁò?ý?¥ñJ쉝1êÅ°´žë¥`Ĭ‰št€3÷õ‹Þ€½Û®zfœòbÅ¡«7O•¥BÚ×#ÑÙÑ?êÇ?“.¿??&?÷L'ó/Þ?,?W¹+Ÿ`?Ï{֒S¸3Ÿç?ÝÐ@?Õ¿U¸=î?#Y†AÁu-zãúµn¥¸??75µ?7mûíG)1À?X?!n>)¶¿b#n—$QòŠùÙ-⽕¸Œ:èñ?¹(OÖ?Ž`:ýñÏ_
…ÅŽ?.Öú½Y4N…
¥çÍ?p¼6g»ÉKzå?Ö?q?ƒ'L>çï?=Ovx™¦™ºX¨ŸÎèx©¤Gä—?W(ãX®€¼Fð$/Š—?Ý>??„¼ˆ?z"ùø‚ÙzæRAâV?9j‘÷µš?¯)?B4(ý:ä÷Pƒ'‡ÛéTLBtš^GuõX?‡?Æ»Š?E¸5s–éôh¾0??*†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270966159850‚?\?*†H†÷
??? ‚?M0‚?I???0‚?B? *†H†÷
???0)?
*†H†÷
0???9?`fPˆ¬IM›Å
Ä?Ê÷Q”‡Ç???ÃP€‚??m¾WÇ
^’[â8?l€0_z¸0TÐԝò9o?£H?€÷öªÚ?ºÉ?ÆÇ+˘½?=ðcå%Q#~0ääþiwOÿvgAïæú?sò†1;`U(?cñøñ+>üùD?Sk?Ëöä?ËSöp?”±¼$÷qd?kÂ?0?8`?Êe?V?ËÛ²ÄP?æÕ???›ðîñµ½`?ˆ,hþj¦û[”T?5ü“öØ·n7äNŸþÁ»ÀF5NÉlZáŨñ©¬?€ÁSë'œ?6yX?z"£àüÑñeÞ÷m???¯wSü®g©?DX?5Ê]?¥?1y?n
²¶÷0!0
??+u?é?É?áڅ¨ú?¢4ºÝbκ??¯?ƒƒÄ?õ?›2?¿–3[Ž?Ú»#???† 

=
== File: 

=
0‚?†???0‚???*†H†÷
??? ‚?0?‚?,0‚?(0‚?$?*†H†÷
??? ‚??0‚?0‚?
?   *†H†÷
???0)?
*†H†÷
0???8,?¿¹lÓ;°hXš.j·¡Û.À7???ÃP€‚?Ъ24zÅi‚ H±?u¡zåûH>pæÇôj?¦? 
Š"Èò(?Á|Ê&$rö1~ñ ì×W?÷
»??N½^@éÙvVEËÓwÍ?'?éÛbpãu?ÿ‚X?z¡xܝ€‘4=6?5'´6X%ŽÇ?™¦“S4¼òKhüèή×ÀÝ%m`×òí¦dŠ?Ì9
…`,4gêÆk늶ÐRˆ?lyݜF÷#š´ 
"YvîÌ`äùñ4?­®ñúL™ÛÊ!æV{v?2>ÛBL?tÖUŸpÁœøž*+fDÖ?iŠ?ÄI«Mп'W&:§??Ðt÷?v¢í…
½?†ã>Ã?Y×ómüO?¥)³êEŽ¸ê»Ø?
gìZs}.»‰'6ò¡àU?و?ªtÀÖù²?Þ÷??@«õ«¸@§?RòçÎ9(çQ?þv?'ê?¼–Yú?'Ðû×ê§ÀáÉv6¹êM‘å¥O·—2Ñ]™4ß+ëŒ?OŸAwŒ?ö)‚Xt
 ?›éf’]É?!.&ÁTS𙠳&¡Y 
ÕgLƒˆm?™—¢q×m8I?þ—¢ÏØm??oå]ÙÉѾ=ª]d›?tpçëˆ#©ÚÑàH+Æã¥éhaÁ‘$ñ?¬=??e—Ÿ?…Ms 
àÓ¤X›K#0>0!0 ??+?8ÔôÑ?ÉÚºûëÕ¤ HTê?Ÿ??¡Þ…
ßü…HÜ&BŒàËð„„>† 

=
== File: 

=
0‚
0‚  Ò?  *†H†÷
??? ‚   Ã?‚ ¿0‚ »0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???5?“s?Lù‹nbáQ%ÔÍ?£?á???ÃP?‚?È}‡N%M/5fє?D¹-™ÝîUÈy©? QÔÜ
lÿçtÂãn@u‚ùÁù×2V{ ™Þ–ÅÉÁò,áf6…î´ðÞ!á?ƒ>íô Þ>‡ïßv’Î?<)ˆû>?i&§Æ¡„ÐÆU}O?‡É¡©„
Æôɐ*®‹Õß?U?ÛÓ´"UûMØ–?i¼$þ@Õe®?±m?kâAFW>¦þIº??¬õè?h"Ü?ƒb¥&»%yÈúÔ?Q?ë2Ñ%¦Ô†Çµ\?&
ò@è¤÷mfjÏÒ«]=‰É
?—?–÷ìµxůxkB?û™¥?2?‹¤?GØÞu_
-tëL±BO³,?Àé¥??ˤ`î˜í2Ôu‹?]a!u
o?Fø\ÂÐÏ?e³
·+¨??¸dn?6“?ƒxÄ??­0½x??.Um?Ø"Â
8?Ë4_??è@??:³ßühdðº¶6æ±?‹‰RÐ^Ÿîò˦g–3ñÌ,»aô녰œúpé4Tq²I‡i<â\?2?˜?˜??”ªdxþàb
iRc•|Œ¸wšV?©úœµf
9]?p¸?橀ß#¿î|&›¸2BCÒ%!¡??dK½î™»­??0ûP?³¼?„´3Ñ"?wR¤Ek[Ô脚.¤‰(Ä|]?ô?’^­ÏèWñ&Üxç´:´”?Õ
   
Í"ŽI–"ô|ýéÞ·;µ•Ô}¹??2F?(à²z[Ž‰Pcͼ?z¸`?Cž¡àKn?Lተ¢Í?~Ä?z×6÷áW¶??³?މ&afø"fm3û(?K*ÏcWÅÒwÍé´Wؖ?-§uL?¥b_à@s&؛eÞ?G?04ÿ'°œ?aÄgq!¥È?à¸ñ¡?'`÷¢-*?d÷‹½ßÒ¦"Š‹AoÛ»¢)l+ýº’?•:mÓ¶d’»??º7i±´º¢¯N¯u,??äÓfw?¸ûÉ?8d毿uÿ4?®Šr­/X?;wø²Í'W÷SM4æчԥÍÏTG¦‚’w[?"•mÁm¸îŠB°Œs\¢^ë?Äk?Ì}?3'Ô°“˜¤§{ÑMX©ŒY0Y8·ÙÏmÞñ
 þ???¿·
Ê?4`ÒĹH±X«„‘ÀãíŽóóÚçe•õ4õ¥
XÊÔ?֗Wx?x-¨š[@·ù°Õ{T k>&˜˜‚n"?ďÇƼ’N„üD=¸wÊ才Ç?•} ý݅
vzœ{?$K@M?Þßî¾Á?‚Rž?É»tý2m´A²eÀ$.F?þ›._-?ï“?f†?%cZšY?þ9%)b…k¢g™ß1>0?? *†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270978378910‚?L?*†H†÷
??? ‚?=0‚?9???0‚?2? *†H†÷
???0)?
*†H†÷
0???’M©o©?›k?³?ÂщÀ?xc?ü¥f1??+4†^Á×¥?ã³?Â\ò?áý³ÓÅ?Ìãþ„u'é??㫝õ¹ÉO¹¥
 }êÅð×?Nq.ìÃØËф¡öÊ@FÅ4û^ï“Q8Õ­½Cř©æ?
?JÝ(Df¦?Êóm·3Ûäã ùµyÌ@
Ƕ0!?>qΨH‚N?…Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IəD ??õÓân„û?¤©}P}@,*op4
”?ç;·¯‚Ü?zþÉoo…?àäVmà?{?&º#ŠB’gùòx?ËnC7×x—ÁúÜúÆh1A2ˆÔ§·?ÈJð ObßMÖëP
?‹ˆ_`?Úz-$z<¯?ƒ¨ˆ?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uE‰kræρ?1±ÀÄÓ?K±ˆ:?ƒ_Z7-J9l0ýò<8Ò«??š9€Ñ«“?þ46´W?!pC´“ûãŒ?rwjõ?–˜r¬ërþ?÷ÆSŸ½vבDrü±Oà$‡€?ôûÿò„?ó‰
 "Ðó0Læ; 
˜×R›?Çäþ£¸·“ªÓoòÙÌúÕt7$Ä??Õ??õ?‘?“È™

[activemq-artemis] branch master updated: ARTEMIS-2283 Bad WARN message "AMQ222211: Storage is back to stable now"

[jbertram]

This is an automated email from the ASF dual-hosted git repository.

jbertram 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 ac4cd48  ARTEMIS-2283 Bad WARN message "AMQ11: Storage is back to 
stable now"
 new 8ca4b66  This closes #2591
ac4cd48 is described below

commit ac4cd4856c386c4cd824a56b68c6c34a2a1aab6c
Author: Francesco Nigro 
AuthorDate: Tue Mar 26 18:04:07 2019 +0100

ARTEMIS-2283 Bad WARN message "AMQ11: Storage is back to stable now"

LocalMonitor::under on PagingManagerImpl won't log anymore with a
warning message if the producers got unblocked and with info
if disk it getting freed
---
 .../artemis/core/paging/impl/PagingManagerImpl.java  | 16 ++--
 .../artemis/core/server/ActiveMQServerLogger.java|  2 +-
 .../tests/integration/paging/AddressFullLoggingTest.java |  8 +---
 3 files changed, 12 insertions(+), 14 deletions(-)

diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingManagerImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingManagerImpl.java
index 92cbf03..cce039e 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingManagerImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingManagerImpl.java
@@ -17,7 +17,6 @@
 package org.apache.activemq.artemis.core.paging.impl;
 
 import java.nio.file.FileStore;
-import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Queue;
@@ -180,13 +179,7 @@ public final class PagingManagerImpl implements 
PagingManager {
memoryReleased();
 }
  }
- Iterator storeIterator = blockedStored.iterator();
- while (storeIterator.hasNext()) {
-PagingStore store = storeIterator.next();
-if (store.checkReleasedMemory()) {
-   storeIterator.remove();
-}
- }
+ blockedStored.removeIf(PagingStore::checkReleasedMemory);
   }
}
 
@@ -213,9 +206,12 @@ public final class PagingManagerImpl implements 
PagingManager {
 
   @Override
   public void under(FileStore store, double usage) {
+ final boolean diskFull = PagingManagerImpl.this.diskFull;
  if (diskFull || !blockedStored.isEmpty() || 
!memoryCallback.isEmpty()) {
-ActiveMQServerLogger.LOGGER.diskCapacityRestored();
-diskFull = false;
+if (diskFull) {
+   ActiveMQServerLogger.LOGGER.diskCapacityRestored();
+   PagingManagerImpl.this.diskFull = false;
+}
 checkMemoryRelease();
  }
   }
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
index af474f0..9ed1419 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
@@ -1337,7 +1337,7 @@ public interface ActiveMQServerLogger extends BasicLogger 
{
   format = Message.Format.MESSAGE_FORMAT)
void diskBeyondCapacity();
 
-   @LogMessage(level = Logger.Level.WARN)
+   @LogMessage(level = Logger.Level.INFO)
@Message(id = 11, value = "Storage is back to stable now, under 
max-disk-usage.",
   format = Message.Format.MESSAGE_FORMAT)
void diskCapacityRestored();
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/AddressFullLoggingTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/AddressFullLoggingTest.java
index 1e88d30..fa57764 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/AddressFullLoggingTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/paging/AddressFullLoggingTest.java
@@ -58,6 +58,7 @@ public class AddressFullLoggingTest extends ActiveMQTestBase {
 
   AddressSettings defaultSetting = new 
AddressSettings().setPageSizeBytes(10 * 1024).setMaxSizeBytes(20 * 
1024).setAddressFullMessagePolicy(AddressFullMessagePolicy.BLOCK);
   server.getAddressSettingsRepository().addMatch("#", defaultSetting);
+  server.getConfiguration().setDiskScanPeriod(100);
   server.start();
 
   internalTest(MAX_MESSAGES, MY_ADDRESS, MY_QUEUE, server);
@@ -73,7 +74,7 @@ public class AddressFullLoggingTest extends ActiveMQTestBase {
 
   AddressSettings defaultSetting = new 
AddressSettings().setAddressFullMessagePolicy(AddressFullMessagePolicy.BLOCK);
   server.getAddressSettingsRepository().addMatch("#"

Build failed in Jenkins: ActiveMQ-Artemis-Master #2316

[Apache Jenkins Server]

See 


Changes:

[jbertram] ARTEMIS-2291 ClassCastException on JMSBridgeImpl::stop leaks bridge

--
[...truncated 1.20 MB...]
*¾Ñ~Ñ(
vϪuIšYE?§¨?ÚÈDŽN6زe?oj??ŸÛÿnü&Nœº?Hì 
d¨Ð4F´A[ƒž:«?g·¬Ÿ?DvÄ÷*V?eéÐxê?øz¹Œ5Fâü£= 
?aýÔ©?0åÑ5%ó?N—+h¤?¶`.0¡›~0??§Â??ç%Î?O?_—ãGŒU³t-͎•8¦’_;qóºv+jz%’¨ïèÚadpQAŽóo²€ýÎ8uû‚Kz?\À??ÐiX²0—›b?ØޛXb
 ÐȀC´,·¢ë¾ÙJãšub}Ø*ò?jÅ$¤µË+ÚýÊáhÐ??)R>º¶¦(À 
ê‰Ë$¿Š2w«?Äe“€?29¥?½žõ¸¨ô?,giï]ÄÎþ6`üD$?x;$Y†v¨½ë?o?­]Rk‹²—Qɶ®=ÂP0>0!0 
??+¶Wgfh?ô??f?ÊD?Äd,?Ĉ??ËCB Îî):†f&ɗƒú>üÿ!´???† 

=
== File: 

=
0‚
)???0‚  â?  *†H†÷
??? ‚   Ó?‚ Ï0‚ Ë0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???½/ 
DÛüo¶7?E\"Øê?Ò¶???ÃP?‚?ÈèÐF玀8§©òct¦$X„öCCâ?yï5?Q?‡?ÀcKÖ??§ÐLù²ÅŸûÑ??˜eÛ~w†ÛÆk?Yîwuú#°KSï:8¨ß¾uv9CGö?FV5bŸ?\’°Õ¨e$VCŸÜÄ??¼Àç?®SÝ{ž?|à?7AÈ4±?éÃCi?°¯n¾µŒÖÍP
 oßá=`0t&zœuê9?ó®rê÷ˆFÞ?%äþV7ÁîKüHíí—ÀP?ï
å?CŽ¶f?ÿØÌúށu¤ÖAéuèoXç˜Í1?9UE}·€ù:·O™‰ó»ÊKž¸?‘?ÀBG?{X@kòËÕº;O?Y|WA†Î§?° 
‰ŽÀBsî`"d?„öŒ³?þ^–·ÂÁò?ý?¥ñJ쉝1êÅ°´žë¥`Ĭ‰št€3÷õ‹Þ€½Û®zfœòbÅ¡«7O•¥BÚ×#ÑÙÑ?êÇ?“.¿??&?÷L'ó/Þ?,?W¹+Ÿ`?Ï{֒S¸3Ÿç?ÝÐ@?Õ¿U¸=î?#Y†AÁu-zãúµn¥¸??75µ?7mûíG)1À?X?!n>)¶¿b#n—$QòŠùÙ-⽕¸Œ:èñ?¹(OÖ?Ž`:ýñÏ_
…ÅŽ?.Öú½Y4N…
¥çÍ?p¼6g»ÉKzå?Ö?q?ƒ'L>çï?=Ovx™¦™ºX¨ŸÎèx©¤Gä—?W(ãX®€¼Fð$/Š—?Ý>??„¼ˆ?z"ùø‚ÙzæRAâV?9j‘÷µš?¯)?B4(ý:ä÷Pƒ'‡ÛéTLBtš^GuõX?‡?Æ»Š?E¸5s–éôh¾0??*†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270966159850‚?\?*†H†÷
??? ‚?M0‚?I???0‚?B? *†H†÷
???0)?
*†H†÷
0???9?`fPˆ¬IM›Å
Ä?Ê÷Q”‡Ç???ÃP€‚??m¾WÇ
^’[â8?l€0_z¸0TÐԝò9o?£H?€÷öªÚ?ºÉ?ÆÇ+˘½?=ðcå%Q#~0ääþiwOÿvgAïæú?sò†1;`U(?cñøñ+>üùD?Sk?Ëöä?ËSöp?”±¼$÷qd?kÂ?0?8`?Êe?V?ËÛ²ÄP?æÕ???›ðîñµ½`?ˆ,hþj¦û[”T?5ü“öØ·n7äNŸþÁ»ÀF5NÉlZáŨñ©¬?€ÁSë'œ?6yX?z"£àüÑñeÞ÷m???¯wSü®g©?DX?5Ê]?¥?1y?n
²¶÷0!0
??+u?é?É?áڅ¨ú?¢4ºÝbκ??¯?ƒƒÄ?õ?›2?¿–3[Ž?Ú»#???† 

=
== File: 

=
0‚?†???0‚???*†H†÷
??? ‚?0?‚?,0‚?(0‚?$?*†H†÷
??? ‚??0‚?0‚?
?   *†H†÷
???0)?
*†H†÷
0???8,?¿¹lÓ;°hXš.j·¡Û.À7???ÃP€‚?Ъ24zÅi‚ H±?u¡zåûH>pæÇôj?¦? 
Š"Èò(?Á|Ê&$rö1~ñ ì×W?÷
»??N½^@éÙvVEËÓwÍ?'?éÛbpãu?ÿ‚X?z¡xܝ€‘4=6?5'´6X%ŽÇ?™¦“S4¼òKhüèή×ÀÝ%m`×òí¦dŠ?Ì9
…`,4gêÆk늶ÐRˆ?lyݜF÷#š´ 
"YvîÌ`äùñ4?­®ñúL™ÛÊ!æV{v?2>ÛBL?tÖUŸpÁœøž*+fDÖ?iŠ?ÄI«Mп'W&:§??Ðt÷?v¢í…
½?†ã>Ã?Y×ómüO?¥)³êEŽ¸ê»Ø?
gìZs}.»‰'6ò¡àU?و?ªtÀÖù²?Þ÷??@«õ«¸@§?RòçÎ9(çQ?þv?'ê?¼–Yú?'Ðû×ê§ÀáÉv6¹êM‘å¥O·—2Ñ]™4ß+ëŒ?OŸAwŒ?ö)‚Xt
 ?›éf’]É?!.&ÁTS𙠳&¡Y 
ÕgLƒˆm?™—¢q×m8I?þ—¢ÏØm??oå]ÙÉѾ=ª]d›?tpçëˆ#©ÚÑàH+Æã¥éhaÁ‘$ñ?¬=??e—Ÿ?…Ms 
àÓ¤X›K#0>0!0 ??+?8ÔôÑ?ÉÚºûëÕ¤ HTê?Ÿ??¡Þ…
ßü…HÜ&BŒàËð„„>† 

=
== File: 

=
0‚
0‚  Ò?  *†H†÷
??? ‚   Ã?‚ ¿0‚ »0‚?g?  *†H†÷
??? ‚?X?‚?T0‚?P0‚?L??*†H†÷
??
?? ‚?û0‚?÷0)?
*†H†÷
0???5?“s?Lù‹nbáQ%ÔÍ?£?á???ÃP?‚?È}‡N%M/5fє?D¹-™ÝîUÈy©? QÔÜ
lÿçtÂãn@u‚ùÁù×2V{ ™Þ–ÅÉÁò,áf6…î´ðÞ!á?ƒ>íô Þ>‡ïßv’Î?<)ˆû>?i&§Æ¡„ÐÆU}O?‡É¡©„
Æôɐ*®‹Õß?U?ÛÓ´"UûMØ–?i¼$þ@Õe®?±m?kâAFW>¦þIº??¬õè?h"Ü?ƒb¥&»%yÈúÔ?Q?ë2Ñ%¦Ô†Çµ\?&
ò@è¤÷mfjÏÒ«]=‰É
?—?–÷ìµxůxkB?û™¥?2?‹¤?GØÞu_
-tëL±BO³,?Àé¥??ˤ`î˜í2Ôu‹?]a!u
o?Fø\ÂÐÏ?e³
·+¨??¸dn?6“?ƒxÄ??­0½x??.Um?Ø"Â
8?Ë4_??è@??:³ßühdðº¶6æ±?‹‰RÐ^Ÿîò˦g–3ñÌ,»aô녰œúpé4Tq²I‡i<â\?2?˜?˜??”ªdxþàb
iRc•|Œ¸wšV?©úœµf
9]?p¸?橀ß#¿î|&›¸2BCÒ%!¡??dK½î™»­??0ûP?³¼?„´3Ñ"?wR¤Ek[Ô脚.¤‰(Ä|]?ô?’^­ÏèWñ&Üxç´:´”?Õ
   
Í"ŽI–"ô|ýéÞ·;µ•Ô}¹??2F?(à²z[Ž‰Pcͼ?z¸`?Cž¡àKn?Lተ¢Í?~Ä?z×6÷áW¶??³?މ&afø"fm3û(?K*ÏcWÅÒwÍé´Wؖ?-§uL?¥b_à@s&؛eÞ?G?04ÿ'°œ?aÄgq!¥È?à¸ñ¡?'`÷¢-*?d÷‹½ßÒ¦"Š‹AoÛ»¢)l+ýº’?•:mÓ¶d’»??º7i±´º¢¯N¯u,??äÓfw?¸ûÉ?8d毿uÿ4?®Šr­/X?;wø²Í'W÷SM4æчԥÍÏTG¦‚’w[?"•mÁm¸îŠB°Œs\¢^ë?Äk?Ì}?3'Ô°“˜¤§{ÑMX©ŒY0Y8·ÙÏmÞñ
 þ???¿·
Ê?4`ÒĹH±X«„‘ÀãíŽóóÚçe•õ4õ¥
XÊÔ?֗Wx?x-¨š[@·ù°Õ{T k>&˜˜‚n"?ďÇƼ’N„üD=¸wÊ才Ç?•} ý݅
vzœ{?$K@M?Þßî¾Á?‚Rž?É»tý2m´A²eÀ$.F?þ›._-?ï“?f†?%cZšY?þ9%)b…k¢g™ß1>0?? *†H†÷
?   ?1??
?m?y?k?e?y0!?   *†H†÷
?   ?1???Time 15270978378910‚?L?*†H†÷
??? ‚?=0‚?9???0‚?2? *†H†÷
???0)?
*†H†÷
0???’M©o©?›k?³?ÂщÀ?xc?ü¥f1??+4†^Á×¥?ã³?Â\ò?áý³ÓÅ?Ìãþ„u'é??㫝õ¹ÉO¹¥
 }êÅð×?Nq.ìÃØËф¡öÊ@FÅ4û^ï“Q8Õ­½Cř©æ?
?JÝ(Df¦?Êóm·3Ûäã ùµyÌ@
Ƕ0!?>qΨH‚N?…Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IəD ??õÓân„û?¤©}P}@,*op4
”?ç;·¯‚Ü?zþÉoo…?àäVmà?{?&º#ŠB’gùòx?ËnC7×x—ÁúÜúÆh1A2ˆÔ§·?ÈJð ObßMÖëP
?‹ˆ_`?Úz-$z<¯?ƒ¨ˆ?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uE‰kræρ?1±ÀÄÓ?K±ˆ:?ƒ_Z7-J9l0ýò<8Ò«??š9€Ñ«“?þ46´W?!pC´“ûãŒ?rwjõ?–˜r¬ërþ?÷ÆSŸ½vבDrü±Oà$‡€?ôûÿò„?ó‰
 "Ðó0Læ; 
˜×R›?Çäþ£¸·“ªÓoòÙÌúÕt7$Ä??Õ??

[activemq-artemis] branch master updated: ARTEMIS-2290 JMSBridgeImpl::stop is failing when called from FailureHandler

[jbertram]

This is an automated email from the ASF dual-hosted git repository.

jbertram 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 dc1cfa3  ARTEMIS-2290 JMSBridgeImpl::stop is failing when called from 
FailureHandler
 new b62e081  This closes #2598
dc1cfa3 is described below

commit dc1cfa3536087d8dd29b5462775e8a95809ed883
Author: Francesco Nigro 
AuthorDate: Tue Mar 19 12:10:07 2019 +0100

ARTEMIS-2290 JMSBridgeImpl::stop is failing when called from FailureHandler
---
 .../artemis/jms/bridge/impl/JMSBridgeImpl.java | 428 +
 1 file changed, 272 insertions(+), 156 deletions(-)

diff --git 
a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
 
b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
index a5e1c0e..2da550b 100644
--- 
a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
+++ 
b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
@@ -45,13 +45,16 @@ import java.util.LinkedList;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.ServiceLoader;
+import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.activemq.artemis.api.core.ActiveMQException;
 import org.apache.activemq.artemis.api.core.ActiveMQInterruptedException;
+import org.apache.activemq.artemis.api.core.Pair;
 import org.apache.activemq.artemis.api.core.client.FailoverEventListener;
 import org.apache.activemq.artemis.api.core.client.FailoverEventType;
 import org.apache.activemq.artemis.api.jms.ActiveMQJMSConstants;
@@ -113,8 +116,8 @@ public final class JMSBridgeImpl implements JMSBridge {
 
private boolean started;
 
-   private final Object stoppingGuard = new Object();
-   private boolean stopping = false;
+   private static final Object stoppingGuard = new Object();
+   private volatile boolean stopping = false;
 
private final LinkedList messages;
 
@@ -142,7 +145,13 @@ public final class JMSBridgeImpl implements JMSBridge {
 
private MessageProducer targetProducer;
 
-   private BatchTimeChecker timeChecker;
+   private CountDownLatch batchTimeCheckerFinished;
+
+   private Future batchTimeCheckerTask;
+
+   private CountDownLatch sourceReceiverFinished;
+
+   private Future sourceReceiverTask;
 
private ExecutorService executor;
 
@@ -418,17 +427,25 @@ public final class JMSBridgeImpl implements JMSBridge {
 ActiveMQJMSBridgeLogger.LOGGER.trace("Starting time checker 
thread");
  }
 
- timeChecker = new BatchTimeChecker();
-
- executor.execute(timeChecker);
  batchExpiryTime = System.currentTimeMillis() + maxBatchTime;
 
+ batchTimeCheckerFinished = new CountDownLatch(1);
+
+ batchTimeCheckerTask = executor.submit(new BatchTimeChecker());
+
  if (ActiveMQJMSBridgeLogger.LOGGER.isTraceEnabled()) {
 ActiveMQJMSBridgeLogger.LOGGER.trace("Started time checker 
thread");
  }
+  } else {
+
+ batchTimeCheckerFinished = null;
+
+ batchTimeCheckerTask = null;
   }
 
-  executor.execute(new SourceReceiver());
+  sourceReceiverFinished = new CountDownLatch(1);
+
+  sourceReceiverTask = executor.submit(new SourceReceiver());
 
   if (ActiveMQJMSBridgeLogger.LOGGER.isTraceEnabled()) {
  ActiveMQJMSBridgeLogger.LOGGER.trace("Started " + this);
@@ -451,6 +468,43 @@ public final class JMSBridgeImpl implements JMSBridge {
 
@Override
public void stop() throws Exception {
+  stop(false);
+   }
+
+   private boolean awaitTaskCompletion(CountDownLatch finished, long time, 
TimeUnit timeUnit, String taskName) {
+  boolean taskCompleted;
+  try {
+ taskCompleted = finished.await(time, timeUnit);
+ if (!taskCompleted) {
+ActiveMQJMSBridgeLogger.LOGGER.tracef("%s task on bridge %s wasn't 
able to finish", taskName, bridgeName);
+ }
+ return taskCompleted;
+  } catch (InterruptedException ie) {
+ ActiveMQJMSBridgeLogger.LOGGER.tracef("An interruption has happened 
on bridge %s while waiting %s task to finish", bridgeName, taskName);
+ return false;
+  }
+   }
+
+   private boolean awaitAll(long time, TimeUnit timeUnit, Pair... namedTaskCompletions) {
+  long remainingNanos = timeUnit.toNanos(time);
+  boolean allFinished = true;
+  for (Pair namedTaskCompletion : 
namedTaskCompletions) {
+ final CountDownLatch taskCompletion = namedTaskCompletion.getB();
+ if (taskCompletion != null) {
+final String taskName = named

[activemq-artemis] branch master updated: ARTEMIS-2291 ClassCastException on JMSBridgeImpl::stop leaks bridge resources

[jbertram]

This is an automated email from the ASF dual-hosted git repository.

jbertram 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 34c8ed2  ARTEMIS-2291 ClassCastException on JMSBridgeImpl::stop leaks 
bridge resources
 new affb6a4  This closes #2597
34c8ed2 is described below

commit 34c8ed2adb08f879b4925cc83409868c199fbdd1
Author: Francesco Nigro 
AuthorDate: Fri Mar 29 17:14:26 2019 +0100

ARTEMIS-2291 ClassCastException on JMSBridgeImpl::stop leaks bridge 
resources
---
 .../artemis/jms/bridge/impl/JMSBridgeImpl.java | 32 ++
 1 file changed, 27 insertions(+), 5 deletions(-)

diff --git 
a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
 
b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
index b1e7e12..a5e1c0e 100644
--- 
a/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
+++ 
b/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
@@ -533,12 +533,34 @@ public final class JMSBridgeImpl implements JMSBridge {
   }
}
 
-   private void stopSessionFailover() {
-  XASession xaSource = (XASession) sourceSession;
-  XASession xaTarget = (XASession) targetSession;
+   private static void releaseCommunications(Session session, String 
sessionName) {
+  final XASession xaSession = (XASession) session;
+
+  if (xaSession.getXAResource() instanceof ClientSessionInternal) {
+ try {
+((ClientSessionInternal) 
xaSession.getXAResource()).getSessionContext().releaseCommunications();
+ } catch (Throwable t) {
+ActiveMQJMSBridgeLogger.LOGGER.warnf(t, "Cannot release 
communications on %s", sessionName);
+ }
+  } else {
+ if (ActiveMQJMSBridgeLogger.LOGGER.isTraceEnabled()) {
+ActiveMQJMSBridgeLogger.LOGGER.tracef("Cannot cast XAResource of 
%s to ClientSessionInternal and release communications: found class %s",
+  sessionName, 
xaSession.getClass().getCanonicalName());
+ }
+  }
+   }
 
-  ((ClientSessionInternal) 
xaSource.getXAResource()).getSessionContext().releaseCommunications();
-  ((ClientSessionInternal) 
xaTarget.getXAResource()).getSessionContext().releaseCommunications();
+   private void stopSessionFailover() {
+  try {
+ releaseCommunications(sourceSession, "sourceSession");
+  } catch (Throwable t) {
+ ActiveMQJMSBridgeLogger.LOGGER.error("cannot release communications 
on sourceSession ", t);
+  }
+  try {
+ releaseCommunications(targetSession, "targetSession");
+  } catch (Throwable t) {
+ ActiveMQJMSBridgeLogger.LOGGER.error("cannot release communications 
on targetSession ", t);
+  }
}
 
@Override