You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/10/03 09:30:18 UTC
[camel] branch camel-2.21.x updated: CAMEL-12852 - use minimum
expected message count
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 <ap...@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 <ap...@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));