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

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

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 connectedPayload = (WebSocketClosedPayload) wsPayload;
View Full Code Here
114
115
116
117
118
119
120
   * @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
145
146
147
148
149
150
151
   * @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
68
69
70
71
72
73
74
75
76
77
78
        onMessage(webSocketHandler, binaryData);
      }
      else if (wsPayload instanceof WebSocketConnectedPayload)
      {
        WebSocketConnectedPayload connectedPayload = (WebSocketConnectedPayload) wsPayload;
        ConnectedMessage message = connectedPayload.getMessage();
        onConnect(message);
      }
      else if (wsPayload instanceof WebSocketClosedPayload)
      {
        WebSocketClosedPayload connectedPayload = (WebSocketClosedPayload) wsPayload;
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
    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
105
106
107
108
109
110
111
   * @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
67
68
69
70
71
72
73
74
75
76
77
        onMessage(webSocketHandler, binaryData);
      }
      else if (wsPayload instanceof WebSocketConnectedPayload)
      {
        WebSocketConnectedPayload connectedPayload = (WebSocketConnectedPayload) wsPayload;
        ConnectedMessage message = connectedPayload.getMessage();
        onConnect(message);
      }
      else if (wsPayload instanceof WebSocketClosedPayload)
      {
        WebSocketClosedPayload connectedPayload = (WebSocketClosedPayload) wsPayload;
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
      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
64
65
66
67
68
69
70
71
72
73
74
        onMessage(webSocketHandler, binaryData);
      }
      else if (wsPayload instanceof WebSocketConnectedPayload)
      {
        WebSocketConnectedPayload connectedPayload = (WebSocketConnectedPayload) wsPayload;
        ConnectedMessage message = connectedPayload.getMessage();
        onConnect(message);
      }
      else if (wsPayload instanceof WebSocketClosedPayload)
      {
        WebSocketClosedPayload connectedPayload = (WebSocketClosedPayload) wsPayload;
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
    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.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.