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

Examples of org.apache.wicket.protocol.ws.api.message.ConnectedMessage

144
145
146
147
148
149
150
151
   */
  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
181
182
183
184
185
186
187
   */
  protected final void onConnect(final IWebSocketConnection connection)
  {
    IKey key = getRegistryKey();
    connectionRegistry.setConnection(getApplication(), getSessionId(), key, connection);
    broadcastMessage(new ConnectedMessage(getApplication(), getSessionId(), key));
  }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
      onMessage(webSocketHandler, binaryData);
    }
    else if (payload instanceof WebSocketConnectedPayload)
    {
      WebSocketConnectedPayload connectedPayload = (WebSocketConnectedPayload) payload;
      ConnectedMessage message = connectedPayload.getMessage();
      onConnect(message);
    }
    else if (payload instanceof WebSocketClosedPayload)
    {
      WebSocketClosedPayload connectedPayload = (WebSocketClosedPayload) payload;
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
        onMessage(webSocketHandler, binaryData);
      }
      else if (wsPayload instanceof WebSocketConnectedPayload)
      {
        WebSocketConnectedPayload connectedPayload = (WebSocketConnectedPayload) wsPayload;
        ConnectedMessage message = connectedPayload.getMessage();
        onConnect(message);
      }
      else if (wsPayload instanceof WebSocketClosedPayload)
      {
        WebSocketClosedPayload closedPayload = (WebSocketClosedPayload) wsPayload;
View Full Code Here
148
149
150
151
152
153
154
   */
  protected final void onConnect(final IWebSocketConnection connection)
  {
    IKey key = getRegistryKey();
    connectionRegistry.setConnection(getApplication(), getSessionId(), key, connection);
    broadcastMessage(new ConnectedMessage(getApplication(), getSessionId(), key));
  }
View Full Code Here
144
145
146
147
148
149
150
151
   */
  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
148
149
150
151
152
153
154
   */
  protected final void onConnect(final IWebSocketConnection connection)
  {
    IKey key = getRegistryKey();
    connectionRegistry.setConnection(getApplication(), getSessionId(), key, connection);
    broadcastMessage(new ConnectedMessage(getApplication(), getSessionId(), key));
  }
View Full Code Here
176
177
178
179
180
181
182
   */
  protected final void onConnect(final IWebSocketConnection connection)
  {
    IKey key = getRegistryKey();
    connectionRegistry.setConnection(getApplication(), getSessionId(), key, connection);
    broadcastMessage(new ConnectedMessage(getApplication(), getSessionId(), key));
  }
View Full Code Here
180
181
182
183
184
185
186
   */
  protected final void onConnect(final IWebSocketConnection connection)
  {
    IKey key = getRegistryKey();
    connectionRegistry.setConnection(getApplication(), getSessionId(), key, connection);
    broadcastMessage(new ConnectedMessage(getApplication(), getSessionId(), key));
  }
View Full Code Here
108
109
110
111
112
113
114
   * @see #onOpen(Object)
   */
  protected final void onConnect(final IWebSocketConnection connection)
  {
    connectionRegistry.setConnection(getApplication(), getSessionId(), pageId, connection);
    broadcastMessage(new ConnectedMessage(getApplication(), getSessionId(), pageId));
  }
View Full Code Here
TOP

Related Classes of org.apache.wicket.protocol.ws.api.message.ConnectedMessage

  • org.apache.wicket.protocol.ws.api.AbstractWebSocketProcessor
  • org.apache.wicket.protocol.ws.api.WebSocketBehavior
  • org.apache.wicket.protocol.ws.api.WebSocketResource
  • 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.