|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mortbay.cometd.MessagePool
org.mortbay.cometd.client.BayeuxClient
public class BayeuxClient
Bayeux protocol Client.
Implements a Bayeux Ajax Push client as part of the cometd project.
http://cometd.com
Constructor Summary | |
---|---|
BayeuxClient(HttpClient client,
Address address,
String uri)
|
|
BayeuxClient(HttpClient client,
Address address,
String uri,
Timer timer)
|
Method Summary | |
---|---|
void |
addListener(org.cometd.ClientListener listener)
|
protected void |
customize(HttpExchange exchange)
Customize an Exchange. |
void |
deliver(org.cometd.Client from,
org.cometd.Message message)
Deprecated. use deliver(Client, String, Object, String) |
void |
deliver(org.cometd.Client from,
String toChannel,
Object data,
String id)
|
void |
endBatch()
|
String |
getId()
|
org.cometd.Listener |
getListener()
Deprecated. |
int |
getMaxQueue()
|
Queue<org.cometd.Message> |
getQueue()
|
boolean |
hasMessages()
|
boolean |
isLocal()
|
boolean |
isPolling()
|
void |
publish(String toChannel,
Object data,
String msgId)
|
void |
remove(boolean timeout)
|
void |
removeListener(org.cometd.ClientListener listener)
|
void |
setCookie(Cookie cookie)
|
void |
setListener(org.cometd.Listener listener)
Deprecated. |
void |
setMaxQueue(int max)
|
void |
start()
|
void |
startBatch()
|
void |
subscribe(String toChannel)
|
List<org.cometd.Message> |
takeMessages()
|
void |
unsubscribe(String toChannel)
|
Methods inherited from class org.mortbay.cometd.MessagePool |
---|
getBatchJSON, getJSON, getMsgJSON, newMessage, newMessage, parse, parse, parseTo, recycleMessage, setBatchJSON, setJSON, setMsgJSON |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public BayeuxClient(HttpClient client, Address address, String uri, Timer timer) throws IOException
IOException
public BayeuxClient(HttpClient client, Address address, String uri) throws IOException
IOException
Method Detail |
---|
public String getId()
getId
in interface org.cometd.Client
public void start()
public boolean isPolling()
public void deliver(org.cometd.Client from, org.cometd.Message message)
deliver(Client, String, Object, String)
org.cometd.Client#deliver(org.cometd.Client, java.util.Map)
public void deliver(org.cometd.Client from, String toChannel, Object data, String id)
deliver
in interface org.cometd.Client
public org.cometd.Listener getListener()
public boolean hasMessages()
hasMessages
in interface org.cometd.Client
public boolean isLocal()
isLocal
in interface org.cometd.Client
public void publish(String toChannel, Object data, String msgId)
public void subscribe(String toChannel)
public void unsubscribe(String toChannel)
public void remove(boolean timeout)
public void setListener(org.cometd.Listener listener)
public List<org.cometd.Message> takeMessages()
takeMessages
in interface org.cometd.Client
public void endBatch()
endBatch
in interface org.cometd.Client
public void startBatch()
startBatch
in interface org.cometd.Client
protected void customize(HttpExchange exchange)
public void setCookie(Cookie cookie)
public void addListener(org.cometd.ClientListener listener)
addListener
in interface org.cometd.Client
public void removeListener(org.cometd.ClientListener listener)
removeListener
in interface org.cometd.Client
public int getMaxQueue()
getMaxQueue
in interface org.cometd.Client
public Queue<org.cometd.Message> getQueue()
getQueue
in interface org.cometd.Client
public void setMaxQueue(int max)
setMaxQueue
in interface org.cometd.Client
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |