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

[Apache Jenkins Server]

See 


Changes:

[clebertsuconic] ARTEMIS-1923 fix constructing binding journalimpl bug

[clebertsuconic] ARTEMIS-1927 treat exceptions and disconnect properly

--
[...truncated 1.13 MB...]
*¾Ñ~Ñ(
vϪuIšYE?§¨?ÚÈDŽN6زe?oj??ŸÛÿ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???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¶??³?މø"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$Ä??Õ??õ?‘?“È™ò[†û¢˜àݔ}?óô?õO¸J[î>f1m?§ÖxLì?9?#¸Ä¡¼½@ÆI
 ñ?“§zߟe²3U­®­Ùy¦s՚Ԛ¿<¢L?²n??9ÚÝE‚?¿½ÙûA@æ?S¨–?N¥§ª‡KçX·?Û{5i‡ßf 
€ÝÕ4::šÚø›éÙÌa.À€??ýWÚ'?ž[À]+õÇ)gÕf>°§)כªäN?¢†
ÁÈ?YOQQDs¬
. 
jÒßP‰ÆéÐø?Ž†x¯¥!4†)S?¶?š?Œ=œ/?q8:™??Þ¢ª?T·ÛC‹ÇÊÀÀN+]??{ÈZ‡»»?ò:?#©Ü‘Ô?:/?QŒNRjr=„??‹:?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†÷
??? ‚   Ó?‚ Ï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œ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†÷

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

[clebertsuconic]

Repository: activemq-artemis
Updated Branches:
  refs/heads/master 1d5128839 -> 83d363de6


This closes #2139


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

Branch: refs/heads/master
Commit: 83d363de62c788861a772fa26bdfa86f76265550
Parents: 1d51288 88833c7
Author: Clebert Suconic 
Authored: Tue Jun 12 18:54:45 2018 -0400
Committer: Clebert Suconic 
Committed: Tue Jun 12 18:54:45 2018 -0400

--
 .../remoting/impl/netty/ActiveMQChannelHandler.java  |  3 +--
 .../remoting/server/impl/RemotingServiceImpl.java| 15 ++-
 2 files changed, 7 insertions(+), 11 deletions(-)
--

[2/2] activemq-artemis git commit: ARTEMIS-1927 treat exceptions and disconnect properly

[clebertsuconic]

ARTEMIS-1927 treat exceptions and disconnect properly

I couldn't do this with a test as this is dependent on windows. Regular 
testsuite should be sufficient as long as you run in Windows.


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

Branch: refs/heads/master
Commit: 88833c790af1459990bc4203414966afd7438e02
Parents: 1d51288
Author: Clebert Suconic 
Authored: Tue Jun 12 16:29:13 2018 -0400
Committer: Clebert Suconic 
Committed: Tue Jun 12 18:54:45 2018 -0400

--
 .../remoting/impl/netty/ActiveMQChannelHandler.java  |  3 +--
 .../remoting/server/impl/RemotingServiceImpl.java| 15 ++-
 2 files changed, 7 insertions(+), 11 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/88833c79/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/ActiveMQChannelHandler.java
--
diff --git 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/ActiveMQChannelHandler.java
 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/ActiveMQChannelHandler.java
index d0d5c0e..de8b49e 100644
--- 
a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/ActiveMQChannelHandler.java
+++ 
b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/ActiveMQChannelHandler.java
@@ -26,7 +26,6 @@ import io.netty.channel.group.ChannelGroup;
 import org.apache.activemq.artemis.api.core.ActiveMQException;
 import org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper;
 import org.apache.activemq.artemis.core.client.ActiveMQClientLogger;
-import org.apache.activemq.artemis.core.client.ActiveMQClientMessageBundle;
 import 
org.apache.activemq.artemis.spi.core.remoting.BaseConnectionLifeCycleListener;
 import org.apache.activemq.artemis.spi.core.remoting.BufferHandler;
 
@@ -99,7 +98,7 @@ public class ActiveMQChannelHandler extends 
ChannelDuplexHandler {
   // and we don't want to spew out stack traces in that event
   // The user has access to this exeception anyway via the 
ActiveMQException initial cause
 
-  ActiveMQException me = ActiveMQClientMessageBundle.BUNDLE.nettyError();
+  ActiveMQException me = new ActiveMQException(cause.getMessage());
   me.initCause(cause);
 
   synchronized (listener) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/88833c79/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
--
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
index 17351d9..5a1ddef 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
@@ -539,6 +539,10 @@ public class RemotingServiceImpl implements 
RemotingService, ServerConnectionLif
  logger.trace("Connection removed " + connectionID + " from server " + 
this.server, new Exception("trace"));
   }
 
+  issueFailure(connectionID, new ActiveMQRemoteDisconnectException());
+   }
+
+   private void issueFailure(Object connectionID, ActiveMQException e) {
   ConnectionEntry conn = connections.get(connectionID);
 
   if (conn != null && !conn.connection.isSupportReconnect()) {
@@ -554,20 +558,13 @@ public class RemotingServiceImpl implements 
RemotingService, ServerConnectionLif
return;
 }
  }
