qpid flakiness improvements:

* increase awaitability period time, from 1 min to 3 min.
* emit a qpid event every 500 ms (previously was set to 5 sec).
* JMS consumer check if has been received a message before close connection.

messaging/qpid/src/main/java/io/quarkus/ts/openshift/messaging/qpid/PriceConsumer.java

@@ -48,7 +48,7 @@ public void run() {
             JMSConsumer consumer = context.createConsumer(context.createQueue("prices"));
             while (true) {
                 Message message = consumer.receive();
-                if (message == null) return;
+                if (message == null && (lastPrice != null || !lastPrice.isEmpty())) return;
                 lastPrice = message.getBody(String.class);
             }
         } catch (JMSException e) {

messaging/qpid/src/main/java/io/quarkus/ts/openshift/messaging/qpid/PriceProducer.java

@@ -28,7 +28,7 @@ public class PriceProducer implements Runnable {
     private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
 
     void onStart(@Observes StartupEvent ev) {
-        scheduler.scheduleWithFixedDelay(this, 0L, 5L, TimeUnit.SECONDS);
+        scheduler.scheduleWithFixedDelay(this, 0L, 500L, TimeUnit.MILLISECONDS);
     }
 
     void onStop(@Observes ShutdownEvent ev) {

messaging/qpid/src/test/java/io/quarkus/ts/openshift/messaging/qpid/AbstractQPIDTest.java

@@ -19,7 +19,7 @@ public abstract class AbstractQPIDTest {
     @Test
     @Order(1)
     public void testLastPrice() {
-        await().atMost(60, TimeUnit.SECONDS).untilAsserted(() -> {
+        await().atMost(3, TimeUnit.MINUTES).untilAsserted(() -> {
             String value =
                     when()
                             .get("/prices/last")