date:20190313

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

2019-03-13 Thread Apache Jenkins Server

See 


Changes:

[clebertsuconic] ARTEMIS-2229 turns out a valid bug. So restore the fix commit.

--
[...truncated 1.29 MB...]
:2?|???ÃP?øõ?DV
©jéäDý9Oô[Ìqw=ã?/Ò7?fê?ÈÎöd[Lr÷l³¬þwE
¶C?Z´gé2Ë^?W;\°´y?ÉQºëyò?1C8  
þ}4¤£ÒTü`Ý´?%übÉåq?¡9LuÀ?¢ôËêá?+PÅbÎ=>ÑÀ?xc?ü¥f1??+4^Á×¥?ã³?Â\ò?áý³ÓÅ?Ìãþu'é??ã«õ¹ÉO¹¥
 }êÅð×?Nq.ìÃØËÑ¡öÊ@FÅ4û^ïQ8Õ½CÅ©æ?
?JÝ(Df¦?Êóm·3Ûäã ùµyÌ@
Ç¶0!?>qÎ¨HN?Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IÉD ??õÓânû?¤©}P}@,*op4
?ç;·¯Ü?zþÉoo?àäVmà?{?&º#Bgùòx?ËnC7×xÁúÜúÆh1A2Ô§·?ÈJð ObßMÖëP
?_`?Úz-$z<¯?¨?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uEkræÏ?1±ÀÄÓ?K±:?_Z7-J9l0ýò<8Ò«??9Ñ«?þ46´W?!pC´ûã?rwjõ?r¬ërþ?÷ÆS½v×Drü±Oà$?ôûÿò?ó
 "Ðó0Læ; 
×R?Çäþ£¸·ªÓoòÙÌúÕt7$Ä??Õ??õ??Èò[û¢àÝ}?óô?õO¸J[î>f1m?§ÖxLì?9?#¸Ä¡¼½@ÆI
 ñ?§zße²3U®Ùy¦sÕÔ¿<¢L?²n??9ÚÝE?¿½ÙûA@æ?S¨?N¥§ª&uKçX·?Û{5ißf 
ÝÕ4::ÚøéÙÌa.À??ýWÚ'?[À]+õÇ)gÕf>°§)×ªäN?¢
ÁÈ?YOQQDs¬
. 
jÒßPÆéÐø?x¯¥!4)S?¶??=/?q8:??Þ¢ª?T·ÛCÇÊÀÀN+]??{ÈZ»»?ò:?#©ÜÔ?:/?QNRjr=??:?M~Àì'I^çÍÙ?D¿Ub\?ÆíóµR¬uý±°õÝ
óÛ?Öæ¶?âÀ?ÞI.ÉQ°1bPøô®*[&"A?Nö2?K¾jÍ5s?Þøñ:ëqxV÷Ïá>ã
ñD?
Òy¹)»?
q÷n7?{QW??NVïéKíî?ì»?¥.ö©ïCN½îÄ^?Èk¢+?QÍ??ªÙ]d®ÿ'éæw?7¡0>0!0  
??+d?Ë.´??}GWJAÚ$£6¤Ñ??oPåØ'\ØãY÷GÈ
FÃ??? 

=
== File: 

=
0?¦???0?_?*H÷
??? ?P??L0?H0?D?*H÷
??? ?50?1???0?*? *H÷
???0)?
*H÷
0???ø?Áûä
ÏOL?¿?å}¦UÃP?ð/?k+³0ËB\*Æ`ë&#¨è?ÎÍ4àFr?²òsûo$^°Ø±Ø¼µjãbñA?ï?õ`uÙË?Í3Èû
 <þôÑøa?XÌpÄ4ÂOÍME!äHv0}ßéqª¼ëå?)-*.ÕÃ@$ß[S?NxÜé?b
d¯¾Ivl?ûf±xãöÿ`?æGkfª=[sdÎ©ñ?W+®éÜü?FÀ{?vW?.®y±³L´øCò_A  
3ÊõwÓFô¿äø}x»?§;ð`??ÖÌ
ø???M½P%
è,¯??ì?C´¾ê^8
{çíØFùbÜ{þ¬ò?¦¢Fà?¬?¡xÌ{>}ïà>??(?rxLí?û·ãÝ?màTÖó³jñe??Â-?ù¦cèBCÛhn?/»MLøc¦ÞÔð¢?LÙÌU4=ÓxómÜ?Açi??Òþ?*A
áC??Û=L£Gôj?ñËÓ>kD"??äB{?³?þ¬ùk3K´Î?.oÙH*KDr¨¢eØ@7*Uuc}¸¤´~~Äß·ì¢?7B$¶À_¯r¼?AøP:þá*Kó9þ©Â?kÛE·<óR¦ø?ý?=\ótúº?ÂUèÌ'"²À«?KzÿÕ?Ç7á?ânÝïs
?~¨;ÛÖ  :gàFÿtøÌîóÁ?÷Dz>!b£Á/?~<
`½ÉæÞmÝ´[?ì?Zs:ÈÃ?/ûÿd,?ÆA ÀCá?ÆB
pòi?&]Ìtøw?ñç?òì?â\ñÛgÕ´08«PLz?A^,r?o¶Ûm?íd?X±Ü
0¡÷m+?âü?H¸)??¬ÿÁsg^ñv;H?0\f×ìb-su?ÑKåAÙo'?<ß¯¹ñ&Fi{B¼Å»?
*¾Ñ~Ñ(
vÏªuIYE?§¨?ÚÈDN6Ø²e?oj??Ûÿnü&Nº?Hì 
d¨Ð4F´A[:«?g·¬?DvÄ÷*V?eéÐxê?øz¹5Fâü£= 
?aýÔ©?0åÑ5%ó?N+h¤?¶`.0¡~0??§Â??ç%Î?O?_ãGU³t-Í8¦_;qóºv+jz%¨ïèÚadpQAóoÂ²ýÎ8uûKz?\À??ÐiX²0b?ØÞXb
 ÐÈC´,·¢ë¾ÙJãub}Ø*ò?jÅ$¤µË+ÚýÊáhÐ??)R>º¶¦(À 
êË$¿2w«?Äe?29¥?½õ¸¨ô?,giï]ÄÎþ6`üD$?x;$Yv¨½ë?o?]Rk²QÉ¶®=ÂP0>0!0 
??+¶Wgfh?ô??f?ÊD?Äd,?Ä??ËCB Îî):f&Éú>üÿ!´??? 

=
== File: 

=
0?¦???0?_?*H÷
??? ?P??L0?H0?D?*H÷
??? ?50?1???0?*? *H÷
???0)?
*H÷
0???V?«OéÛ[f¾=¶!f?ëc???ÃP?ð??½Fàù?zb|Ú?páºÀ1?qk??ÜFpt¦??Âbá
sQÀxgºÆÂRÈô
Ã?wi?õ?7ïL?iõ¡#þ8÷o29?zEhu$?{@'m£?¿yÿKí>á 
Sg'9JÓ???ßµàR=p!Õ#$ÇPn»|ÔÖmaË'jU¯fh?Ù$!±®?¶áª?R·ÔWØv·?Ñc±¤=HÍ:¶nhú/Ç8Ó£#ó?9à
 
ªUHÕ¨?Ö]pzæÈ©e?Õgù%5¢<ìþBm??âÜ¸,[(ÛÅ?ëC²?hVM"¡ð?#zïpsÊpÖ«usjsS?OéásþÍ×í?H?o?Tü-yäòìÿUsKEÜç?ý{ëÁ)³h7ÑK?uâEÔ3®í
ªv?ìú_oCË3?®.fÍ}`t?ç?|ª"°z¤?   'â6??²£u5ë_£v?-
õFøÑvSjæÎ9ú?ï_gú
95?¡0#Î¿±XX?ýú?f°Q?ÑÀs¯???+³æDL`smZÂYFS?ðb½ôzO2ZyE¿?¡§¶I
mÍ£M7Jü0,¾8z
ýÂ£äìæJÌKÎèà U¤9ØÚ[ÂGjáÿ&+?!¶?lz9«),÷µÙ?u? ??#Ò^?²?1Çìj¤ú
Õj.o®Ô/<>ZH!?LÔÑDU#yÈ.-¯qeh[¡Ê<æå/hÞÃöR?X.;øÙÅ,¾ù!?×¡AÄ¸´E[åÞÊ=$,rúfó?}¾Ì(j?ÝW´Ò©¤ûø:ím/vÌÿIi»U\?û?
oQôò¯Ó¸??î>B"?FSË{d?>[±¼? #6/ 
wÒh¡·?§²((ÿî8!J632¡?Ï$û?íù?âbV?wD^?:ç0>0!0
??+¨?±Åò©8m\*ËÿöJã¾ø??ôz5è&óÆ=rÆ?§ 

=
== 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ÖUpÁø*+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ß+ë?OAw?ö)Xt
 ?éf]É?!.&ÁTSð ³&¡Y 
ÕgLm?¢q×m8I?þ¢ÏØm??oå]ÙÉÑ¾=ª]d?tpçë#©ÚÑàH+Æã¥éhaÁ$ñ?¬=??e?Ms 
àÓ¤XK#0>0!0 ??+?8ÔôÑ?ÉÚºûëÕ¤ HTê???¡Þ
ßüHÜ&BàËð> 