- conn.connection.fail(new ActiveMQRemoteDisconnectException());
+ conn.connection.fail(e);
   }
}
 
@Override
public void connectionException(final Object connectionID, final 
ActiveMQException me) {
-  // We DO NOT call fail on connection exception, otherwise in event of 
real connection failure, the
-  // connection will be failed, the session will be closed and won't be 
able to reconnect
-
-  // E.g. if live server fails, then this handler wil be called on backup 
server for the server
-  // side replicating connection.
-  // If the connection fail() is called then the sessions on the backup 
will get closed.
-
-  // Connections should only fail when TTL is exceeded
+  

activemq-artemis git commit: ARTEMIS-1923 fix constructing binding journalimpl bug

[clebertsuconic]

Repository: activemq-artemis
Updated Branches:
  refs/heads/master e990e95f3 -> 1d5128839


ARTEMIS-1923 fix constructing binding journalimpl bug

Clebert Suconic ammended this commit by adding a test and getter properties to 
satisfy the test

This closes #2133


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

Branch: refs/heads/master
Commit: 1d5128839f0cffe32cdd85032310665450792837
Parents: e990e95
Author: yang wei 
Authored: Mon Jun 11 19:27:00 2018 +0800
Committer: Clebert Suconic 
Committed: Tue Jun 12 12:30:25 2018 -0400

--
 .../journal/impl/JournalFilesRepository.java|   4 +
 .../artemis/core/journal/impl/JournalImpl.java  |  11 ++
 .../impl/journal/JournalStorageManager.java |   2 +-
 .../JournalStorageManagerConstantTest.java  | 167 +++
 4 files changed, 183 insertions(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1d512883/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
--
diff --git 
a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
 
b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
index 488aa1f..5896fba 100644
--- 
a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
+++ 
b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalFilesRepository.java
@@ -130,6 +130,10 @@ public class JournalFilesRepository {
 
// Public 
 
+   public int getPoolSize() {
+  return poolSize;
+   }
+
public void setExecutor(final Executor fileExecutor) {
   this.openFilesExecutor = fileExecutor;
}

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1d512883/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
--
diff --git 
a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
 
b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
index 849dd3e..55b92c5 100644
--- 
a/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
+++ 
b/artemis-journal/src/main/java/org/apache/activemq/artemis/core/journal/impl/JournalImpl.java
@@ -215,6 +215,17 @@ public class JournalImpl extends JournalBase implements 
TestableJournal, Journal
 
private final Reclaimer reclaimer = new Reclaimer();
 
+   public float getCompactPercentage() {
+  return compactPercentage;
+   }
+
+   public int getCompactMinFiles() {
+  return compactMinFiles;
+   }
+
+   public JournalFilesRepository getFilesRepository() {
+  return filesRepository;
+   }
// Constructors --
 
public JournalImpl(final int fileSize,

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/1d512883/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
--
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
index 9199bbe..dd8bb22 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/JournalStorageManager.java
@@ -129,7 +129,7 @@ public class JournalStorageManager extends 
AbstractJournalStorageManager {
   bindingsFF = new NIOSequentialFileFactory(config.getBindingsLocation(), 
criticalErrorListener, config.getJournalMaxIO_NIO());
   bindingsFF.setDatasync(config.isJournalDatasync());
 
-  Journal localBindings = new JournalImpl(ioExecutorFactory, 1024 * 1024, 
2, config.getJournalCompactMinFiles(), config.getJournalPoolFiles(), 
config.getJournalCompactPercentage(), config.getJournalFileOpenTimeout(), 
bindingsFF, "activemq-bindings", "bindings", 1, 0, criticalErrorListener);
+  Journal localBindings = new JournalImpl(ioExecutorFactory, 1024 * 1024, 
2, config.getJournalPoolFiles(), config.getJournalCompactMinFiles(), 

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

[Apache Jenkins Server]

See 


Changes:

[clebertsuconic] ARTEMIS-1893: Treat the detach of a link with expiry policy of

--
[...truncated 925.37 KB...]
[Thread-6 
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$5@7cb502c)]
 14:23:25,276 WARN  [org.apache.activemq.artemis.core.server] AMQ222165: No 
Dead Letter Address configured for queue test.queue in AddressSettings
[Thread-6 
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$5@7cb502c)]
 14:23:25,276 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No 
Expiry Address configured for queue test.queue in AddressSettings
[main] 14:23:25,287 INFO  [org.apache.activemq.artemis.core.server] AMQ221002: 
Apache ActiveMQ Artemis Message Broker version 2.7.0-SNAPSHOT 
[2afd3ffb-6e4c-11e8-9ceb-0242253659e1] stopped, uptime 0.026 seconds
[main] 14:23:25,292 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: 
live Message Broker is starting with configuration Broker Configuration 
(clustered=false,journalDirectory=data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/largemessages,pagingDirectory=data/paging)
[main] 14:23:25,293 INFO  [org.apache.activemq.artemis.core.server] AMQ221057: 
Global Max Size is being adjusted to 1/2 of the JVM max size (-Xmx). being 
defined as 11,263,279,104
[main] 14:23:25,293 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: 
Protocol module found: [artemis-server]. Adding protocol support for: CORE
[main] 14:23:25,300 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: 
Server is now live
[main] 14:23:25,300 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: 
Apache ActiveMQ Artemis Message Broker version 2.7.0-SNAPSHOT 
[embedded-jms-server, nodeID=2b01faf4-6e4c-11e8-9ceb-0242253659e1] 
[Thread-6 
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$5@55cf0d14)]
 14:23:25,315 WARN  [org.apache.activemq.artemis.core.server] AMQ222165: No 
Dead Letter Address configured for queue test.queue in AddressSettings
[Thread-6 
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$5@55cf0d14)]
 14:23:25,315 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No 
Expiry Address configured for queue test.queue in AddressSettings
[main] 14:23:25,329 INFO  [org.apache.activemq.artemis.core.server] AMQ221002: 
Apache ActiveMQ Artemis Message Broker version 2.7.0-SNAPSHOT 
[2b01faf4-6e4c-11e8-9ceb-0242253659e1] stopped, uptime 0.036 seconds
[main] 14:23:25,332 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: 
live Message Broker is starting with configuration Broker Configuration 
(clustered=false,journalDirectory=data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/largemessages,pagingDirectory=data/paging)
[main] 14:23:25,332 INFO  [org.apache.activemq.artemis.core.server] AMQ221057: 
Global Max Size is being adjusted to 1/2 of the JVM max size (-Xmx). being 
defined as 11,263,279,104
[main] 14:23:25,333 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: 
Protocol module found: [artemis-server]. Adding protocol support for: CORE
[main] 14:23:25,338 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: 
Server is now live
[main] 14:23:25,338 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: 
Apache ActiveMQ Artemis Message Broker version 2.7.0-SNAPSHOT 
[embedded-jms-server, nodeID=2b08157d-6e4c-11e8-9ceb-0242253659e1] 
[Thread-5 
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$5@5117dd67)]
 14:23:25,359 WARN  [org.apache.activemq.artemis.core.server] AMQ222165: No 
Dead Letter Address configured for queue test.queue in AddressSettings
[Thread-5 
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$5@5117dd67)]
 14:23:25,359 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No 
