Repository: camel Updated Branches: refs/heads/master 50d134f72 -> ff6e52ebb
Add test of HereNowRefresh. Upgrade to PubNub 4.6.4 Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/ff6e52eb Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/ff6e52eb Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/ff6e52eb Branch: refs/heads/master Commit: ff6e52ebb922c86b7278b8184b8a46d5d57ef5e4 Parents: eef3590 Author: Preben Asmussen <preben.asmus...@gmail.com> Authored: Sat Jun 10 09:57:45 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat Jun 10 10:13:46 2017 +0200 ---------------------------------------------------------------------- .../camel/component/pubnub/PubNubPresenceTest.java | 17 +++++++++++++++++ parent/pom.xml | 2 +- 2 files changed, 18 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/ff6e52eb/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java ---------------------------------------------------------------------- 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 e49fdf8..dc83b81 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 @@ -56,6 +56,23 @@ public class PubNubPresenceTest extends PubNubTestBase { assertThat(presence.getOccupancy(), equalTo(3)); } + @Test + public void testPresenceWithHereNowRefresh() throws Exception { + stubFor(get(urlPathEqualTo("/v2/presence/sub-key/mySubscribeKey/channel/mychannel/heartbeat")) + .willReturn(aResponse().withBody("{\"status\": 200, \"message\": \"OK\", \"service\": \"Presence\"}"))); + + stubFor(get(urlPathEqualTo("/v2/subscribe/mySubscribeKey/mychannel,mychannel-pnpres/0")) + .willReturn(aResponse() + .withBody("{\"t\":{\"t\":\"14901247588021627\",\"r\":2},\"m\":[{\"a\":\"4\",\"f\":0,\"p\":{\"t\":\"14901247587675704\",\"r\":1},\"k\":\"demo-36\",\"c\":\"mychannel-pnpres\"," + + "\"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); + assertMockEndpointsSatisfied(); + PNPresenceEventResult presence = mockResult.getReceivedExchanges().get(0).getIn().getBody(PNPresenceEventResult.class); + assertThat(presence.getHereNowRefresh(), equalTo(true)); + } + @Override protected RouteBuilder createRouteBuilder() throws Exception { http://git-wip-us.apache.org/repos/asf/camel/blob/ff6e52eb/parent/pom.xml ---------------------------------------------------------------------- diff --git a/parent/pom.xml b/parent/pom.xml index ab56773..09eb014 100644 --- a/parent/pom.xml +++ b/parent/pom.xml @@ -537,7 +537,7 @@ <protobuf-version>3.1.0</protobuf-version> <protobuf-guava-version>18.0</protobuf-guava-version> <protobuf-maven-plugin-version>0.5.0</protobuf-maven-plugin-version> - <pubnub-version>4.6.3</pubnub-version> + <pubnub-version>4.6.4</pubnub-version> <qpid-bundle-version>0.28_1</qpid-bundle-version> <qpid-proton-j-version>0.16.0</qpid-proton-j-version> <qpid-proton-j-bundle-version>0.14.0</qpid-proton-j-bundle-version>