=
== File:

[activemq-artemis] branch master updated: ARTEMIS-2229 turns out a valid bug. So restore the fix commit.

2019-03-13 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 9f7d23c  ARTEMIS-2229 turns out a valid bug. So restore the fix commit.
 new 3b3a8c2  This closes #2583
9f7d23c is described below

commit 9f7d23c36c6bb052170e45206cd4913b52e0c8a2
Author: Howard Gao 
AuthorDate: Wed Mar 13 18:34:20 2019 +0800

ARTEMIS-2229 turns out a valid bug. So restore the fix commit.

this was reverted previously on commit 
f4436a9f72afeb8117ecd6e377df8198eeec9aa3.

It seems it is ok after further changes into FQQN, so this is being 
reapplied
---
 .../protocol/amqp/broker/AMQPSessionCallback.java  |  7 +++--
 .../amqp/proton/ProtonServerSenderContext.java | 10 +--
 .../amqp/AmqpFullyQualifiedNameTest.java   | 34 ++
 3 files changed, 47 insertions(+), 4 deletions(-)

diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java
index 63f5521..f850cc1 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java
@@ -289,8 +289,11 @@ public class AMQPSessionCallback implements 
SessionCallback {
   }
 
   // if auto-create we will return whatever type was used before
-  if (queueQueryResult.isExists() && !queueQueryResult.isAutoCreated() && 
queueQueryResult.getRoutingType() != routingType) {
- throw new IllegalStateException("Incorrect Routing Type for queue, 
expecting: " + routingType);
+  if (queueQueryResult.isExists() && !queueQueryResult.isAutoCreated()) {
+ //if routingType is null we bypass the check
+ if (routingType != null && queueQueryResult.getRoutingType() != 
routingType) {
+throw new IllegalStateException("Incorrect Routing Type for queue, 
expecting: " + routingType);
+ }
   }
 
   return queueQueryResult;
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 60d5a5a..580c4ce 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
@@ -347,7 +347,10 @@ public class ProtonServerSenderContext extends 
ProtonInitializable implements Pr
 if (multicast && !routingTypes.contains(RoutingType.MULTICAST)) {
throw new ActiveMQAMQPIllegalStateException("Address " + 
addressToUse + " is not configured for topic support");
 } else if (!multicast && 
!routingTypes.contains(RoutingType.ANYCAST)) {
-   throw new ActiveMQAMQPIllegalStateException("Address " + 
addressToUse + " is not configured for queue support");
+   //if client specifies fully qualified name that's allowed, 
don't throw exception.
+   if (queueNameToUse == null) {
+  throw new ActiveMQAMQPIllegalStateException("Address " + 
addressToUse + " is not configured for queue support");
+   }
 }
  } else {
 // if not we look up the address
@@ -445,7 +448,10 @@ public class ProtonServerSenderContext extends 
ProtonInitializable implements Pr
 }
  } else {
 if (queueNameToUse != null) {
-   SimpleString matchingAnycastQueue = 
getMatchingQueue(queueNameToUse, addressToUse, RoutingType.ANYCAST);
+   //a queue consumer can receive from a multicast queue if it 
uses a fully qualified name
+   //setting routingType to null means do not check the 
routingType against the Queue's routing type.
+   routingTypeToUse = null;
+   SimpleString matchingAnycastQueue = 
getMatchingQueue(queueNameToUse, addressToUse, null);
if (matchingAnycastQueue != null) {
   queue = matchingAnycastQueue;
} else {
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFullyQualifiedNameTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpFullyQualifiedNameTest.java
index b9adc59..ba9ff23 100644
--- 
a/tests/int

buildbot success in on activemq-site-production

2019-03-13 Thread 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/32389

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

Jenkins build is back to normal : ActiveMQ-Artemis-Master #2305

2019-03-13 Thread Apache Jenkins Server

See

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

2019-03-13 Thread Apache Jenkins Server

See 


Changes:

[clebertsuconic] ARTEMIS-2274 Test showing issue with Message overflowing 
buffer when

[clebertsuconic] ARTEMIS-2274 Fix on Journal buffer overflow with almost large 
messages

--
[...truncated 1.29 MB...]
ÏOL?¿?å}¦UÃP?ð/?k+³0ËB\*Æ`ë&#¨è?ÎÍ4àFr?²òsûo$^°Ø±Ø¼µjãbñA?ï?õ`uÙË?Í3Èû
 <þôÑøa?XÌpÄ4ÂOÍME!äHv0}ßéqª¼ëå?)-*.ÕÃ@$ß[S?NxÜé?b
d¯¾Ivl?ûf±xãöÿ`?æGkfª=[sdÎ©ñ?W+®éÜü?FÀ{?vW?.®y±³L´øCò_A  
3ÊõwÓFô¿äø}x»?§;ð`??ÖÌ
ø???M½P%
è,¯??ì?C´¾ê^8
{çíØFùbÜ{þ¬ò?¦¢Fà?¬?¡xÌ{>}ïà>??(?rxLí?û·ãÝ?màTÖó³jñe??Â-?ù¦cèBCÛhn?/»MLøc¦ÞÔð¢?LÙÌU4=ÓxómÜ?Açi??Òþ?*A
áC??Û=L£Gôj?ñËÓ>kD"??äB{?³?þ¬ùk3K´Î?.oÙH*KDr¨¢eØ@7*Uuc}¸¤´~~Äß·ì¢?7B$¶À_¯r¼?AøP:þá*Kó9þ©Â?kÛE·<óR¦ø?ý?=\ótúº?ÂUèÌ'"²À«?KzÿÕ?Ç7á?ânÝïs
?~¨;ÛÖ  :gàFÿtøÌîóÁ?÷Dz>!b£Á/?~<
`½ÉæÞmÝ´[?ì?Zs:ÈÃ?/ûÿd,?ÆA ÀCá?ÆB
pòi?&]Ìtøw?ñç?òì?â\ñÛgÕ´08«PLz?A^,r?o¶Ûm?íd?X±Ü
0¡÷m+?âü?H¸)??¬ÿÁsg^ñv;H?0\f×ìb-su?ÑKåAÙo'?<ß¯¹ñ&Fi{B¼Å»?
*¾Ñ~Ñ(
vÏªuIYE?§¨?ÚÈDN6Ø²e?oj??Ûÿnü&Nº?Hì 
d¨Ð4F´A[:«?g·¬?DvÄ÷*V?eéÐxê?øz¹5Fâü£= 
?aýÔ©?0åÑ5%ó?N+h¤?¶`.0¡~0??§Â??ç%Î?O?_ãGU³t-Í8¦_;qóºv+jz%¨ïèÚadpQAóoÂ²ýÎ8uûKz?\À??ÐiX²0b?ØÞXb
 ÐÈC´,·¢ë¾ÙJãub}Ø*ò?jÅ$¤µË+ÚýÊáhÐ??)R>º¶¦(À 
êË$¿2w«?Äe?29¥?½õ¸¨ô?,giï]ÄÎþ6`üD$?x;$Yv¨½ë?o?]Rk²QÉ¶®=ÂP0>0!0 
??+¶Wgfh?ô??f?ÊD?Äd,?Ä??ËCB Îî):f&Éú>üÿ!´??? 

=
== File: 

=
0????0???*H÷
??? ?0??,0?(0?$?*H÷
??? ??0?0?
?   *H÷
???0)?
*H÷
0???æå!Rj7Î}?Ïy~©Óÿ?}ð?v???ÃP?Ð7ÆÛS!Æ
÷?È-ÆÜ?ÆU½î?)9nD?ÖèÙHB[»
ã¬ÔoçmÐqéùt¶Í:Éðßö" zPJVîQ(he%y¤RqÁ >8??{eS¤CùÙ©h×í'Ñ©¢~z?)½OÓÚ:nn,?ö 
tÍ4NæÑ.'Ú %a?Ü)&?]?""]?¯_Ï¿Ô 
Éy÷R?2¡Yq¹Èãù@?g¥(??´g¾L`ÔÍ;÷-B|-uøX@uÂ&%²ü|±¨M³ötËÃQ×!$»G?è÷?Í??SÝ3õâ¸ä
 Ð`*An^?µkT/þ£*YÞõ½z8w?ÿVÅ÷?PÂ&%[RÇh·ê+÷BºÂF_ÉH#p?4f?P¿®vÞux2Õg`[?
s:W
7
V?«¢aà'®?ã?NÌÎéw?&¾Øj¡z"%SÉº¼nÂw+lgõ?¦àþê>þ½îø?fÿ
)?pÜ¢?xÐZÕ,t9\¿Wl¦qúQ¨??ëôF*A?â>
)GIl?Æ¨;x[??e/³-¿èûÏ¹Ô²ùÞÆË¡$I5A  
À|?C¨0ô£ÂÑe4°þDÐ!1À¥rËÏßÇY¿Kî{@'g^Ë÷£zÙ|¸h3
4B?ÙX?ìmà?}Ñ#Pó¯RÞ??õGü¯JÞâ`oÂ¼?°BÔdÐ?p3_lÙòîQ??ön7ÞÂí`?©3=L?ÍíNÿj?KG?ª?ÉZ·®þFM¡NäÝèCh.û_¾§
 +nïY¥òhª ÕÏ³~y¤Û¹v[ä®?I#®±u??{¨¥§ ±×ÏçZ?§BN
àBvçÝTMû]b]ï¦²»¢1D*U{?ÁÓÕÝv£GiÄãþ]?dðjýøjKåa`MÇ9ð)ïhÒ?-0eÞ°åØ9?Ï¨7¥?n?=nÉÕñ¸
þ?Ù#_ø?½4Ú#KÊûcì*)«3òqWï²±*:V.éo¼??Ñåî~?àpß*Krz-NuæÐwêÁ.6ñ§?:ï 
AJÕ?í?QÑ?úH?(DÀ+5?à)8îhtO|¤pê@Æn*?K?WÁ?ÇNH+ì´Ìæó´È?^º_må
cÒFb(?¹Eu@«Òij?:?±Ò?Puc?á~¸?mùkLv?Ê¯dõÖB)Gùn¢¸OÔÚ}'qE*B%a&Ý$h4jÌ:~W{fJýÕº
  N?¢ÑqrÚ°Ä??Æ?)D3?¥?&ËnØà0>0!0   
??+hÀ?ý?ãvK,Íhd?~$¢??ß?w/Ã¹vLß6`êOjûÌã??? 

=
== 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Ð^îòË¦g3ñÌ,»aôë°úpé4Tq²Ii<â\?2????ªdxþàb
iRc|¸wV?©úµ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?%cZY?þ9%)bk¢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Î¨HN?Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IÉD ??õÓânû?¤©}P}@,*op4
?ç;·¯Ü?zþÉoo?àäVmà?{?&º#Bgùòx?ËnC7×xÁúÜúÆh1A2Ô§·?ÈJð ObßMÖëP
?_`?Úz-$z<¯?¨?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uEkræÏ?1±ÀÄÓ?K±:?_Z7-J9l0ýò<8Ò«??9Ñ«?þ46´W?!pC´ûã?rwjõ?r¬ërþ?÷ÆS½v×Drü±Oà$?ôûÿò?ó
 "Ðó0Læ; 
×R?Çäþ£¸·ªÓoòÙÌúÕt7$Ä??Õ??õ??Èò[û¢àÝ}?óô?õO¸J[î>f1m?§ÖxLì?9?#¸Ä¡¼½@ÆI
 ñ?§zße²3U®Ùy¦sÕÔ¿<¢L?²n??9ÚÝE?¿½ÙûA@æ?S¨?N¥§ª&uKçX·?Û{5ißf

[activemq-artemis] branch master updated: NO-JIRA More general test fixes

2019-03-13 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 e217f9a  NO-JIRA More general test fixes
e217f9a is described below

commit e217f9ab6c3b76dfda38cb3db694429e97eab67b
Author: Clebert Suconic 
AuthorDate: Wed Mar 13 15:26:48 2019 -0400

NO-JIRA More general test fixes
---
 .../artemis/tests/integration/addressing/AddressingTest.java| 2 +-
 .../activemq/artemis/tests/integration/client/LargeMessageTest.java | 5 +++--
 .../tests/integration/management/ActiveMQServerControlTest.java | 6 +-
 3 files changed, 9 insertions(+), 4 deletions(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AddressingTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AddressingTest.java
index 550adbe..37e365b 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AddressingTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/addressing/AddressingTest.java
@@ -264,7 +264,7 @@ public class AddressingTest extends ActiveMQTestBase {
   producer.send(session.createMessage(true));
   session.createConsumer(queueName).close();
   assertNotNull(server.locateQueue(queueName));
-  assertEquals(1, server.locateQueue(queueName).getMessageCount());
+  Wait.assertEquals(1, server.locateQueue(queueName)::getMessageCount);
}
 
@Test
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java
index eac724c..84727f6 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/LargeMessageTest.java
@@ -51,6 +51,7 @@ import 
org.apache.activemq.artemis.tests.integration.IntegrationTestLogger;
 import 
org.apache.activemq.artemis.tests.integration.largemessage.LargeMessageTestBase;
 import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
 import org.apache.activemq.artemis.tests.util.RandomUtil;
+import org.apache.activemq.artemis.tests.util.Wait;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
@@ -2545,9 +2546,9 @@ public class LargeMessageTest extends 
LargeMessageTestBase {
 
   session.commit();
 
-  Assert.assertEquals(0, 
server.getPagingManager().getPageStore(ADDRESS).getAddressSize());
+  Wait.assertEquals(0, 
server.getPagingManager().getPageStore(ADDRESS)::getAddressSize);
 
-  Assert.assertEquals(0, server.getPagingManager().getGlobalSize());
+  Wait.assertEquals(0, server.getPagingManager()::getGlobalSize);
 
   session.close();
 
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
index 36ad5fb..e2e8607 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/ActiveMQServerControlTest.java
@@ -1716,7 +1716,11 @@ public class ActiveMQServerControlTest extends 
ManagementTestBase {
   Assert.assertEquals("messagesAcked", "0", 
array.getJsonObject(0).getString("messagesAcked"));
   Assert.assertEquals("deliveringCount", "0", 
array.getJsonObject(0).getString("deliveringCount"));
   Assert.assertEquals("messagesKilled", "0", 
array.getJsonObject(0).getString("messagesKilled"));
-  Assert.assertEquals("deliverDeliver", "false", 
array.getJsonObject(0).getString("deliverDeliver"));
+  String resultDirectDeliver = 
array.getJsonObject(0).getString("deliverDeliver");
+  // if there is a core consumer, the result here would be true (if 
directDeliver is supported).
+  // as for what we expect it's either true or false through management, 
we are not testing for directDeliver here, just
+  // if management works.
+  Assert.assertTrue(resultDirectDeliver.equals("true") || 
resultDirectDeliver.equals("false"));
 
}

buildbot failure in on activemq-site-production

2019-03-13 Thread 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/32386

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

[activemq-artemis] 01/03: ARTEMIS-2274 Test showing issue with Message overflowing buffer when sizes are too close to TimedBuffer size

2019-03-13 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 b672cc3ad97da7ae0ffcff8dbf24c2aad5c3f174
Author: yb <17061...@cn.suning.com>
AuthorDate: Wed Mar 13 10:43:44 2019 +0800

ARTEMIS-2274 Test showing issue with Message overflowing buffer when sizes 
are too close to TimedBuffer size
---
 .../unit/core/message/impl/MessageImplTest.java| 59 ++
 1 file changed, 59 insertions(+)

diff --git 
a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/message/impl/MessageImplTest.java
 
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/message/impl/MessageImplTest.java
index e88097a..9fd4469 100644
--- 
a/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/message/impl/MessageImplTest.java
+++ 
b/tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/message/impl/MessageImplTest.java
@@ -24,9 +24,18 @@ import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
 import org.apache.activemq.artemis.api.core.ICoreMessage;
 import org.apache.activemq.artemis.api.core.Message;
 import org.apache.activemq.artemis.api.core.SimpleString;
+import org.apache.activemq.artemis.api.core.client.ClientConsumer;
+import org.apache.activemq.artemis.api.core.client.ClientMessage;
+import org.apache.activemq.artemis.api.core.client.ClientProducer;
+import org.apache.activemq.artemis.api.core.client.ClientSession;
+import org.apache.activemq.artemis.api.core.client.ClientSessionFactory;
+import org.apache.activemq.artemis.api.core.client.ServerLocator;
 import org.apache.activemq.artemis.core.client.impl.ClientMessageImpl;
+import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
 import org.apache.activemq.artemis.core.message.impl.CoreMessage;
 import 
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendMessage;
+import org.apache.activemq.artemis.core.server.ActiveMQServer;
+import org.apache.activemq.artemis.junit.Wait;
 import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
 import org.apache.activemq.artemis.utils.RandomUtil;
 import org.junit.Assert;
@@ -336,6 +345,56 @@ public class MessageImplTest extends ActiveMQTestBase {
   buf.writeBytes(new byte[1024]);
}
 
+   @Test
+   public void testCloseCallBuffer() throws Exception {
+
+  SimpleString ADDRESS = new SimpleString("SimpleAddress");
+
+  final int messageSize = 1024 * 1024 - 64;
+
+  final int journalsize = 10 * 1024 * 1024;
+
+  ServerLocator locator = createInVMNonHALocator();
+
+  locator.setMinLargeMessageSize(1024 * 1024);
+
+  ClientSession session = null;
+
+  ConfigurationImpl config = (ConfigurationImpl)createDefaultConfig(false);
+  config.setJournalFileSize(journalsize).setJournalBufferSize_AIO(1024 * 
1024).setJournalBufferSize_NIO(1024 * 1024);
+
+  ActiveMQServer server = createServer(true, config);
+
+  server.start();
+
+  ClientSessionFactory sf = 
addSessionFactory(createSessionFactory(locator));
+
+  session = addClientSession(sf.createSession(false, false, 0));
+
+  session.createQueue(ADDRESS, ADDRESS, true);
+
+  ClientProducer producer = session.createProducer(ADDRESS);
+
+  ClientConsumer consumer = session.createConsumer(ADDRESS);
+
+  ClientMessage clientFile = session.createMessage(true);
+  for (int i = 0; i < messageSize; i++) {
+ clientFile.getBodyBuffer().writeByte(getSamplebyte(i));
+  }
+
+  producer.send(clientFile);
+
+  session.commit();
+
+  session.start();
+
+  ClientMessage msg1 = consumer.receive(1000);
+
+  Wait.assertTrue(server::isActive);
+
+  assertNotNull(msg1);
+   }
+
// Protected 
---
// Private 
--

[activemq-artemis] 02/03: ARTEMIS-2274 Fix on Journal buffer overflow with almost large messages

2019-03-13 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 828a4856da83ae11ecdee2f87face0f1f624b049
Author: Clebert Suconic 
AuthorDate: Wed Mar 13 14:55:22 2019 -0400

ARTEMIS-2274 Fix on Journal buffer overflow with almost large messages
---
 .../org/apache/activemq/artemis/core/io/buffer/TimedBuffer.java | 2 +-
 .../core/persistence/impl/journal/LargeServerMessageImpl.java   | 6 +-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/buffer/TimedBuffer.java
 
b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/buffer/TimedBuffer.java
index d49f930..942f88c 100644
--- 
a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/buffer/TimedBuffer.java
+++ 
b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/io/buffer/TimedBuffer.java
@@ -244,7 +244,7 @@ public final class TimedBuffer extends 
CriticalComponentImpl {
 }
 
 if (sizeChecked > bufferSize) {
-   throw new IllegalStateException("Can't write records bigger 
than the bufferSize(" + bufferSize + ") on the journal");
+   throw new IllegalStateException("Can't write records (size=" + 
sizeChecked + ") bigger than the bufferSize(" + bufferSize + ") on the 
journal");
 }
 
 if (bufferLimit == 0 || buffer.writerIndex() + sizeChecked > 
bufferLimit) {
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java
index 42a76be..153c583 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java
@@ -42,13 +42,17 @@ import io.netty.buffer.Unpooled;
 
 public final class LargeServerMessageImpl extends CoreMessage implements 
LargeServerMessage {
 
+   // When a message is stored on the journal, it will contain some header and 
trail on the journal
+   // we need to take that into consideration if that would fit the Journal 
TimedBuffer.
+   private static final int ESTIMATE_RECORD_TRAIL = 512;
+
/** This will check if a regular message needs to be converted as large 
message */
public static Message checkLargeMessage(Message message, StorageManager 
storageManager) throws Exception {
   if (message.isLargeMessage()) {
  return message; // nothing to be done on this case
   }
 
-  if (message.getEncodeSize() > storageManager.getMaxRecordSize()) {
+  if (message.getEncodeSize() + ESTIMATE_RECORD_TRAIL > 
storageManager.getMaxRecordSize()) {
  return asLargeMessage(message, storageManager);
   } else {
  return message;

[activemq-artemis] 03/03: This closes #2581

2019-03-13 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 3a3be57fd3b84c8b2e8b5db3da111d49e0ababb4
Merge: 3ccf6a8 828a485
Author: Clebert Suconic 
AuthorDate: Wed Mar 13 15:03:52 2019 -0400

This closes #2581

 .../artemis/core/io/buffer/TimedBuffer.java|  2 +-
 .../impl/journal/LargeServerMessageImpl.java   |  6 ++-
 .../unit/core/message/impl/MessageImplTest.java| 59 ++
 3 files changed, 65 insertions(+), 2 deletions(-)

[activemq-artemis] branch master updated (3ccf6a8 -> 3a3be57)

2019-03-13 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 3ccf6a8  This closes #2582
 new b672cc3  ARTEMIS-2274 Test showing issue with Message overflowing 
buffer when sizes are too close to TimedBuffer size
 new 828a485  ARTEMIS-2274 Fix on Journal buffer overflow with almost large 
messages
 new 3a3be57  This closes #2581

The 3 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/core/io/buffer/TimedBuffer.java|  2 +-
 .../impl/journal/LargeServerMessageImpl.java   |  6 ++-
 .../unit/core/message/impl/MessageImplTest.java| 59 ++
 3 files changed, 65 insertions(+), 2 deletions(-)

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

2019-03-13 Thread Apache Jenkins Server

See 


Changes:

[clebertsuconic] Revert "ARTEMIS-2240 ActiveMQThreadPoolExecutor should use

--
[...truncated 1.19 MB...]
)???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&zuê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êÅ°´ë¥`Ä¬t3÷õÞ½Û®zfòbÅ¡«7O¥BÚ×#ÑÙÑ?êÇ?.¿??&?÷L'ó/Þ?,?W¹+`?Ã{ÖS¸3ç?ÝÐ@?Õ¿U¸=î?#YAÁ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?l0_z¸0TÐÔò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ÖUpÁø*+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ß+ë?OAw?ö)Xt
 ?éf]É?!.&ÁTSð ³&¡Y 