Expiry Address configured for queue test.queue in AddressSettings
[main] 14:23:25,368 INFO  [org.apache.activemq.artemis.core.server] AMQ221002: 
Apache ActiveMQ Artemis Message Broker version 2.7.0-SNAPSHOT 
[2b08157d-6e4c-11e8-9ceb-0242253659e1] stopped, uptime 0.035 seconds
[main] 14:23:25,371 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: 
live Message Broker is starting with configuration Broker Configuration 
(clustered=false,journalDirectory=data/journal,bindingsDirectory=data/bindings,largeMessagesDirectory=data/largemessages,pagingDirectory=data/paging)
[main] 14:23:25,372 INFO  [org.apache.activemq.artemis.core.server] AMQ221057: 
Global Max Size is being adjusted to 1/2 of the JVM max size (-Xmx). being 
defined as 11,263,279,104
[main] 14:23:25,372 INFO  [org.apache.activemq.artemis.core.server] AMQ221043: 
Protocol module found: [artemis-server]. Adding protocol support for: CORE
[main] 14:23:25,377 INFO  

activemq-artemis git commit: ARTEMIS-1893: Treat the detach of a link with expiry policy of link-detatch as if closed flag were true.

[clebertsuconic]

Repository: activemq-artemis
Updated Branches:
  refs/heads/2.6.x 8058a512e -> 17d7dde4c


