|
||||||||||
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.AbstractBayeux
public abstract class AbstractBayeux
Nested Class Summary | |
---|---|
protected class |
AbstractBayeux.ConnectHandler
|
static class |
AbstractBayeux.DefaultPolicy
|
protected class |
AbstractBayeux.DisconnectHandler
|
protected class |
AbstractBayeux.Handler
|
protected class |
AbstractBayeux.HandshakeHandler
|
protected class |
AbstractBayeux.MetaPublishHandler
|
protected class |
AbstractBayeux.PingHandler
|
protected class |
AbstractBayeux.PublishHandler
|
protected class |
AbstractBayeux.ServiceChannel
|
protected class |
AbstractBayeux.SubscribeHandler
|
protected class |
AbstractBayeux.UnsubscribeHandler
|
Field Summary | |
---|---|
protected JSON.Literal |
_advice
|
protected int |
_adviceVersion
|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,java.util.List<java.lang.String>> |
_browser2client
|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,ChannelId> |
_channelIdCache
|
protected java.util.List<org.cometd.ChannelBayeuxListener> |
_channelListeners
|
protected java.util.List<org.cometd.ClientBayeuxListener> |
_clientListeners
|
protected org.cometd.Extension[] |
_extensions
|
protected java.lang.Object |
_handshakeAdvice
|
protected boolean |
_initialized
|
protected long |
_interval
|
protected int |
_logLevel
|
protected int |
_maxClientQueue
|
protected long |
_maxInterval
|
protected int |
_maxLazyLatency
|
protected AbstractBayeux.Handler |
_metaPublishHandler
|
protected JSON.Literal |
_multiFrameAdvice
|
protected int |
_multiFrameInterval
|
protected AbstractBayeux.Handler |
_publishHandler
|
protected java.util.Random |
_random
|
protected java.lang.ThreadLocal<javax.servlet.http.HttpServletRequest> |
_request
|
protected boolean |
_requestAvailable
|
protected org.cometd.SecurityPolicy |
_securityPolicy
|
protected long |
_timeout
|
protected JSON.Literal |
_transports
|
static ChannelId |
META_CLIENT_ID
|
static ChannelId |
META_CONNECT_ID
|
static ChannelId |
META_DISCONNECT_ID
|
static ChannelId |
META_HANDSHAKE_ID
|
static ChannelId |
META_ID
|
static ChannelId |
META_PING_ID
|
static ChannelId |
META_STATUS_ID
|
static ChannelId |
META_SUBSCRIBE_ID
|
static ChannelId |
META_UNSUBSCRIBE_ID
|
Fields inherited from interface org.cometd.Bayeux |
---|
ADVICE_FIELD, ATTRIBUTE, CHANNEL_FIELD, CLIENT_FIELD, CONNECTION_TYPE_FIELD, DATA_FIELD, ERROR_FIELD, EXT_FIELD, HANDSHAKE_RESPONSE, ID_FIELD, INTERVAL_FIELD, JSON_COMMENT_FILTERED_FIELD, JSON_CONTENT_TYPE, JSONP_DEFAULT_NAME, JSONP_PARAMETER, MESSAGE_PARAMETER, META, META_CLIENT, META_CONNECT, META_DISCONNECT, META_HANDSHAKE, META_PING, META_SLASH, META_STATUS, META_SUBSCRIBE, META_UNSUBSCRIBE, MIN_VERSION_FIELD, NONE_RESPONSE, RECONNECT_FIELD, RETRY_RESPONSE, SERVICE, SERVICE_SLASH, SUBSCRIPTION_FIELD, SUCCESSFUL_FIELD, SUPPORTED_CONNECTION_TYPES_FIELD, TIMESTAMP_FIELD, TRANSPORT_CALLBACK_POLL, TRANSPORT_FIELD, TRANSPORT_FLASH, TRANSPORT_IFRAME, TRANSPORT_LONG_POLL, VERSION_FIELD |
Constructor Summary | |
---|---|
protected |
AbstractBayeux()
|
Method Summary | |
---|---|
protected void |
addChannel(ChannelImpl channel)
|
protected void |
addClient(ClientImpl client,
java.lang.String idPrefix)
|
void |
addExtension(org.cometd.Extension ext)
|
void |
addListener(org.cometd.BayeuxListener listener)
|
protected void |
doPublish(ChannelId to,
org.cometd.Client from,
java.lang.Object data,
java.lang.String msgId,
boolean lazy)
Publish data to a channel. |
protected org.cometd.Message |
extendRcv(ClientImpl from,
org.cometd.Message message)
|
protected org.cometd.Message |
extendRcvMeta(ClientImpl from,
org.cometd.Message message)
|
protected org.cometd.Message |
extendSendBayeux(org.cometd.Client from,
org.cometd.Message message)
|
org.cometd.Message |
extendSendClient(org.cometd.Client from,
ClientImpl to,
org.cometd.Message message)
|
org.cometd.Message |
extendSendMeta(ClientImpl from,
org.cometd.Message message)
|
JSON.Literal |
getAdvice()
|
ChannelImpl |
getChannel(ChannelId id)
|
ChannelImpl |
getChannel(java.lang.String id)
|
org.cometd.Channel |
getChannel(java.lang.String id,
boolean create)
|
int |
getChannelCount()
|
ChannelId |
getChannelId(java.lang.String id)
|
int |
getChannelIdCacheLimit()
|
java.util.Collection<org.cometd.Channel> |
getChannels()
|
org.cometd.Client |
getClient(java.lang.String client_id)
|
int |
getClientCount()
|
java.util.Set<java.lang.String> |
getClientIDs()
|
java.util.Collection<org.cometd.Client> |
getClients()
|
javax.servlet.http.HttpServletRequest |
getCurrentRequest()
|
long |
getInterval()
|
int |
getLogLevel()
|
int |
getMaxClientQueue()
|
long |
getMaxInterval()
|
int |
getMaxLazyLatency()
|
int |
getMultiFrameInterval()
|
org.cometd.SecurityPolicy |
getSecurityPolicy()
|
long |
getTimeout()
|
java.lang.String |
handle(ClientImpl client,
Transport transport,
org.cometd.Message message)
Handle a Bayeux message. |
boolean |
hasChannel(java.lang.String id)
|
boolean |
hasClient(java.lang.String clientId)
|
protected void |
initialize(javax.servlet.ServletContext context)
|
boolean |
isDirectDeliver()
|
boolean |
isInitialized()
|
boolean |
isJSONCommented()
Deprecated. |
boolean |
isLogDebug()
|
boolean |
isLogInfo()
|
boolean |
isRequestAvailable()
|
void |
logDebug(java.lang.String message)
|
void |
logDebug(java.lang.String message,
java.lang.Throwable th)
|
void |
logInfo(java.lang.String message)
|
void |
logWarn(java.lang.String message)
|
void |
logWarn(java.lang.String message,
java.lang.Throwable th)
|
org.cometd.Client |
newClient(java.lang.String idPrefix)
|
protected java.lang.String |
newClientId(long variation,
java.lang.String idPrefix)
|
abstract ClientImpl |
newRemoteClient()
|
Transport |
newTransport(ClientImpl client,
java.util.Map<?,?> message)
Create new transport object for a bayeux message |
boolean |
removeChannel(ChannelImpl channel)
|
org.cometd.Channel |
removeChannel(java.lang.String channelId)
|
org.cometd.Client |
removeClient(java.lang.String client_id)
|
void |
removeExtension(org.cometd.Extension ext)
|
void |
removeListener(org.cometd.BayeuxListener listener)
|
void |
setAdvice(JSON.Literal advice)
|
void |
setChannelIdCacheLimit(int channelIdCacheLimit)
Sets the cache limit for ChannelId s: use -1 to disable the cache, 0 for
an unlimited cache, and any positive value for the limit after which the cache
is cleared. |
void |
setDirectDeliver(boolean directDeliver)
Deprecated. |
void |
setInterval(long ms)
|
void |
setJSONCommented(boolean commented)
|
void |
setLogLevel(int logLevel)
|
void |
setMaxClientQueue(int size)
|
void |
setMaxInterval(long ms)
|
void |
setMaxLazyLatency(int ms)
|
void |
setMultiFrameInterval(int multiFrameInterval)
The time a client should delay between reconnects when multiple connections from the same browser are detected. |
void |
setRequestAvailable(boolean requestAvailable)
|
void |
setSecurityPolicy(org.cometd.SecurityPolicy securityPolicy)
|
void |
setTimeout(long ms)
|
Methods inherited from class org.mortbay.cometd.MessagePool |
---|
getBatchJSON, getJSON, getMsgJSON, newMessage, newMessage, parse, parse, parseTo, setBatchJSON, setJSON, setMsgJSON, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final ChannelId META_ID
public static final ChannelId META_CONNECT_ID
public static final ChannelId META_CLIENT_ID
public static final ChannelId META_DISCONNECT_ID
public static final ChannelId META_HANDSHAKE_ID
public static final ChannelId META_PING_ID
public static final ChannelId META_STATUS_ID
public static final ChannelId META_SUBSCRIBE_ID
public static final ChannelId META_UNSUBSCRIBE_ID
protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,ChannelId> _channelIdCache
protected final java.util.concurrent.ConcurrentHashMap<java.lang.String,java.util.List<java.lang.String>> _browser2client
protected final java.lang.ThreadLocal<javax.servlet.http.HttpServletRequest> _request
protected final java.util.List<org.cometd.ClientBayeuxListener> _clientListeners
protected final java.util.List<org.cometd.ChannelBayeuxListener> _channelListeners
protected final AbstractBayeux.Handler _publishHandler
protected final AbstractBayeux.Handler _metaPublishHandler
protected org.cometd.SecurityPolicy _securityPolicy
protected JSON.Literal _advice
protected JSON.Literal _multiFrameAdvice
protected int _adviceVersion
protected java.lang.Object _handshakeAdvice
protected int _logLevel
protected long _timeout
protected long _interval
protected long _maxInterval
protected boolean _initialized
protected int _multiFrameInterval
protected boolean _requestAvailable
protected java.util.Random _random
protected int _maxClientQueue
protected org.cometd.Extension[] _extensions
protected JSON.Literal _transports
protected int _maxLazyLatency
Constructor Detail |
---|
protected AbstractBayeux()
Method Detail |
---|
public void addExtension(org.cometd.Extension ext)
addExtension
in interface org.cometd.Bayeux
public void removeExtension(org.cometd.Extension ext)
removeExtension
in interface org.cometd.Bayeux
public ChannelImpl getChannel(ChannelId id)
id
- the channel id
public ChannelImpl getChannel(java.lang.String id)
public org.cometd.Channel getChannel(java.lang.String id, boolean create)
getChannel
in interface org.cometd.Bayeux
public ChannelId getChannelId(java.lang.String id)
public org.cometd.Client getClient(java.lang.String client_id)
getClient
in interface org.cometd.Bayeux
public java.util.Set<java.lang.String> getClientIDs()
public long getMaxInterval()
public int getLogLevel()
public org.cometd.SecurityPolicy getSecurityPolicy()
getSecurityPolicy
in interface org.cometd.Bayeux
public long getTimeout()
public long getInterval()
public boolean isDirectDeliver()
public void setDirectDeliver(boolean directDeliver)
directDeliver
- true if published messages are directly delivered to
subscribers. False if a new message is to be created that
holds only supported fields.public java.lang.String handle(ClientImpl client, Transport transport, org.cometd.Message message) throws java.io.IOException
client
- The client if knowntransport
- The transport to use for the messagemessage
- The bayeux message.
java.io.IOException
- if the handle failspublic boolean hasChannel(java.lang.String id)
hasChannel
in interface org.cometd.Bayeux
public boolean isInitialized()
public boolean isJSONCommented()
public boolean isLogDebug()
public boolean isLogInfo()
public void logDebug(java.lang.String message)
public void logDebug(java.lang.String message, java.lang.Throwable th)
public void logWarn(java.lang.String message, java.lang.Throwable th)
public void logWarn(java.lang.String message)
public void logInfo(java.lang.String message)
public org.cometd.Client newClient(java.lang.String idPrefix)
newClient
in interface org.cometd.Bayeux
public abstract ClientImpl newRemoteClient()
public Transport newTransport(ClientImpl client, java.util.Map<?,?> message)
client
- The clientmessage
- the bayeux message
protected void doPublish(ChannelId to, org.cometd.Client from, java.lang.Object data, java.lang.String msgId, boolean lazy)
to
- the channel id to publish tofrom
- the client that publishesdata
- the data to publishmsgId
- the message idlazy
- whether the message is published lazilypublic boolean removeChannel(ChannelImpl channel)
protected void addChannel(ChannelImpl channel)
protected java.lang.String newClientId(long variation, java.lang.String idPrefix)
protected void addClient(ClientImpl client, java.lang.String idPrefix)
public org.cometd.Client removeClient(java.lang.String client_id)
removeClient
in interface org.cometd.Bayeux
public void setMaxInterval(long ms)
ms
- The maximum time in ms to wait between polls before timing out
a clientpublic void setJSONCommented(boolean commented)
commented
- the commented to setpublic void setLogLevel(int logLevel)
logLevel
- the logLevel: 0=none, 1=info, 2=debugpublic void setSecurityPolicy(org.cometd.SecurityPolicy securityPolicy)
setSecurityPolicy
in interface org.cometd.Bayeux
public void setTimeout(long ms)
public void setInterval(long ms)
public void setMultiFrameInterval(int multiFrameInterval)
multiFrameInterval
- the multiFrameInterval to setpublic int getMultiFrameInterval()
public int getChannelIdCacheLimit()
ChannelId
cachesetChannelIdCacheLimit(int)
public void setChannelIdCacheLimit(int channelIdCacheLimit)
ChannelId
s: use -1 to disable the cache, 0 for
an unlimited cache, and any positive value for the limit after which the cache
is cleared.
channelIdCacheLimit
- the limit of the ChannelId
cachegetChannelIdCacheLimit()
public void setAdvice(JSON.Literal advice)
public JSON.Literal getAdvice()
public boolean isRequestAvailable()
getCurrentRequest()
will return the current
requestpublic void setRequestAvailable(boolean requestAvailable)
requestAvailable
- TRUE if getCurrentRequest()
will return the current
requestpublic javax.servlet.http.HttpServletRequest getCurrentRequest()
getCurrentRequest
in interface org.cometd.Bayeux
isRequestAvailable()
is true,
else nullpublic java.util.Collection<org.cometd.Channel> getChannels()
getChannels
in interface org.cometd.Bayeux
public int getChannelCount()
public java.util.Collection<org.cometd.Client> getClients()
getClients
in interface org.cometd.Bayeux
public int getClientCount()
public boolean hasClient(java.lang.String clientId)
hasClient
in interface org.cometd.Bayeux
public org.cometd.Channel removeChannel(java.lang.String channelId)
removeChannel
in interface org.cometd.Bayeux
protected void initialize(javax.servlet.ServletContext context)
public void addListener(org.cometd.BayeuxListener listener)
addListener
in interface org.cometd.Bayeux
public void removeListener(org.cometd.BayeuxListener listener)
removeListener
in interface org.cometd.Bayeux
public int getMaxClientQueue()
getMaxClientQueue
in interface org.cometd.Bayeux
public void setMaxClientQueue(int size)
setMaxClientQueue
in interface org.cometd.Bayeux
protected org.cometd.Message extendRcv(ClientImpl from, org.cometd.Message message)
protected org.cometd.Message extendRcvMeta(ClientImpl from, org.cometd.Message message)
protected org.cometd.Message extendSendBayeux(org.cometd.Client from, org.cometd.Message message)
public org.cometd.Message extendSendClient(org.cometd.Client from, ClientImpl to, org.cometd.Message message)
public org.cometd.Message extendSendMeta(ClientImpl from, org.cometd.Message message)
public int getMaxLazyLatency()
public void setMaxLazyLatency(int ms)
ms
- the maximum ms that a lazy message will wait before
resuming waiting client
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |