Package org.cometd.bayeux.client

Examples of org.cometd.bayeux.client.ClientSessionChannel.unsubscribe()

332
333
334
335
336
337
338
339
340
341
342
            final ClientSessionChannel.MessageListener listener = listenerMap.remove(consumer);
            if (listener != null) {

                LOG.info("Unsubscribing from channel {}...", channelName);
                final ClientSessionChannel clientChannel = client.getChannel(channelName);
                clientChannel.unsubscribe(listener);

                // confirm unsubscribe
                try {
                    if (!latch.await(CHANNEL_TIMEOUT, SECONDS)) {
                        String message;
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        channel.publish("test");

        Assert.assertFalse(messageLatch.await(1, TimeUnit.SECONDS));

        final CountDownLatch unsubscribeLatch = new CountDownLatch(1);
        channel.unsubscribe(listener, new ClientSessionChannel.MessageListener()
        {
            @Override
            public void onMessage(ClientSessionChannel channel, Message message)
            {
                Assert.assertTrue(message.isSuccessful());
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
        String data = "data";
        aChannel.publish(data);
        message = messages.poll(5, TimeUnit.SECONDS);
        Assert.assertEquals(data, message.getData());

        aChannel.unsubscribe(subscriber);
        message = metaMessages.poll(5, TimeUnit.SECONDS);
        Assert.assertEquals(Channel.META_UNSUBSCRIBE, message.getChannel());
        Assert.assertTrue(message.isSuccessful());

        disconnectBayeuxClient(client);
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
            public void onMessage(ClientSessionChannel channel, Message message)
            {
                unsubscribe.countDown();
            }
        });
        channel.unsubscribe(listener);
        Assert.assertTrue(unsubscribe.await(5, TimeUnit.SECONDS));
        Assert.assertTrue(channel.getSubscribers().isEmpty());
        released = channel.release();

        Assert.assertTrue(released);
View Full Code Here
284
285
286
287
288
289
290
291
292
293
294
        {
        }

        try
        {
            channel.unsubscribe(listener);
            Assert.fail();
        }
        catch (IllegalStateException expected)
        {
        }
View Full Code Here
293
294
295
296
297
298
299
300
301
302
303
        {
        }

        try
        {
            channel.unsubscribe();
            Assert.fail();
        }
        catch (IllegalStateException expected)
        {
        }
View Full Code Here
143
144
145
146
147
148
149
150
151
152
153
        client.batch(new Runnable()
        {
            public void run()
            {
                channel.subscribe(listener);
                channel.unsubscribe(listener);
            }
        });
        Assert.assertTrue(latch.await(5, TimeUnit.SECONDS));

        Assert.assertEquals(0, extension.rcvs.size());
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        assertTrue(subscribeLatch.await(5, TimeUnit.SECONDS));

        channel.publish(new HashMap<>());
        assertTrue(publishLatch.await(5, TimeUnit.SECONDS));

        channel.unsubscribe();
        assertTrue(unsubscribeLatch.await(5, TimeUnit.SECONDS));

        disconnectBayeuxClient(client);
    }
View Full Code Here
464
465
466
467
468
469
470
471
472
473
474
        String data = "data";
        aChannel.publish(data);
        Assert.assertTrue(publishLatch.await(5, TimeUnit.SECONDS));

        aChannel.unsubscribe(subscriber);
        Assert.assertTrue(unsubscribeLatch.await(5, TimeUnit.SECONDS));

        disconnectBayeuxClient(client);
    }
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
        Assert.assertEquals("hello",events.poll());
        Assert.assertEquals(session1.getId(),events.poll());
        Assert.assertEquals("hello",events.poll());
        Assert.assertEquals(session2.getId(),events.poll());
        Assert.assertEquals("hello",events.poll());
        foostar0.unsubscribe(listener);

        session1.batch(new Runnable()
        {
            public void run()
            {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.