File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed 
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/persistence Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 5757import  org .apache .activemq .artemis .tests .unit .util .InVMContext ;
5858import  org .apache .activemq .artemis .tests .util .ActiveMQTestBase ;
5959import  org .apache .activemq .artemis .tests .util .RandomUtil ;
60+ import  org .apache .activemq .artemis .tests .util .Wait ;
6061import  org .apache .activemq .artemis .utils .UUIDGenerator ;
6162import  org .jboss .logging .Logger ;
6263import  org .junit .Test ;
@@ -1152,7 +1153,7 @@ public void testImportWrongRoutingType() throws Exception {
11521153      producer .send (createTextMessage (session , payload ).putByteProperty (Message .HDR_ROUTING_TYPE , (byte ) 1 ));
11531154      session .start ();
11541155      ClientConsumer  consumer  = session .createConsumer (myQueue );
1155-       ClientMessage  m  = consumer .receive (500 );
1156+       ClientMessage  m  = consumer .receive (5000 );
11561157      m .acknowledge ();
11571158
11581159      assertNotNull (m );
@@ -1189,10 +1190,10 @@ public void testImportWrongRoutingType() throws Exception {
11891190      xmlDataImporter .process (xmlInputStream , session , managementSession );
11901191
11911192      //Check that message is imported with no "routingType" and is intact 
1192-       assertTrue (server .getTotalMessageCount () == 1 );
1193+       Wait . assertTrue (() ->  server .getTotalMessageCount () == 1 );
11931194      session .start ();
11941195      consumer  = session .createConsumer (dlaPrefix .concat (myAddress ));
1195-       m  = consumer .receive (500 );
1196+       m  = consumer .receive (5000 );
11961197
11971198      assertNotNull (m );
11981199      assertEquals (m .getBodyBuffer ().readString (), payload );
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments