Package org.cometd.server

Class ServerMessageImpl

java.lang.Object

java.util.AbstractMap<K,V>

java.util.HashMap<String,Object>

org.cometd.common.HashMapMessage

org.cometd.server.ServerMessageImpl

All Implemented Interfaces:

Serializable, Cloneable, Map<String,Object>, Message, Message.Mutable, ServerMessage, ServerMessage.Mutable

public class ServerMessageImpl
extends HashMapMessage
implements ServerMessage.Mutable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.AbstractMap

AbstractMap.SimpleEntry<K extends Object,V extends Object>, AbstractMap.SimpleImmutableEntry<K extends Object,V extends Object>

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K extends Object,V extends Object>

Nested classes/interfaces inherited from interface org.cometd.bayeux.Message

Message.Mutable

Nested classes/interfaces inherited from interface org.cometd.bayeux.server.ServerMessage

ServerMessage.Mutable

Field Summary

Fields inherited from interface org.cometd.bayeux.Message

ADVICE_FIELD, CHANNEL_FIELD, CLIENT_ID_FIELD, CONNECTION_TYPE_FIELD, DATA_FIELD, ERROR_FIELD, EXT_FIELD, ID_FIELD, INTERVAL_FIELD, MAX_INTERVAL_FIELD, MIN_VERSION_FIELD, RECONNECT_FIELD, RECONNECT_HANDSHAKE_VALUE, RECONNECT_NONE_VALUE, RECONNECT_RETRY_VALUE, SUBSCRIPTION_FIELD, SUCCESSFUL_FIELD, SUPPORTED_CONNECTION_TYPES_FIELD, TIMEOUT_FIELD, TIMESTAMP_FIELD, TRANSPORT_FIELD, VERSION_FIELD

Constructor Summary

Constructors

Constructor	Description
ServerMessageImpl()

Method Summary

Modifier and Type	Method	Description
Set<Map.Entry<String,Object>>	entrySet()
protected void	freeze(String json)
Map<String,Object>	getAdvice()	Convenience method to retrieve the Message.ADVICE_FIELD
ServerMessage.Mutable	getAssociated()
BayeuxContext	getBayeuxContext()
Object	getData()	Convenience method to retrieve the Message.DATA_FIELD
Map<String,Object>	getDataAsMap()
Map<String,Object>	getExt()	Convenience method to retrieve the Message.EXT_FIELD
String	getJSON()
byte[]	getJSONBytes()
ServerTransport	getServerTransport()
protected boolean	isFrozen()
boolean	isHandled()
boolean	isLazy()
Object	put(String key, Object value)
void	setAssociated(ServerMessage.Mutable associated)
void	setBayeuxContext(BayeuxContext context)
void	setHandled(boolean handled)
void	setLazy(boolean lazy)	A lazy message does not provoke immediately delivery to the client but it will be delivered at first occasion or after a timeout expires
void	setServerTransport(ServerTransport transport)

Methods inherited from class org.cometd.common.HashMapMessage

getAdvice, getChannel, getChannelId, getClientId, getDataAsMap, getExt, getId, isMeta, isPublishReply, isSuccessful, setChannel, setClientId, setData, setId, setSuccessful

Methods inherited from class java.util.HashMap

clear, clone, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, forEach, get, getOrDefault, isEmpty, keySet, merge, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Methods inherited from class java.util.AbstractMap

equals, hashCode, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Map

clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, equals, forEach, get, getOrDefault, hashCode, isEmpty, keySet, merge, putAll, putIfAbsent, remove, remove, replace, replace, replaceAll, size, values

Methods inherited from interface org.cometd.bayeux.Message

getChannel, getChannelId, getClientId, getId, isMeta, isPublishReply, isSuccessful

Methods inherited from interface org.cometd.bayeux.Message.Mutable

getAdvice, getDataAsMap, getExt, setChannel, setClientId, setData, setId, setSuccessful

Constructor Detail

ServerMessageImpl

public ServerMessageImpl()

Method Detail

getAssociated

public ServerMessage.Mutable getAssociated()

Specified by:

getAssociated in interface ServerMessage

Returns:

a message associated with this message on the server. Typically this is a meta message that the current message is being sent in response to.

setAssociated

public void setAssociated(ServerMessage.Mutable associated)

Specified by:

setAssociated in interface ServerMessage.Mutable

Parameters:

associated - the message associated with this message

isLazy

public boolean isLazy()

Specified by:

isLazy in interface ServerMessage

Returns:

true if the message is lazy and should not force the session's queue to be flushed

isHandled

public boolean isHandled()

getBayeuxContext

public BayeuxContext getBayeuxContext()

Specified by:

getBayeuxContext in interface ServerMessage

Returns:

the BayeuxContext associated with this message

setBayeuxContext

public void setBayeuxContext(BayeuxContext context)

getServerTransport

public ServerTransport getServerTransport()

Specified by:

getServerTransport in interface ServerMessage

Returns:

the ServerTransport associated with this message

setServerTransport

public void setServerTransport(ServerTransport transport)

setLazy

public void setLazy(boolean lazy)

Description copied from interface: ServerMessage.Mutable

A lazy message does not provoke immediately delivery to the client but it will be delivered at first occasion or after a timeout expires

Specified by:

setLazy in interface ServerMessage.Mutable

Parameters:

lazy - whether the message is lazy

setHandled

public void setHandled(boolean handled)

freeze

protected void freeze(String json)

isFrozen

protected boolean isFrozen()

getJSON

public String getJSON()

Specified by:

getJSON in interface Message

Overrides:

getJSON in class HashMapMessage

Returns:

this message as a JSON string

getJSONBytes

public byte[] getJSONBytes()

getData

public Object getData()

Description copied from interface: Message

Convenience method to retrieve the Message.DATA_FIELD

Specified by:

getData in interface Message

Overrides:

getData in class HashMapMessage

Returns:

the data of the message

See Also:

Message.getDataAsMap()

put

public Object put(String key,
                  Object value)

Specified by:

put in interface Map<String,Object>

Overrides:

put in class HashMap<String,Object>

entrySet

public Set<Map.Entry<String,Object>> entrySet()

Specified by:

entrySet in interface Map<String,Object>

Overrides:

entrySet in class HashMap<String,Object>

getDataAsMap

public Map<String,Object> getDataAsMap()

Specified by:

getDataAsMap in interface Message

Overrides:

getDataAsMap in class HashMapMessage

Returns:

the data of the message as a map

See Also:

Message.getData()

getExt

public Map<String,Object> getExt()

Description copied from interface: Message

Convenience method to retrieve the Message.EXT_FIELD

Specified by:

getExt in interface Message

Overrides:

getExt in class HashMapMessage

Returns:

the ext of the message

getAdvice

public Map<String,Object> getAdvice()

Description copied from interface: Message

Convenience method to retrieve the Message.ADVICE_FIELD

Specified by:

getAdvice in interface Message

Overrides:

getAdvice in class HashMapMessage

Returns:

the advice of the message