[camel] branch camel-2.21.x updated: CAMEL-12852 - use minimum expected message count

[acosentino]

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

acosentino pushed a commit to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/camel-2.21.x by this push:
     new 03065a5  CAMEL-12852 - use minimum expected message count
03065a5 is described below

commit 03065a53076e44adaf37b20f374b9c1946bb4ace
Author: Aurélien Pupier <apup...@redhat.com>
AuthorDate: Wed Oct 3 11:16:10 2018 +0200

    CAMEL-12852 - use minimum expected message count
    
    a lot of messages are generated, only the first oen is checked.
    
    Signed-off-by: Aurélien Pupier <apup...@redhat.com>
---
 .../java/org/apache/camel/component/pubnub/PubNubPresenceTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
 
b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
index dc83b81..f89ebec 100644
--- 
a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
+++ 
b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
@@ -48,7 +48,7 @@ public class PubNubPresenceTest extends PubNubTestBase {
                           + 
"{\"a\":\"4\",\"f\":512,\"p\":{\"t\":\"14637536741726901\",\"r\":1},\"k\":\"demo-36\",\"c\":\"mychannel-pnpres\",\"d\":{\"action\":
 \"state-change\", "
                           + "\"timestamp\": 1463753674, \"data\": {\"state\": 
\"cool\"}, \"uuid\": \"24c9bb19-1fcd-4c40-a6f1-522a8a1329ef\", \"occupancy\": 
3},\"b\":\"mychannel-pnpres\"}]}")));
         context.startRoute("presence-route");
-        mockResult.expectedMessageCount(1);
+        mockResult.expectedMinimumMessageCount(1);
         mockResult.expectedHeaderReceived(PubNubConstants.CHANNEL, 
"mychannel");
         assertMockEndpointsSatisfied();
         PNPresenceEventResult presence = 
mockResult.getReceivedExchanges().get(0).getIn().getBody(PNPresenceEventResult.class);
@@ -67,7 +67,7 @@ public class PubNubPresenceTest extends PubNubTestBase {
                           + "\"d\":{\"action\": \"interval\", \"timestamp\": 
1490124758, \"occupancy\": 2, \"here_now_refresh\": true, "
                           + "\"join\": 
[\"2220E216-5A30-49AD-A89C-1E0B5AE26AD7\", 
\"4262AE3F-3202-4487-BEE0-1A0D91307DEB\"]},\"b\":\"mychannel-pnpres\"}]}")));
         context.startRoute("presence-route");
-        mockResult.expectedMessageCount(1);
+        mockResult.expectedMinimumMessageCount(1);
         assertMockEndpointsSatisfied();
         PNPresenceEventResult presence = 
mockResult.getReceivedExchanges().get(0).getIn().getBody(PNPresenceEventResult.class);
         assertThat(presence.getHereNowRefresh(), equalTo(true));