org.mortbay.cometd
Class ClientImpl
java.lang.Object
org.mortbay.cometd.ClientImpl
- All Implemented Interfaces:
- org.cometd.Client
- Direct Known Subclasses:
- ContinuationClient
public class ClientImpl
- extends Object
- implements org.cometd.Client
- Author:
- gregw
_bayeux
protected AbstractBayeux _bayeux
ClientImpl
protected ClientImpl(AbstractBayeux bayeux)
ClientImpl
protected ClientImpl(AbstractBayeux bayeux,
String idPrefix)
deliver
public void deliver(org.cometd.Client from,
String toChannel,
Object data,
String id)
- Specified by:
deliver
in interface org.cometd.Client
doDelivery
protected void doDelivery(org.cometd.Client from,
org.cometd.Message message)
doDeliverListeners
public void doDeliverListeners()
startBatch
public void startBatch()
- Specified by:
startBatch
in interface org.cometd.Client
endBatch
public void endBatch()
- Specified by:
endBatch
in interface org.cometd.Client
getConnectionType
public String getConnectionType()
getId
public String getId()
- Specified by:
getId
in interface org.cometd.Client
hasMessages
public boolean hasMessages()
- Specified by:
hasMessages
in interface org.cometd.Client
isJSONCommented
public boolean isJSONCommented()
- Returns:
- the commented
isLocal
public boolean isLocal()
- Specified by:
isLocal
in interface org.cometd.Client
remove
public void remove(boolean timeout)
responded
public int responded()
responsePending
public int responsePending()
resume
public void resume()
- Called by deliver to resume anything waiting on this client.
setJSONCommented
public void setJSONCommented(boolean commented)
- Parameters:
commented
- the commented to set
getMessages
public int getMessages()
takeMessages
public List<org.cometd.Message> takeMessages()
- Specified by:
takeMessages
in interface org.cometd.Client
returnMessages
public void returnMessages(List<org.cometd.Message> messages)
toString
public String toString()
- Overrides:
toString
in class Object
addSubscription
protected void addSubscription(ChannelImpl channel)
removeSubscription
protected void removeSubscription(ChannelImpl channel)
setConnectionType
protected void setConnectionType(String type)
setId
protected void setId(String _id)
unsubscribeAll
protected void unsubscribeAll()
setBrowserId
public void setBrowserId(String id)
getBrowserId
public String getBrowserId()
equals
public boolean equals(Object o)
- Overrides:
equals
in class Object
getAdvice
public JSON.Literal getAdvice()
- Get the advice specific for this Client
- Returns:
- advice specific for this client or null
setAdvice
public void setAdvice(JSON.Literal advice)
- Parameters:
advice
- specific for this client
addListener
public void addListener(org.cometd.ClientListener listener)
- Specified by:
addListener
in interface org.cometd.Client
removeListener
public void removeListener(org.cometd.ClientListener listener)
- Specified by:
removeListener
in interface org.cometd.Client
getTimeout
public long getTimeout()
setTimeout
public void setTimeout(long timeoutMS)
setMaxQueue
public void setMaxQueue(int maxQueue)
- Specified by:
setMaxQueue
in interface org.cometd.Client
getMaxQueue
public int getMaxQueue()
- Specified by:
getMaxQueue
in interface org.cometd.Client
getQueue
public Queue<org.cometd.Message> getQueue()
- Specified by:
getQueue
in interface org.cometd.Client
Copyright © 1995-2008 Mort Bay Consulting. All Rights Reserved.