ÕgLm?¢q×m8I?þ¢ÏØm??oå]ÙÉÑ¾=ª]d?tpçë#©ÚÑàH+Æã¥éhaÁ$ñ?¬=??e?Ms 
àÓ¤XK#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Ð^îòË¦g3ñÌ,»aôë°úpé4Tq²Ii<â\?2????ªdxþàb
iRc|¸wV?©úµ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?%cZY?þ9%)bk¢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Î¨HN?Jþfk?õiRÏç?Xp?l_ÍÙ?gL%¤7ÏßNÀ0fº(´Úê]IÉD ??õÓânû?¤©}P}@,*op4
?ç;·¯Ü?zþÉoo?àäVmà?{?&º#Bgùòx?ËnC7×xÁúÜúÆh1A2Ô§·?ÈJð ObßMÖëP
?_`?Úz-$z<¯?¨?LbjwÎ`Ädlé/dcÑ=1ÛrÊÝçÏ/uEkræÏ?1±ÀÄÓ?K±:?_Z7-J9l0ýò<8Ò«??9Ñ«?þ46´W?!pC´ûã?rwjõ?r¬ërþ?÷ÆS½v×Drü±Oà$?ôûÿò?ó
 "Ðó0Læ; 
×R?Çäþ£¸·ªÓoòÙÌúÕt7$Ä??Õ??õ??Èò[û¢àÝ}?óô?õO¸J[î>f1m?§ÖxLì?9?#¸Ä¡¼½@ÆI
 ñ?§zße²3U®Ùy¦sÕÔ¿<¢L?²n??9ÚÝE?¿½ÙûA@æ?S¨?N¥§ª&uKçX·?Û{5ißf 
ÝÕ4::ÚøéÙÌa.À??ýWÚ'?[À]+õÇ)gÕf>°§)×ªäN?¢
ÁÈ?YOQQDs¬
. 
jÒßPÆéÐø?x¯¥!4)S?¶??=/?q8:??Þ¢ª?T·ÛCÇÊÀÀN+]??{ÈZ»»?ò:?#©ÜÔ?:/?QNRjr=??:?M~Àì'I^çÍÙ?D¿Ub\?ÆíóµR¬uý±°õÝ
óÛ?Öæ¶?âÀ?ÞI.ÉQ°1bPøô®*[&"A?Nö2?K¾jÍ5s?Þøñ:ëqxV÷Ïá>ã
ñD?
Òy¹)»?
q÷n7?{QW??NVïéKíî?ì»?¥.ö©ïCN½îÄ^?Èk¢+?QÍ??ªÙ]d®ÿ'éæw?7¡0>0!0  
??+d?Ë.´??}GWJAÚ$£6¤Ñ??oPåØ'\ØãY÷GÈ
FÃ??? 

=
== File:

[activemq-artemis] branch master updated: Revert "ARTEMIS-2240 ActiveMQThreadPoolExecutor should use LinkedTransferQueue"

2019-03-13 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 79ca203  Revert "ARTEMIS-2240 ActiveMQThreadPoolExecutor should use 
LinkedTransferQueue"
 new 3ccf6a8  This closes #2582
79ca203 is described below

commit 79ca203d6dd529b14dc19086a93bdb8216f1f0f4
Author: Francesco Nigro 
AuthorDate: Wed Mar 13 13:47:06 2019 +0100

Revert "ARTEMIS-2240 ActiveMQThreadPoolExecutor should use 
LinkedTransferQueue"

This reverts commit ea29483449eb74d4bc8ee703e1161c0d67dc77b4
---
 .../artemis/utils/ActiveMQThreadPoolExecutor.java  | 136 +++--
 1 file changed, 101 insertions(+), 35 deletions(-)

diff --git 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ActiveMQThreadPoolExecutor.java
 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ActiveMQThreadPoolExecutor.java
index 628283f..da7de12 100755
--- 
a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ActiveMQThreadPoolExecutor.java
+++ 
b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/ActiveMQThreadPoolExecutor.java
@@ -16,12 +16,11 @@
  */
 package org.apache.activemq.artemis.utils;
 
-import java.util.Objects;
-import java.util.concurrent.LinkedTransferQueue;
-import java.util.concurrent.RejectedExecutionHandler;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
 /*
  * ActiveMQThreadPoolExecutor: a special ThreadPoolExecutor that combines
@@ -30,58 +29,125 @@ import java.util.concurrent.TimeUnit;
  * and will be removed after idling for a specified keep time.
  * But in contrast to a standard cached executor, tasks are queued if the
  * maximum pool size if reached, instead of rejected.
+ *
+ * This is achieved by using a specialized blocking queue, which checks the
+ * state of the associated executor in the offer method to decide whether to
+ * queue a task or have the executor create another thread.
+ *
+ * Since the thread pool's execute method is reentrant, more than one caller
+ * could try to offer a task into the queue. There is a small chance that
+ * (a few) more threads are created as it should be limited by max pool size.
+ * To allow for such a case not to reject a task, the underlying thread pool
+ * executor is not limited. Only the offer method checks the configured limit.
  */
 public class ActiveMQThreadPoolExecutor extends ThreadPoolExecutor {
 
-   /**
-* The default rejected execution handler
-*/
-   private static final RejectedExecutionHandler defaultHandler = new 
AbortPolicy();
+   @SuppressWarnings("serial")
+   private static class ThreadPoolQueue extends LinkedBlockingQueue {
 
-   // Handler executed when a task is submitted and a new thread cannot be 
created (because maxSize was reached)
-   // It queues the task on the executors's queue (using the add() method, see 
ThreadPoolQueue class below)
-   private static class QueueExecutionHandler implements 
RejectedExecutionHandler {
+  private ActiveMQThreadPoolExecutor executor = null;
 
-  private final RejectedExecutionHandler handler;
+  // keep track of the difference between the number of idle threads and
+  // the number of queued tasks. If the delta is > 0, we have more
+  // idle threads than queued tasks and can add more tasks into the queue.
+  // The delta is incremented if a thread becomes idle or if a task is 
taken from the queue.
+  // The delta is decremented if a thread leaves idle state or if a task 
is added to the queue.
+  private static final AtomicIntegerFieldUpdater 
DELTA_UPDATER = AtomicIntegerFieldUpdater.newUpdater(ThreadPoolQueue.class, 
"threadTaskDelta");
+  private volatile int threadTaskDelta = 0;
 
-  private QueueExecutionHandler(RejectedExecutionHandler handler) {
- Objects.requireNonNull(handler);
- this.handler = handler;
+  public void setExecutor(ActiveMQThreadPoolExecutor executor) {
+ this.executor = executor;
   }
 
   @Override
-  public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
- if (executor.isShutdown() || !executor.getQueue().add(r)) {
-handler.rejectedExecution(r, executor);
+  public boolean offer(Runnable runnable) {
+ boolean retval = false;
+
+ if (threadTaskDelta > 0 || (executor.getPoolSize() >= 
executor.getMaximumPoolSize())) {
+// A new task will be added to the queue if the maximum number of 
threads has been reached
+// or if the delta is > 0, which means that there are enough idle 
threads.
+
+retval = super.offer(runnable);
+
+// Onl

buildbot success in on activemq-site-production

2019-03-13 Thread 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/32384

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

2019-03-13 Thread 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/32383

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

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

2019-03-13 Thread Apache Jenkins Server

See

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: Partition Management #1264

2019-03-13 Thread Apache Jenkins Server

See

Jenkins build is still unstable: ActiveMQ-Java8 #1264

2019-03-13 Thread Apache Jenkins Server

See

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: MQTT Protocol #1264

2019-03-13 Thread Apache Jenkins Server

See

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

2019-03-13 Thread Apache Jenkins Server

See 


Changes:

[clebertsuconic] NO-JIRA fixing test failures

--
[...truncated 292.13 KB...]
[INFO] --- dependency-check-maven:1.4.3:check (default) @ artemis-protocols ---
[INFO] Skipping dependency-check
[INFO] 
[INFO] --- maven-install-plugin:2.4:install (default-install) @ 
artemis-protocols ---
[INFO] Installing 

 to 
/home/jenkins/.m2/repository/org/apache/activemq/artemis-protocols/2.7.0-SNAPSHOT/artemis-protocols-2.7.0-SNAPSHOT.pom
[INFO] 
[INFO] 
[INFO] Building ActiveMQ Artemis AMQP Protocol 2.7.0-SNAPSHOT
[INFO] 
[INFO] 
[INFO] --- maven-enforcer-plugin:1.4:enforce (enforce-maven) @ 
artemis-amqp-protocol ---
[INFO] 
[INFO] --- maven-enforcer-plugin:1.4:enforce (enforce-java) @ 
artemis-amqp-protocol ---
[INFO] 
[INFO] --- maven-dependency-plugin:3.1.1:unpack (copy) @ artemis-amqp-protocol 
---
[INFO] Configured Artifact: 
org.apache.activemq:activemq-artemis-native:1.0.0:jar
[INFO] Unpacking 
/home/jenkins/.m2/repository/org/apache/activemq/activemq-artemis-native/1.0.0/activemq-artemis-native-1.0.0.jar
 to 

 with includes "**/*.so" and excludes ""
[INFO] 
[INFO] --- maven-remote-resources-plugin:1.5:process (process-resource-bundles) 
@ artemis-amqp-protocol ---
[INFO] 
[INFO] --- maven-resources-plugin:2.6:resources (default-resources) @ 
artemis-amqp-protocol ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource
[INFO] Copying 3 resources
[INFO] 
[INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ 
artemis-amqp-protocol ---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 76 source files to 

:326:
 warning: [TypeParameterUnusedInFormals] Declaring a type parameter that is 
only used in the return type is a misuse of generics: operations on the type 
parameter are unchecked, it hides unsafe casts at invocations of the method, 
and it interacts badly with method overload resolution. NOTE: correcting this 
issue is often an incompatible API change; you should check that all dependent 
code still compiles succesfully.
   private  T scanForMessageSection(int scanStartPosition, 
Class...targetTypes) {
 ^
(see http://errorprone.info/bugpattern/TypeParameterUnusedInFormals)
  Did you mean 'private Object scanForMessageSection(int scanStartPosition, 
Class...targetTypes) {'?
Note: 

 uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: Some input files use unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
1 warning
[INFO] 
[INFO] --- maven-checkstyle-plugin:2.17:check (default) @ artemis-amqp-protocol 
---
[INFO] Starting audit...
Audit done.
[INFO] 
[INFO] --- apache-rat-plugin:0.12:check (default) @ artemis-amqp-protocol ---
[INFO] Enabled default license matchers.
[INFO] Will parse SCM ignores for exclusions...
[INFO] Finished adding exclusions from SCM ignore files.
[INFO] 61 implicit excludes (use -debug for more details).
[INFO] Exclude: .travis.yml
[INFO] Exclude: **/footer.html
[INFO] Exclude: **/*.txt
[INFO] Exclude: **/*.md
[INFO] Exclude: etc/ide-settings/**
[INFO] Exclude: docs/**/*.json
[INFO] Exclude: docs/**/_book/
[INFO] Exclude: **/target/
[INFO] Exclude: **/META-INF/services/*
[INFO] Exclude: **/META-INF/MANIFEST.MF
[INFO] Exclude: **/*.iml
[INFO] Exclude: **/*.jceks
[INFO] Exclude: **/*.jks
[INFO] Exclude: **/xml.xsd
[INFO] Exclude: **/org/apache/activemq/artemis/utils/json/**
[INFO] Exclude: **/org/apache/activemq/artemis/utils/Base64.java
[INFO] Exclude: **/.settings/**
[INFO] Exclude: **/.project
[INFO] Exclude: **/.classpath
[INFO] Exclude: **/.editorconfig
[INFO] Exclude: **/.checkstyle
[INFO] Exclude: **/.factorypath
[INFO] Exclude: **/org.apache.activemq.artemis.cfg
[INFO] Exclude: **/nb-configuration.xml
[INFO] Exclude: **/*.data
[INFO] Exclude: **/*.bin
[INFO] Exclude: **/src/test/resources/keystore
[INFO] Exclude: **/*.log
[INFO] Exclude: **/*.redo
[INFO] Exclude: **/node/**
[INFO] Exclude: **/node_module

[activemq-artemis] branch master updated: NO-JIRA fixing test failures

2019-03-13 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 5a74b8b  NO-JIRA fixing test failures
5a74b8b is described below

commit 5a74b8b34df0c800793831bccb40fbd0f1286c13
Author: Clebert Suconic 
AuthorDate: Wed Mar 13 11:36:14 2019 -0400

NO-JIRA fixing test failures
---
 .../management/AcceptorControlTest.java| 22 ++
 .../management/SecurityNotificationTest.java   | 18 +-
 .../integration/mqtt/imported/MQTTFQQNTest.java| 22 --
 .../imported/MQTTInterceptorPropertiesTest.java| 13 -
 .../tests/integration/server/QueueQueryTest.java   |  1 +
 5 files changed, 32 insertions(+), 44 deletions(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AcceptorControlTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AcceptorControlTest.java
index c6ba3dc..2a37038 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AcceptorControlTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/AcceptorControlTest.java
@@ -135,19 +135,33 @@ public class AcceptorControlTest extends 
ManagementTestBase {
 
   acceptorControl.stop();
 
-  Assert.assertEquals(usingCore() ? 5 : 1, 
notifListener.getNotifications().size());
-  Notification notif = notifListener.getNotifications().get(usingCore() ? 
2 : 0);
+  Assert.assertEquals(usingCore() ? 7 : 1, 
notifListener.getNotifications().size());
+
+  int i = findNotification(notifListener, 
CoreNotificationType.ACCEPTOR_STOPPED);
+
+  Notification notif = notifListener.getNotifications().get(i);
   Assert.assertEquals(CoreNotificationType.ACCEPTOR_STOPPED, 
notif.getType());
   Assert.assertEquals(NettyAcceptorFactory.class.getName(), 
notif.getProperties().getSimpleStringProperty(new 
SimpleString("factory")).toString());
 
   acceptorControl.start();
 
-  Assert.assertEquals(usingCore() ? 10 : 2, 
notifListener.getNotifications().size());
-  notif = notifListener.getNotifications().get(usingCore() ? 7 : 1);
+  i = findNotification(notifListener, 
CoreNotificationType.ACCEPTOR_STARTED);
+  notif = notifListener.getNotifications().get(i);
   Assert.assertEquals(CoreNotificationType.ACCEPTOR_STARTED, 
notif.getType());
   Assert.assertEquals(NettyAcceptorFactory.class.getName(), 
notif.getProperties().getSimpleStringProperty(new 
SimpleString("factory")).toString());
}
 
+   private int findNotification(SimpleNotificationService.Listener 
notifListener, CoreNotificationType type) {
+  int i = 0;
+  for (i = 0; i < notifListener.getNotifications().size(); i++) {
+ if (notifListener.getNotifications().get(i).getType().equals(type)) {
+break;
+ }
+  }
+  Assert.assertTrue(i < notifListener.getNotifications().size());
+  return i;
+   }
+
// Package protected -
 
// Protected -
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/SecurityNotificationTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/SecurityNotificationTest.java
index b8d5231..08accec 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/SecurityNotificationTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/SecurityNotificationTest.java
@@ -112,11 +112,19 @@ public class SecurityNotificationTest extends 
ActiveMQTestBase {
   } catch (Exception e) {
   }
 
-  ClientMessage[] notifications = 
SecurityNotificationTest.consumeMessages(1, notifConsumer);
-  Assert.assertEquals(SECURITY_PERMISSION_VIOLATION.toString(), 
notifications[0].getObjectProperty(ManagementHelper.HDR_NOTIFICATION_TYPE).toString());
-  Assert.assertEquals("guest", 
notifications[0].getObjectProperty(ManagementHelper.HDR_USER).toString());
-  Assert.assertEquals(address.toString(), 
notifications[0].getObjectProperty(ManagementHelper.HDR_ADDRESS).toString());
-  Assert.assertEquals(CheckType.CREATE_DURABLE_QUEUE.toString(), 
notifications[0].getObjectProperty(ManagementHelper.HDR_CHECK_TYPE).toString());
+  ClientMessage[] notifications = 
SecurityNotificationTest.consumeMessages(2, notifConsumer);
+
+  int i = 0;
+  for (i = 0; i < notifications.length; i++) {
+ if 
(SECURITY_PERMISSION_VIOLATION.toString().equals(notifications[i].getObjectProp

buildbot success in on activemq-site-production

2019-03-13 Thread 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/32382

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

2019-03-13 Thread 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/32381

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

buildbot success in on activemq-site-production

2019-03-13 Thread 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/32380

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

2019-03-13 Thread 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/32378

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

[activemq] branch master updated: AMQ-7167 - ensure remote IP is visible in acceptor error messages from the transport connector - test and fix

2019-03-13 Thread gtully

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

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


The following commit(s) were added to refs/heads/master by this push:
 new 2d394b3  AMQ-7167 - ensure remote IP is visible in acceptor error 
messages from the transport connector - test and fix
2d394b3 is described below

commit 2d394b383cf80681f53e24003cbaed9b1c6c1de6
Author: gtully 
AuthorDate: Wed Mar 13 10:21:19 2019 +

AMQ-7167 - ensure remote IP is visible in acceptor error messages from the 
transport connector - test and fix
---
 .../apache/activemq/broker/TransportConnector.java |  7 ++---
 .../activemq/transport/nio/NIOSSLBasicTest.java| 32 +-
 2 files changed, 34 insertions(+), 5 deletions(-)

diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
 
b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
index ba2a3a9..42abf5c 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
@@ -208,6 +208,7 @@ public class TransportConnector implements Connector, 
BrokerServiceAware {
 getServer().setAcceptListener(new TransportAcceptListener() {
 @Override
 public void onAccept(final Transport transport) {
+final String remoteHost = transport.getRemoteAddress();
 try {
 brokerService.getTaskRunnerFactory().execute(new 
Runnable() {
 @Override
@@ -220,14 +221,12 @@ public class TransportConnector implements Connector, 
BrokerServiceAware {
 throw new BrokerStoppedException("Broker " 
+ brokerService + " is being stopped");
 }
 } catch (Exception e) {
-String remoteHost = 
transport.getRemoteAddress();
 ServiceSupport.dispose(transport);
 onAcceptError(e, remoteHost);
 }
 }
 });
 } catch (Exception e) {
-String remoteHost = transport.getRemoteAddress();
 ServiceSupport.dispose(transport);
 onAcceptError(e, remoteHost);
 }
@@ -240,9 +239,9 @@ public class TransportConnector implements Connector, 
BrokerServiceAware {
 
 private void onAcceptError(Exception error, String remoteHost) {
 if (brokerService != null && brokerService.isStopping()) {
-LOG.info("Could not accept connection during shutdown {} : 
{}", (remoteHost == null ? "" : "from " + remoteHost), error);
+LOG.info("Could not accept connection during shutdown {} : 
{}", (remoteHost == null ? "" : "from " + remoteHost), 
error.getLocalizedMessage());
 } else {
-LOG.error("Could not accept connection {} : {}", 
(remoteHost == null ? "" : "from " + remoteHost), error);
+LOG.error("Could not accept connection {} : {}", 
(remoteHost == null ? "" : "from " + remoteHost), error.getLocalizedMessage());
 LOG.debug("Reason: " + error, error);
 }
 }
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/nio/NIOSSLBasicTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/nio/NIOSSLBasicTest.java
index 6444d2c..01c5e57 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/nio/NIOSSLBasicTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/nio/NIOSSLBasicTest.java
@@ -29,12 +29,21 @@ import javax.net.ssl.SSLHandshakeException;
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.util.DefaultTestAppender;
+import org.apache.log4j.Level;
+import org.apache.log4j.spi.LoggingEvent;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 
 import junit.framework.TestCase;
 
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import static junit.framework.TestCase.assertTrue;
+
 public class NIOSSLBasicTest {
 
 public static final String KEYSTORE_TYPE = "jks";
@@ -87,7 +96,7 @@ public class NIOSSLBasicTest {
 
 @Test
 public void enabledCipherSuites() throws Exception {
-BrokerService broker = createBroker("nio+ssl", getTransportType() + 
"://localhost:0?transport.needClientAuth=true&transport.verifyHostName=false&transport.enabledCipherSuites=TLS_RSA_WITH_AES_256_CBC_SHA256");
+Brok

[activemq] branch master updated: no jira - init throwable cause to identify error on shutdown

2019-03-13 Thread gtully

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

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


The following commit(s) were added to refs/heads/master by this push:
 new a000a73  no jira - init throwable cause to identify error on shutdown
a000a73 is described below

commit a000a73431f6dfd249d057e7ee7ecced44b62af9
Author: gtully 
AuthorDate: Wed Mar 13 10:14:06 2019 +

no jira - init throwable cause to identify error on shutdown
---
 .../src/main/java/org/apache/activemq/broker/region/RegionBroker.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
 
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
index aa0909d..caf31f3 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
@@ -826,7 +826,7 @@ public class RegionBroker extends EmptyBroker {
 return getBrokerService().getBroker();
 } catch (Exception e) {
 LOG.error("Trying to get Root Broker", e);
-throw new RuntimeException("The broker from the BrokerService 
should not throw an exception");
+throw new RuntimeException("The broker from the BrokerService 
should not throw an exception", e);
 }
 }

[activemq] branch master updated: no jira - fix unit test failure

2019-03-13 Thread gtully

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

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


The following commit(s) were added to refs/heads/master by this push:
 new d5df23b  no jira - fix unit test failure
d5df23b is described below

commit d5df23b8fb97cbd063a9eb63178da8b61f5d8bbe
Author: gtully 
AuthorDate: Wed Mar 13 10:03:18 2019 +

no jira - fix unit test failure
---
 .../activemq/broker/region/DestinationGCStressTest.java   | 15 +--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/DestinationGCStressTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/DestinationGCStressTest.java
index c23c65a..61c01d8 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/DestinationGCStressTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/DestinationGCStressTest.java
@@ -18,6 +18,7 @@ package org.apache.activemq.broker.region;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerStoppedException;
 import org.apache.activemq.broker.region.policy.PolicyEntry;
 import org.apache.activemq.broker.region.policy.PolicyMap;
 import org.apache.activemq.command.ActiveMQTopic;
@@ -130,6 +131,7 @@ public class DestinationGCStressTest {
 while ((j = max.decrementAndGet()) > 0) {
 producer.send(new ActiveMQTopic("A." + j), 
message);
 }
+c.close();
 } catch (Exception ignored) {
 ignored.printStackTrace();
 }
@@ -162,8 +164,13 @@ public class DestinationGCStressTest {
 @Override
 public void doAppend(LoggingEvent event) {
 if (event.getLevel().equals(Level.ERROR) && 
event.getMessage().toString().startsWith("Failed to remove inactive")) {
-logger.info("received unexpected log message: " + 
event.getMessage());
-failed.set(true);
+if (event.getThrowableInformation().getThrowable() != null
+&& 
event.getThrowableInformation().getThrowable().getCause() instanceof 
BrokerStoppedException) {
+// ok
+} else {
+logger.info("received unexpected log message: " + 
event.getMessage());
+failed.set(true);
+}
 }
 }
 };
@@ -193,6 +200,7 @@ public class DestinationGCStressTest {
 while ((j = max.decrementAndGet()) > 0) {
 producer.send(new ActiveMQTopic("A." + j), 
message);
 }
+c.close();
 } catch (Exception ignored) {
 ignored.printStackTrace();
 }
@@ -209,6 +217,7 @@ public class DestinationGCStressTest {
 messageConsumer.close();
 
 } catch (Exception ignored) {
+ignored.printStackTrace();
 }
 }
 }
@@ -266,6 +275,7 @@ public class DestinationGCStressTest {
 while ((j = max.decrementAndGet()) > 0) {
 producer.send(new ActiveMQTopic("A." + j), 
message);
 }
+c.close();
 } catch (Exception ignored) {
 ignored.printStackTrace();
 }
@@ -285,6 +295,7 @@ public class DestinationGCStressTest {
 messageConsumer.close();
 
 } catch (Exception ignored) {
+ignored.printStackTrace();
 }
 }
 }

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

[activemq-artemis] branch master updated: ARTEMIS-2229 turns out a valid bug. So restore the fix commit.

buildbot success in on activemq-site-production

Jenkins build is back to normal : ActiveMQ-Artemis-Master #2305

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

[activemq-artemis] branch master updated: NO-JIRA More general test fixes

buildbot failure in on activemq-site-production

[activemq-artemis] 01/03: ARTEMIS-2274 Test showing issue with Message overflowing buffer when sizes are too close to TimedBuffer size

[activemq-artemis] 02/03: ARTEMIS-2274 Fix on Journal buffer overflow with almost large messages

[activemq-artemis] 03/03: This closes #2581

[activemq-artemis] branch master updated (3ccf6a8 -> 3a3be57)

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

[activemq-artemis] branch master updated: Revert "ARTEMIS-2240 ActiveMQThreadPoolExecutor should use LinkedTransferQueue"

buildbot success in on activemq-site-production

buildbot failure in on activemq-site-production

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

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: Partition Management #1264

Jenkins build is still unstable: ActiveMQ-Java8 #1264

Jenkins build is still unstable: ActiveMQ-Java8 » ActiveMQ :: MQTT Protocol #1264

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

[activemq-artemis] branch master updated: NO-JIRA fixing test failures

buildbot success in on activemq-site-production

buildbot failure in on activemq-site-production

buildbot success in on activemq-site-production

buildbot failure in on activemq-site-production

[activemq] branch master updated: AMQ-7167 - ensure remote IP is visible in acceptor error messages from the transport connector - test and fix

[activemq] branch master updated: no jira - init throwable cause to identify error on shutdown

[activemq] branch master updated: no jira - fix unit test failure

28 matches

Site Navigation

Mail list logo

Footer information