date:20200331

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 891f281  NO-JIRA Improve AMQP paging test coverage and determinism
 new fb4b8ff  This closes #3045
891f281 is described below

commit 891f2817ff1452daf28223f976f1e206d5a34661
Author: Francesco Nigro 
AuthorDate: Mon Mar 23 18:14:37 2020 +0100

NO-JIRA Improve AMQP paging test coverage and determinism
---
 .../integration/amqp/paging/AmqpPagingTest.java| 31 +-
 1 file changed, 25 insertions(+), 6 deletions(-)

diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPagingTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPagingTest.java
index b4085ed..5218a0d 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPagingTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/paging/AmqpPagingTest.java
@@ -22,15 +22,19 @@ import java.util.Map;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.activemq.artemis.api.core.SimpleString;
+import org.apache.activemq.artemis.core.paging.PagingStore;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
+import org.apache.activemq.artemis.core.server.Queue;
 import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
 import 
org.apache.activemq.artemis.tests.integration.amqp.AmqpClientTestSupport;
+import org.apache.activemq.artemis.tests.util.Wait;
 import org.apache.activemq.transport.amqp.client.AmqpClient;
 import org.apache.activemq.transport.amqp.client.AmqpConnection;
 import org.apache.activemq.transport.amqp.client.AmqpMessage;
 import org.apache.activemq.transport.amqp.client.AmqpReceiver;
 import org.apache.activemq.transport.amqp.client.AmqpSender;
 import org.apache.activemq.transport.amqp.client.AmqpSession;
+import org.hamcrest.Matchers;
 import org.junit.Assert;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -39,22 +43,31 @@ import org.junit.runners.Parameterized;
 @RunWith(Parameterized.class)
 public class AmqpPagingTest extends AmqpClientTestSupport {
 
-   @Parameterized.Parameters(name = "durability={0}")
+   @Parameterized.Parameters(name = "durability={0}, readWholePage={1}")
public static Collection getParams() {
-  return Arrays.asList(new Object[][]{{Boolean.TRUE}, {Boolean.FALSE}, 
{null}});
+  return Arrays.asList(new Object[][]{
+ {Boolean.TRUE, true}, {Boolean.TRUE, false},
+ {Boolean.FALSE, true}, {Boolean.FALSE, false},
+ {null, true}, {null, false}});
}
 
private final Boolean durable;
+   private final boolean readWholePage;
 
-   public AmqpPagingTest(Boolean durable) {
+   public AmqpPagingTest(Boolean durable, boolean readWholePage) {
   this.durable = durable;
+  this.readWholePage = readWholePage;
}
 
@Override
protected void addConfiguration(ActiveMQServer server) {
   super.addConfiguration(server);
-  final Map addressesSettings = 
server.getConfiguration().getAddressesSettings();
-  
addressesSettings.get("#").setMaxSizeBytes(10).setPageSizeBytes(1);
+  final Map addressesSettings = 
server.getConfiguration()
+ .setReadWholePage(readWholePage)
+ .getAddressesSettings();
+  addressesSettings.get("#")
+ .setMaxSizeBytes(10)
+ .setPageSizeBytes(1);
}
 
@Test(timeout = 6)
@@ -86,8 +99,14 @@ public class AmqpPagingTest extends AmqpClientTestSupport {
  }
  sender.send(message);
   }
-  
Assert.assertTrue(server.getPagingManager().getPageStore(SimpleString.toSimpleString(getQueueName())).isPaging());
   sender.close();
+  final Queue queueView = getProxyToQueue(getQueueName());
+  Wait.assertEquals(MSG_COUNT, queueView::getMessageCount);
+  PagingStore pagingStore = 
server.getPagingManager().getPageStore(SimpleString.toSimpleString(getQueueName()));
+  Assert.assertTrue(pagingStore.isPaging());
+  final int pageCacheMaxSize = 
server.getConfiguration().getAddressesSettings().get("#").getPageCacheMaxSize();
+  Assert.assertThat("the size of the messages or the number of messages 
isn't enough",
+pagingStore.getNumberOfPages(), 
Matchers.greaterThan(pageCacheMaxSize));
   receiver.flow(MSG_COUNT);
   for (int i = 0; i < MSG_COUNT; i++) {
  AmqpMessage receive = receiver.receive(10, TimeUnit.SECONDS);

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

2020-03-31 Thread Apache Jenkins Server

See 


Changes:

[clebertsuconic] NO-JIRA Improve AMQP paging test coverage and determinism


--
[...truncated 1.28 MB...]
???    Ã? ¿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¶??³?Þø"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¥§ªKç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÷
???    Ó? Ï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ßá=`0tuê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÷
??? ?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'?<ß¯¹ñ{B¼Å»?

Jenkins build is still unstable: ActiveMQ-Java8-5.15.x » ActiveMQ :: Unit Tests #442

Jenkins build became unstable: ActiveMQ-Java8-5.15.x » ActiveMQ :: STOMP Protocol #442

Jenkins build is still unstable: ActiveMQ-Java8-5.15.x #442

Jenkins build is still unstable: ActiveMQ-Java8-5.15.x » ActiveMQ :: Karaf Integration Tests #442

Jenkins build became unstable: ActiveMQ-Java8-5.15.x » ActiveMQ :: MQTT Protocol #442

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

Jenkins build is unstable: ActiveMQ-Java8 » ActiveMQ :: AMQP #1509

Jenkins build is unstable: ActiveMQ-Java8 #1509

[activemq-artemis] branch master updated: NO-JIRA Improve AMQP paging test coverage and determinism

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

10 matches

Site Navigation

Mail list logo

Footer information