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

Field Summary

protected AbstractBayeux

_bayeux

Constructor Summary

protected	ClientImpl(AbstractBayeux bayeux)
protected	ClientImpl(AbstractBayeux bayeux, String idPrefix)

Method Summary

void	addListener(org.cometd.ClientListener listener)
protected void	addSubscription(ChannelImpl channel)
void	deliver(org.cometd.Client from, String toChannel, Object data, String id)
protected void	doDelivery(org.cometd.Client from, org.cometd.Message message)
void	endBatch()
boolean	equals(Object o)
int	getAdviceVersion()
String	getBrowserId()
String	getConnectionType()
String	getId()
int	getMessages()
long	getTimeout()
boolean	hasMessages()
boolean	isJSONCommented()
boolean	isLocal()
void	remove(boolean timeout)
void	removeListener(org.cometd.ClientListener listener)
protected void	removeSubscription(ChannelImpl channel)
int	responded()
int	responsePending()
void	resume() Called by deliver to resume anything waiting on this client.
void	returnMessage(org.cometd.Message message)
void	returnMessages(List<org.cometd.Message> messages)
void	setAdviceVersion(int version)
void	setBrowserId(String id)
protected void	setConnectionType(String type)
protected void	setId(String _id)
void	setJSONCommented(boolean commented)
void	setTimeout(long timeoutMS)
void	startBatch()
org.cometd.Message	takeMessage()
List<org.cometd.Message>	takeMessages()
String	toString()
protected void	unsubscribeAll()

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

_bayeux

protected AbstractBayeux _bayeux

Constructor Detail

ClientImpl

protected ClientImpl(AbstractBayeux bayeux)

ClientImpl

protected ClientImpl(AbstractBayeux bayeux,
                     String idPrefix)

Method Detail

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)

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)

takeMessage

public org.cometd.Message takeMessage()

returnMessage

public void returnMessage(org.cometd.Message message)

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

getAdviceVersion

public int getAdviceVersion()

Returns:

the advised

setAdviceVersion

public void setAdviceVersion(int version)

Parameters:

advised - the advised to set

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)