Examples of ConnectMessage

Examples of asia.stampy.client.message.connect.ConnectMessage

44
45
46
47
48
49
50
    listener = new TestClientMessageListener();
    listener.setGateway(gateway);
    gateway.addMessageListener(listener, 1);

    gateway.connect();
    gateway.broadcastMessage(new ConnectMessage("localhost"));
  }
View Full Code Here

Examples of asia.stampy.client.message.connect.ConnectMessage

154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
    sendStomp("host");
    sleep();
    evaluateError(LOGIN_AND_PASSCODE_NOT_SPECIFIED);

    ConnectMessage message = new ConnectMessage("1.1", "burt.alexander");
    message.getHeader().setLogin(SystemLoginHandler.GOOD_USER);
    message.getHeader().setPasscode("pass");
    getGateway().broadcastMessage(message);
    sleep();
    evaluateError(ONLY_STOMP_VERSION_1_2_IS_SUPPORTED);

    message.getHeader().removeHeader(ConnectHeader.ACCEPT_VERSION);
    message.getHeader().setAcceptVersion("1.2");
    message.getHeader().setHeartbeat(500, 1000);
    getGateway().broadcastMessage(message);
    sleep();
    evaluateConnect();

    getGateway().broadcastMessage(message);
View Full Code Here

Examples of asia.stampy.client.message.connect.ConnectMessage

285
286
287
288
289
290
291
292
293
294
295
296
    System.out.println();
    receipt = null;
  }

  private void goodConnect() throws InterceptException {
    ConnectMessage message = new ConnectMessage("burt.alexander");
    message.getHeader().setLogin(SystemLoginHandler.GOOD_USER);
    message.getHeader().setPasscode("pass");
    message.getHeader().setHeartbeat(500, 1000);

    getGateway().broadcastMessage(message);
  }
View Full Code Here

Examples of asia.stampy.client.message.connect.ConnectMessage

294
295
296
297
298
299
300
301
302
303
304
305
    getGateway().broadcastMessage(message);
  }

  private void badConnect() throws InterceptException {
    ConnectMessage message = new ConnectMessage("burt.alexander");
    message.getHeader().setLogin(SystemLoginHandler.BAD_USER);
    message.getHeader().setPasscode("pass");
    message.getHeader().setHeartbeat(500, 1000);

    getGateway().broadcastMessage(message);
  }
View Full Code Here

Examples of asia.stampy.client.message.connect.ConnectMessage

387
388
389
390
391
392
393
394
    message.getHeader().setReceipt(id);
    getGateway().broadcastMessage(message);
  }

  private void sendConnect(String id) throws InterceptException {
    ConnectMessage message = new ConnectMessage(id);
    getGateway().broadcastMessage(message);
  }
View Full Code Here

Examples of asia.stampy.client.message.connect.ConnectMessage

50
51
52
53
54
55
56
   */
  public void init() throws Exception {
    setGateway(NettyInitializer.initialize());
    gateway.addMessageListener(new TestClientMessageListener());
    gateway.connect();
    gateway.broadcastMessage(new ConnectMessage("localhost"));
  }
View Full Code Here

Examples of asia.stampy.client.message.connect.ConnectMessage

208
209
210
211
212
213
214
215
216
217
218
      break;
    case COMMIT:
      message = (MSG) new CommitMessage();
      break;
    case CONNECT:
      message = (MSG) new ConnectMessage();
      break;
    case CONNECTED:
      message = (MSG) new ConnectedMessage();
      break;
    case DISCONNECT:
View Full Code Here

Examples of com.corundumstudio.socketio.store.pubsub.ConnectMessage

189
190
191
192
193
194
195
196
197
198
199
            Packet packet = new Packet(PacketType.MESSAGE);
            packet.setSubType(PacketType.CONNECT);
            client.send(packet);

            configuration.getStoreFactory().pubSubStore().publish(PubSubStore.CONNECT, new ConnectMessage(client.getSessionId()));

            SocketIOClient nsClient = client.addNamespaceClient(ns);
            ns.onConnect(nsClient);
        }
    }
View Full Code Here

Examples of com.corundumstudio.socketio.store.pubsub.ConnectMessage

181
182
183
184
185
186
187
188
189
190
191
        disconnectScheduler.cancel(key);
    }

    public void connect(MainBaseClient client) {
        connect(client.getSessionId());
        configuration.getStoreFactory().pubSubStore().publish(PubSubStore.CONNECT, new ConnectMessage(client.getSessionId()));

        client.send(new Packet(PacketType.CONNECT));

        Namespace ns = namespacesHub.get(Namespace.DEFAULT_NAME);
        SocketIOClient nsClient = client.addChildClient(ns);
View Full Code Here

Examples of com.corundumstudio.socketio.store.pubsub.ConnectMessage

186
187
188
189
190
191
192
193
194
195
196
        authorizedSessionIds.remove(sessionId);
    }

    public void connect(MainBaseClient client) {
        connect(client.getSessionId());
        configuration.getStoreFactory().getPubSubStore().publish(PubSubStore.CONNECT, new ConnectMessage(client.getSessionId()));

        client.send(new Packet(PacketType.CONNECT));

        Namespace ns = namespacesHub.get(Namespace.DEFAULT_NAME);
        SocketIOClient nsClient = client.getChildClient(ns);
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.