ARTEMIS-1893: Treat the detach of a link with expiry policy of link-detatch as 
if closed flag were true.

(cherry picked from commit 89f6350c1c730eee1faf2a699d1e88f452e5147f)


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

Branch: refs/heads/2.6.x
Commit: 17d7dde4ca858de340d24895f71f6f99e1ba6550
Parents: 8058a51
Author: Keith Wall 
Authored: Mon Jun 11 08:48:50 2018 +0100
Committer: Clebert Suconic 
Committed: Tue Jun 12 10:12:48 2018 -0400

--
 .../amqp/proton/AMQPConnectionContext.java  | 21 +++--
 .../amqp/AmqpNonDurableReceiverTest.java| 81 
 2 files changed, 96 insertions(+), 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/17d7dde4/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
--
diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
index 886bb2d..ad3a44f 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
@@ -46,6 +46,8 @@ import 
org.apache.activemq.artemis.spi.core.remoting.ReadyListener;
 import org.apache.activemq.artemis.utils.ByteUtil;
 import org.apache.activemq.artemis.utils.VersionLoader;
 import org.apache.qpid.proton.amqp.Symbol;
+import org.apache.qpid.proton.amqp.messaging.Source;
+import org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy;
 import org.apache.qpid.proton.amqp.transaction.Coordinator;
 import org.apache.qpid.proton.amqp.transport.ErrorCondition;
 import org.apache.qpid.proton.engine.Connection;
@@ -482,12 +484,19 @@ public class AMQPConnectionContext extends 
ProtonInitializable implements EventH
 
