Examples of addMessageListener()

Examples of com.aelitis.azureus.core.messenger.ClientMessageContext.addMessageListener()

50
51
52
53
54
55
56
57
58
59
60
 
      final Boolean[] b = new Boolean[1];
      b[0] = Boolean.FALSE;
 
      ClientMessageContext context = browserWindow.getContext();
      context.addMessageListener(new AbstractBrowserMessageListener(
          "contentnetwork") {
        public void handleMessage(BrowserMessage message) {
          String opid = message.getOperationId();
 
          if ("authorize".equals(opid)) {
View Full Code Here

Examples of com.aelitis.azureus.ui.swt.browser.BrowserContext.addMessageListener()

131
132
133
134
135
136
137
138
139
140
141
    try {
      browser = Utils.createSafeBrowser(shell, SWT.NONE);
      if (browser != null) {
        BrowserContext context = new BrowserContext("DevicesFTUX", browser, null, true);
 
        context.addMessageListener(new TorrentListener());
        context.addMessageListener(new VuzeListener());
        context.addMessageListener(new DisplayListener(browser));
        context.addMessageListener(new ConfigListener(browser));
      }
    } catch (Throwable t) {
View Full Code Here

Examples of com.aelitis.azureus.ui.swt.browser.BrowserContext.addMessageListener()

132
133
134
135
136
137
138
139
140
141
142
      browser = Utils.createSafeBrowser(shell, SWT.NONE);
      if (browser != null) {
        BrowserContext context = new BrowserContext("DevicesFTUX", browser, null, true);
 
        context.addMessageListener(new TorrentListener());
        context.addMessageListener(new VuzeListener());
        context.addMessageListener(new DisplayListener(browser));
        context.addMessageListener(new ConfigListener(browser));
      }
    } catch (Throwable t) {
    }
View Full Code Here

Examples of com.aelitis.azureus.ui.swt.browser.BrowserContext.addMessageListener()

133
134
135
136
137
138
139
140
141
142
143
      if (browser != null) {
        BrowserContext context = new BrowserContext("DevicesFTUX", browser, null, true);
 
        context.addMessageListener(new TorrentListener());
        context.addMessageListener(new VuzeListener());
        context.addMessageListener(new DisplayListener(browser));
        context.addMessageListener(new ConfigListener(browser));
      }
    } catch (Throwable t) {
    }
View Full Code Here

Examples of com.aelitis.azureus.ui.swt.browser.BrowserContext.addMessageListener()

134
135
136
137
138
139
140
141
142
143
144
        BrowserContext context = new BrowserContext("DevicesFTUX", browser, null, true);
 
        context.addMessageListener(new TorrentListener());
        context.addMessageListener(new VuzeListener());
        context.addMessageListener(new DisplayListener(browser));
        context.addMessageListener(new ConfigListener(browser));
      }
    } catch (Throwable t) {
    }

    Label lblInfo = new Label(shell, SWT.WRAP);
View Full Code Here

Examples of com.hazelcast.core.ITopic.addMessageListener()

176
177
178
179
180
181
182
183
184
185
186
        }
    }

    private List<Runnable> loadTopicOperations() {
        ITopic topic = hazelcast.getTopic("myTopic");
        topic.addMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                messagesReceived.incrementAndGet();
            }
        });
        List<Runnable> operations = new ArrayList<Runnable>();
View Full Code Here

Examples of com.hazelcast.topic.TopicService.addMessageListener()

51
52
53
54
55
56
57
58
59
60
61
    public String call() throws Exception {
        TopicService service = getService();
        ClientEngine clientEngine = getClientEngine();
        ClientEndpoint endpoint = getEndpoint();
        MessageListener listener = new MessageListenerImpl(endpoint, clientEngine, getCallId());
        String registrationId = service.addMessageListener(name, listener);
        endpoint.setListenerRegistration(TopicService.SERVICE_NAME, name, registrationId);
        return registrationId;
    }

    @Override
View Full Code Here

Examples of com.hazelcast.topic.impl.TopicService.addMessageListener()

47
48
49
50
51
52
53
54
55
56
57
    @Override
    public String call() throws Exception {
        TopicService service = getService();
        ClientEndpoint endpoint = getEndpoint();
        MessageListener listener = new MessageListenerImpl(endpoint, getCallId());
        String registrationId = service.addMessageListener(name, listener);
        endpoint.setListenerRegistration(TopicService.SERVICE_NAME, name, registrationId);
        return registrationId;
    }

    @Override
View Full Code Here

Examples of com.jme3.network.Client.addMessageListener()

41
42
43
44
45
46
47
48
49
50
51
    if (cisClient == null)
      return;

    HandshakeController handshakeController = new HandshakeController(cisClient, callback);
    cisClient.addClientStateListener(handshakeController);
    cisClient.addMessageListener(handshakeController, GameVersionMessage.class, GameInformationMessage.class,
        AuthorizeMessage.class);
    cisClient.addMessageListener(this, UserDataMessage.class);
    gameApp.addGameDestroyCallback(new IGameDestroyCallback() {
      @Override
      public void destroy() {
View Full Code Here

Examples of com.jme3.network.Server.addMessageListener()

49
50
51
52
53
54
55
56
57
58
59
  public void simpleInitApp() {
    try {
      Server cisServer = Network.createServer(tcpPort, udpPort);

      cisServer.addConnectionListener(serverConnectionListener);
      cisServer.addMessageListener(serverMessageListener);

      cisServer.start();

      LogFactory.getLog(ServerMain.class).info("Server is running...");
    } catch (IOException e) {
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.