Package org.cometd

Examples of org.cometd.Client

68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
        Map<String, String> membersMap = _members.get(roomName);
        String peerName = (String)data.get("peer");
        String peerId = membersMap.get(peerName);
  if (peerId!=null)
        {
            Client peer = getBayeux().getClient(peerId);
      if (peer!=null)
      {
    Map<String, Object> message = new HashMap<String, Object>();
    message.put("chat", data.get("chat"));
    message.put("user", data.get("user"));
    message.put("scope", "private");
    peer.deliver(getClient(), roomName, message, messageId);
                if (!peerId.equals(source.getId()))
        source.deliver(getClient(), roomName, message, messageId);
    return;
            }
  }
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
     */
    public void remove(boolean timeout)
    {
        synchronized(this)
        {
            Client client=_bayeux.removeClient(_id);  
            if (_bayeux.isLogInfo())
                _bayeux.logInfo("Remove client "+client+" timeout="+timeout);
            if (_browserId!=null)
                _bayeux.clientOffBrowser(getBrowserId(),_id);
            _browserId=null;
View Full Code Here
201
202
203
204
205
206
207
208
209
    {
        synchronized(this)
        {
            if (client_id==null)
                return null;
            Client client = _clients.get(client_id);
            return client;
        }
    }
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
229
        Channel channel=_bayeux.getChannel(channelId,true);

        if (((ChannelImpl)channel).getChannelId().isWild())
        {
            final Method m=method;
            Client wild_client=_bayeux.newClient(_name+"-wild");
            wild_client.addListener(_listener instanceof MessageListener.Asynchronous?new AsyncWildListen(wild_client,m):new SyncWildListen(wild_client,m));
            channel.subscribe(wild_client);
        }
        else
        {
            _methods.put(channelId,method);
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
        Map<String, String> membersMap = _members.get(roomName);
        String peerName = (String)data.get("peer");
        String peerId = membersMap.get(peerName);
  if (peerId!=null)
        {
            Client peer = getBayeux().getClient(peerId);
      if (peer!=null)
      {
    Map<String, Object> message = new HashMap<String, Object>();
    message.put("chat", data.get("chat"));
    message.put("user", data.get("user"));
    message.put("scope", "private");
    peer.deliver(getClient(), roomName, message, messageId);
    source.deliver(getClient(), roomName, message, messageId);
    return;
            }
  }
  Map<String, Object> message = new HashMap<String, Object>();
View Full Code Here
TOP

Related Classes of org.cometd.Client

  • org.cometd.demo.ChatService
  • org.cometd.oort.Oort
  • org.mortbay.cometd.AbstractBayeux
  • org.mortbay.cometd.BayeuxService
  • org.mortbay.cometd.client.ChatService
  • org.mortbay.cometd.ClientImpl
  • org.mortbay.cometd.session.BayeuxSessionManager$SessionExt
    • 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.