Package org.apache.wicket.protocol.ws.api

Examples of org.apache.wicket.protocol.ws.api.WebSocketPushBroadcaster

52
53
54
55
56
57
58
59
60
61
62
63
64
      protected void onMessage(WebSocketRequestHandler handler, TextMessage message)
      {
        log.info("Received message {}", message.getText());
        FeedItem feedItem = new FeedItem(message.getText());
        IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(getApplication());
        WebSocketPushBroadcaster broadcaster =
            new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
        broadcaster.broadcastAll(Application.get(), feedItem);
        latestMessage.setDefaultModelObject(feedItem).modelChanged();
        log.info("AddContent: {}", handler);
        handler.add(latestMessage);
      }
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
57
        final FeedItem feedItem = new FeedItem(message);
        latestMessage.setDefaultModelObject(feedItem);
        ajaxMessage.setModelObject(null);
        target.add(ajaxForm);
        IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(getApplication());
        WebSocketPushBroadcaster broadcaster =
            new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
        broadcaster.broadcastAll(Application.get(), feedItem);
      }
    });

  };
View Full Code Here
20
21
22
23
24
25
26
27
28
  public void run()
  {
    log.info("Sending timestamp to feed");
    FeedItem feedItem = new FeedItem("------ TIMESTAMP --------");
    IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(application);
    WebSocketPushBroadcaster broadcaster =
        new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    broadcaster.broadcastAll(application, feedItem);
  }
View Full Code Here
143
144
145
146
147
148
149
150
151
   *          The message to broadcast/push
   */
  public void broadcast(Application application, String sessionId, IKey key, IWebSocketPushMessage message)
  {
    IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(application);
    WebSocketPushBroadcaster broadcaster = new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    ConnectedMessage wsMessage = new ConnectedMessage(application, sessionId, key);
    broadcaster.broadcast(wsMessage, message);
  }
View Full Code Here
159
160
161
162
163
164
165
166
   *          The message to broadcast/push
   */
  public void broadcastAll(Application application, IWebSocketPushMessage message)
  {
    IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(application);
    WebSocketPushBroadcaster broadcaster = new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    broadcaster.broadcastAll(application, message);
  }
View Full Code Here
143
144
145
146
147
148
149
150
151
   *          The message to broadcast/push
   */
  public void broadcast(Application application, String sessionId, IKey key, IWebSocketPushMessage message)
  {
    WebSocketSettings webSocketSettings = WebSocketSettings.Holder.get(application);
    WebSocketPushBroadcaster broadcaster = new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    ConnectedMessage wsMessage = new ConnectedMessage(application, sessionId, key);
    broadcaster.broadcast(wsMessage, message);
  }
View Full Code Here
159
160
161
162
163
164
165
166
   *          The message to broadcast/push
   */
  public void broadcastAll(Application application, IWebSocketPushMessage message)
  {
    WebSocketSettings webSocketSettings = WebSocketSettings.Holder.get(application);
    WebSocketPushBroadcaster broadcaster = new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    broadcaster.broadcastAll(application, message);
  }
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
160
    tester.startPage(page);
    tester.getSession().bind();

    new WebSocketTester(tester, page);
    IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(tester.getApplication());
    WebSocketPushBroadcaster broadcaster = new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    ConnectedMessage wsMessage = new ConnectedMessage(tester.getApplication(),
        tester.getHttpSession().getId(), page.getPageId());
    broadcaster.broadcast(wsMessage, new BroadcastMessage(message));

    assertEquals(true, messageReceived.get());
  }
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
162
    tester.startPage(page);
    tester.getSession().bind();

    new WebSocketTester(tester, page);
    IWebSocketSettings webSocketSettings = IWebSocketSettings.Holder.get(tester.getApplication());
    WebSocketPushBroadcaster broadcaster = new WebSocketPushBroadcaster(webSocketSettings.getConnectionRegistry());
    ConnectedMessage wsMessage = new ConnectedMessage(tester.getApplication(),
        tester.getHttpSession().getId(), new PageIdKey(page.getPageId()));
    broadcaster.broadcast(wsMessage, new BroadcastMessage(message));

    assertEquals(true, messageReceived.get());
  }
View Full Code Here
TOP

Related Classes of org.apache.wicket.protocol.ws.api.WebSocketPushBroadcaster

  • com.wicketinaction.AddContentAjaxPanel
  • com.wicketinaction.AddContentWebSocketPanel
  • com.wicketinaction.TimestamperTask
  • org.apache.wicket.Application
  • org.apache.wicket.protocol.ws.api.registry.IKey
  • org.apache.wicket.protocol.ws.concurrent.Executor
  • org.apache.wicket.protocol.ws.IWebSocketSettings
  • org.apache.wicket.protocol.ws.util.tester.WebSocketTester
  • org.apache.wicket.protocol.ws.util.tester.WebSocketTesterBehaviorTest
  • org.apache.wicket.protocol.ws.util.tester.WebSocketTesterTest
    • Copyright © 2018 www.massapicom. 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.