@Override
public void onRemoteDetach(Link link) throws Exception {
-  lock();
-  try {
- link.detach();
- link.free();
-  } finally {
- unlock();
+  boolean handleAsClose = link.getSource() != null
+  && ((Source) link.getSource()).getExpiryPolicy() 
== TerminusExpiryPolicy.LINK_DETACH;
+
+  if (handleAsClose) {
+ onRemoteClose(link);
+  } else {
+ lock();
+ try {
+link.detach();
+link.free();
+ } finally {
+unlock();
+ }
   }
}
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/17d7dde4/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
new file mode 100644
index 000..69f8b53
--- /dev/null
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *  http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.artemis.tests.integration.amqp;
+
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import org.apache.activemq.artemis.api.core.SimpleString;
+import 

[2/2] activemq-artemis git commit: ARTEMIS-1893: Treat the detach of a link with expiry policy of link-detatch as if closed flag were true.

[clebertsuconic]

ARTEMIS-1893: Treat the detach of a link with expiry policy of link-detatch as 
if closed flag were true.


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

Branch: refs/heads/master
Commit: 89f6350c1c730eee1faf2a699d1e88f452e5147f
Parents: 12afc0b
Author: Keith Wall 
Authored: Mon Jun 11 08:48:50 2018 +0100
Committer: Clebert Suconic 
Committed: Tue Jun 12 10:12:19 2018 -0400

--
 .../amqp/proton/AMQPConnectionContext.java  | 21 +++--
 .../amqp/AmqpNonDurableReceiverTest.java| 81 
 2 files changed, 96 insertions(+), 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/89f6350c/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
--
diff --git 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
index 4612a97..3552106 100644
--- 
a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
+++ 
b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/AMQPConnectionContext.java
@@ -46,6 +46,8 @@ import 
org.apache.activemq.artemis.spi.core.remoting.ReadyListener;
 import org.apache.activemq.artemis.utils.ByteUtil;
 import org.apache.activemq.artemis.utils.VersionLoader;
 import org.apache.qpid.proton.amqp.Symbol;
+import org.apache.qpid.proton.amqp.messaging.Source;
+import org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy;
 import org.apache.qpid.proton.amqp.transaction.Coordinator;
 import org.apache.qpid.proton.amqp.transport.ErrorCondition;
 import org.apache.qpid.proton.engine.Connection;
@@ -485,12 +487,19 @@ public class AMQPConnectionContext extends 
ProtonInitializable implements EventH
 
@Override
public void onRemoteDetach(Link link) throws Exception {
-  lock();
-  try {
- link.detach();
- link.free();
-  } finally {
- unlock();
+  boolean handleAsClose = link.getSource() != null
+  && ((Source) link.getSource()).getExpiryPolicy() 
== TerminusExpiryPolicy.LINK_DETACH;
+
+  if (handleAsClose) {
+ onRemoteClose(link);
+  } else {
+ lock();
+ try {
+link.detach();
+link.free();
+ } finally {
+unlock();
+ }
   }
}
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/89f6350c/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
new file mode 100644
index 000..69f8b53
--- /dev/null
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpNonDurableReceiverTest.java
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *  http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.artemis.tests.integration.amqp;
+
+import java.util.concurrent.atomic.AtomicBoolean;
+
+import org.apache.activemq.artemis.api.core.SimpleString;
+import org.apache.activemq.transport.amqp.client.AmqpClient;
+import org.apache.activemq.transport.amqp.client.AmqpConnection;
+import org.apache.activemq.transport.amqp.client.AmqpReceiver;
+import 

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

[clebertsuconic]

Repository: activemq-artemis
Updated Branches:
  refs/heads/master 12afc0b33 -> e990e95f3


This closes #2132


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

Branch: refs/heads/master
Commit: e990e95f30c59f7e1eba25f47dd0bed1f7e976c5
Parents: 12afc0b 89f6350
Author: Clebert Suconic 
Authored: Tue Jun 12 10:12:19 2018 -0400
Committer: Clebert Suconic 
Committed: Tue Jun 12 10:12:19 2018 -0400

--
 .../amqp/proton/AMQPConnectionContext.java  | 21 +++--
 .../amqp/AmqpNonDurableReceiverTest.java| 81 
 2 files changed, 96 insertions(+), 6 deletions(-)
--

svn commit: r1031093 - in /websites/production/activemq/content: cache/main.pageCache message-redelivery-and-dlq-handling.html

[buildbot]

Author: buildbot
Date: Tue Jun 12 09:24:31 2018
New Revision: 1031093

Log:
Production update by buildbot for activemq

Modified:
websites/production/activemq/content/cache/main.pageCache

websites/production/activemq/content/message-redelivery-and-dlq-handling.html

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

Modified: 
websites/production/activemq/content/message-redelivery-and-dlq-handling.html
==
--- 
websites/production/activemq/content/message-redelivery-and-dlq-handling.html 
(original)
+++ 
websites/production/activemq/content/message-redelivery-and-dlq-handling.html 
Tue Jun 12 09:24:31 2018
@@ -81,15 +81,15 @@
   
 
 
-OverviewMessages are 
redelivered to a client when any of the following 
occurs:A transacted session is used 
androllback() is called.A 
transacted session is closed beforecommit() 
is called.A session is 
usingCLIENT_ACKNOWLEDGE 
andSession.recover() is called.A 
client connection times out (perhaps the code being executed takes longer than 
the configured time-out period).The broker transmits the default 
delivery policy that he prefers to a client connection in 
hisBrokerInfo command packet. But the 
client can override the policy settings by using 
theActiveMQConnection.getRedeliveryPolicy() 
method:
-RedeliveryPolicy policy = 
connection.getRedeliveryPolicy();
+OverviewMessages are 
redelivered to a client when any of the following 
occurs:A transacted session is used 
androllback() is called.A 
transacted session is closed beforecommit() 
is called.A session is 
usingCLIENT_ACKNOWLEDGE 
andSession.recover() is called.A 
client connection times out (perhaps the code being executed takes longer than 
the configured time-out period).A client can override the policy 
settings by using 
theActiveMQConnection.getRedeliveryPolicy()orActiveMQConnectionFactory.getRedeliveryPolicyMap()methods:
+RedeliveryPolicy 
policy = connection.getRedeliveryPolicy();
 policy.setInitialRedeliveryDelay(500);
 policy.setBackOffMultiplier(2);
 policy.setUseExponentialBackOff(true);
 policy.setMaximumRedeliveries(2);
 
 Once a message's redelivery attempts exceeds 
themaximumRedeliveries configured for the 
Redelivery Policy, a "Poison 
ACK" is sent back to the broker letting him know that the message was 
considered a poison pill. The Broker then takes the message and sends it to a 
Dead Letter Queue so that it can be analyzed later on.The default Dead 
Letter Queue in ActiveMQ is called ActiveMQ.DLQ; 
all un-deliverable messages will get sent to this queue and this can be 
difficult to manage. So, you can set 
anindividualDeadLetterStrategy in the 
destination policy map of the activemq.xml 
configuration file, which allows you to specify a specific dead letter queue 
prefix for a given queue or topic. You can apply this strategy using wild card 
if you like so that all queues get their own dead-letter queue,
  as is shown in the example below.
-broker
+broker
   
   destinationPolicy
 policyMap
@@ -111,7 +111,7 @@ policy.setMaximumRedeliveries(2);
 /broker
 
 See the Redelivery Policy section for some more 
detail on the policy options.Automatically
 Discard Expired MessagesSome folks simply need expired messages to be 
discarded instead of sent to the DLQ i.e., skip the DLQ entirely. This 
simplifies the management of the DLQ so that you're not sifting through loads 
of expired messages to find messages with real problems. To tell ActiveMQ to 
just discard expired messages, configure the 
processExpired property to false on a dead letter 
strategy:
-broker
+broker
   
   destinationPolicy
policyMap
@@ -134,7 +134,7 @@ policy.setMaximumRedeliveries(2);
 /broker
 
 Place
 Non-Persistent Messages Onto The Dead-Letter QueueBy default, ActiveMQ 
will not place undeliverable non-persistent messages on the 
dead-letter queue. The rationale for this behavior is that if the application 
doesn't care enough to make the message persistent, then there is little or no 
value in recording that the message was undeliverable. If you do want to place 
non-persistent messages on the dead-letter queue, then you should set 
processNonPersistent="true" on the dead-letter 
strategy.
-broker
+broker
   
  destinationPolicy
policyMap
@@ -156,7 +156,7 @@ policy.setMaximumRedeliveries(2);
 /broker
 
 Setting
 Expiration on Messages in the DLQBy default, ActiveMQ will 
never expire messages sent to the DLQ. However, from 
ActiveMQ 5.12 thedeadLetterStrategy 
supports anexpiration attribute whose value 
is given in milliseconds.Be selective in how this is 
applied. In particular do not apply expiration to your DLQ destinations by 
setting expiration on a default or inclusive wildcard policy entry.If a 
DLQ entry expires and forwards to the same or another DLQ with expiry, you will 

[CONF] Apache ActiveMQ > Message Redelivery and DLQ Handling

[Gary Tully (Confluence)]

Title: Message Title



 
 
 
There's 1 new edit on this page 
 
 
 
 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
Message Redelivery and DLQ Handling 
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

 
 
 
 
Gary Tully edited this page 
 
 
  
 
 

 
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
Here's the version comment 
 
 
 
 
 
 
 
 
 
 
 
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 

 
 
 
 
Gary Tully edited at 09:02 AM 
 
 
  
 
 

 
 
 
 
 
 
 
 
 remove incorrect ref to BrokerInfo  
 
 
  
 
 
  
 
 

 
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
Here's what changed: 
 
 
 
 
 
 
 
 
 
 
 ... 
 
A transacted session is used and rollback() is called. 
A transacted session is closed before commit() is called. 
A session is using CLIENT_ACKNOWLEDGE and Session.recover() is called. 
A client connection times out (perhaps the code being executed takes longer than the configured time-out period). 
  The broker transmits the default delivery policy that he prefers to a client connection in his BrokerInfo command packet. But the client A client can override the policy settings by using the ActiveMQConnection.getRedeliveryPolicy() method or ActiveMQConnectionFactory.getRedeliveryPolicyMap()   methods: 
 
 
 
 Code Block 
 
 
 
 
 
 
 
 
 
java 
 
 
 
java 
 
 
  
 
 
 
 
 RedeliveryPolicy policy = connection.getRedeliveryPolicy();
policy.setInitialRedeliveryDelay(500);
policy.setBackOffMultiplier(2);
policy.setUseExponentialBackOff(true);
policy.setMaximumRedeliveries(2);
  
 
 
 ...  
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
Go to page history 
 
 
  
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
View page 
 
 
  
 
 
  
 
 
  
 
 
  
 
 
 
 
 
 
 
 
 
 
Stop watching space
• 
 
 
 
 
 
 
Manage notifications 
 
 
 
 
 
 
 
 
 
 
  
 
 
This message was sent by Atlassian Confluence 6.9.0