Examples of ClientListener

Examples of com.biasedbit.nettytutorials.handshake.client.ClientListener

23
24
25
26
27
28
29
30
31
32
33
        final CountDownLatch latch = new CountDownLatch(1);

        // Create a client with custom id, that connects to a server with given
        // id and has a message listener that ensures that ALL messages are
        // received in perfect order.
        Client c = new Client(id, serverId, new ClientListener() {
            @Override
            public void messageReceived(String message) {
                int num = Integer.parseInt(message.trim());
                if (num != (cLast.get() + 1)) {
                    System.err.println("--- CLIENT-LISTENER(" + id + ") " +
View Full Code Here

Examples of com.google.speedtracer.client.util.PostMessageChannel.ClientListener

68
69
70
71
72
73
74
75
76
77
78
  }

  public void testClientEcho() {
    final int numberOfMessages = 10;

    new Client(Document.get(), getEchoPeerUrl(), new ClientListener() {
      private int count = 0;

      public void onConnected(Client client) {
        sendMessagesThenDone(client, numberOfMessages);
      }
View Full Code Here

Examples of com.google.speedtracer.client.util.PostMessageChannel.ClientListener

95
96
97
98
99
100
101
102
103
104
105
  }

  public void testResponderEcho() {
    final int numberOfMessages = 10;

    new Client(Document.get(), getBlankUrl(), new ClientListener() {
      private int count = 0;

      public void onConnected(Client client) {
        new Responder(client.getFrameContentWindow(), client.getOrigin(),
            new EchoUntilDoneResponseListener());
View Full Code Here

Examples of com.hazelcast.core.ClientListener

82
83
84
85
86
87
88
89
90
91
92
    @Test
    public void testRemoveClientListener_whenListenerAlreadyRemoved(){
        HazelcastInstance instance = Hazelcast.newHazelcastInstance();

        ClientService clientService = instance.getClientService();
        ClientListener clientListener = mock(ClientListener.class);
        String id = clientService.addClientListener(clientListener);

        // first time remove
        clientService.removeClientListener(id);
View Full Code Here

Examples of com.hazelcast.core.ClientListener

185
186
187
188
189
190
191
192
193
194
195
        final ClientService clientService = instance.getClientService();
        final CountDownLatch latchAdd = new CountDownLatch(2);
        final CountDownLatch latchRemove = new CountDownLatch(2);
        final AtomicInteger totalAdd = new AtomicInteger(0);

        final ClientListener clientListener = new ClientListener() {
            @Override
            public void clientConnected(Client client) {
                totalAdd.incrementAndGet();
                latchAdd.countDown();
            }
View Full Code Here

Examples of org.apache.sandesha.client.ClientListener

378
379
380
381
382
383
384
385
386
387
388
    private static void startListener() {
        if (!insideServer) {
            if (!listenerStarted) {
                listenerStarted = true;
                try {
                    clientListner = new ClientListener(PropertyLoader.getClientSideListenerPort());
                    clientListner.start();
                } catch (IOException e) {
                    log.error(e);
                }
            }
View Full Code Here

Examples of org.cometd.ClientListener

33
34
35
36
37
38
39
40
41
42
43
    }

    public void testThrowingListeners() throws Exception
    {
        Message message = m("count", "1");
        ClientListener listener1 = new ThrowingMultiListener();
        MultiListener multiListener = new MultiListener();
        _client.setMaxQueue(1);
        _client.addListener(listener1);
        _client.addListener(multiListener);
View Full Code Here

Examples of org.eclipse.rap.rwt.scripting.ClientListener

214
215
216
217
218
219
220
221
222
223
224
    assertFalse( hasOperation( WidgetUtil.getId( composite ), SET, null ) );
  }

  @Test
  public void testRenderChangesRendersClientListener() throws IOException {
    composite.addListener( SWT.MouseDown, new ClientListener( "" ) );

    lca.renderChanges( composite );

    JsonObject properties = getOperationProperties( WidgetUtil.getId( composite ), CALL, "addListener" );
    assertNotNull( properties );
View Full Code Here

Examples of org.infinispan.client.hotrod.annotation.ClientListener

123
124
125
126
127
128
129
130
131
132
         }
      }
   }

   private ClientListener extractClientListener() {
      ClientListener l = ReflectionUtil.getAnnotation(listener.getClass(), ClientListener.class);
      if (l == null)
         throw log.missingClientListenerAnnotation(listener.getClass().getName());
      return l;
   }
View Full Code Here

Examples of org.infinispan.client.hotrod.annotation.ClientListener

76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
      return dedicatedTransport;
   }

   @Override
   protected Short executeOperation(Transport transport) {
      ClientListener clientListener = extractClientListener();

      HeaderParams params = writeHeader(transport, ADD_CLIENT_LISTENER_REQUEST);
      transport.writeArray(listenerId);
      transport.writeByte((short)(clientListener.includeCurrentState() ? 1 : 0));

      writeNamedFactory(transport, clientListener.filterFactoryName(), filterFactoryParams);
      writeNamedFactory(transport, clientListener.converterFactoryName(), converterFactoryParams);

      transport.flush();

      listenerNotifier.addClientListener(this);
      Either<Short, ClientEvent> either;
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.