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.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 voidfreeze(String json)Map<String,Object>getAdvice()Convenience method to retrieve theMessage.ADVICE_FIELDServerMessage.MutablegetAssociated()ObjectgetData()Convenience method to retrieve theMessage.DATA_FIELDMap<String,Object>getDataAsMap()Map<String,Object>getExt()Convenience method to retrieve theMessage.EXT_FIELDStringgetJSON()byte[]getJSONBytes()protected booleanisFrozen()booleanisLazy()Objectput(String key, Object value)voidsetAssociated(ServerMessage.Mutable associated)voidsetLazy(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 expiresMethods inherited from class org.cometd.common.HashMapMessage
getAdvice, getChannel, getChannelId, getClientId, getDataAsMap, getExt, getId, isMeta, isPublishReply, isSuccessful, setChannel, setClientId, setData, setId, setSuccessfulMethods 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, valuesMethods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, waitMethods 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, valuesMethods inherited from interface org.cometd.bayeux.Message
getChannel, getChannelId, getClientId, getId, isMeta, isPublishReply, isSuccessfulMethods inherited from interface org.cometd.bayeux.Message.Mutable
getAdvice, getDataAsMap, getExt, setChannel, setClientId, setData, setId, setSuccessful
-
Constructor Details
-
ServerMessageImpl
public ServerMessageImpl()
-
-
Method Details
-
getAssociated
- Specified by:
getAssociatedin interfaceServerMessage- 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
- Specified by:
setAssociatedin interfaceServerMessage.Mutable- Parameters:
associated- the message associated with this message
-
isLazy
public boolean isLazy()- Specified by:
isLazyin interfaceServerMessage- Returns:
- true if the message is lazy and should not force the session's queue to be flushed
-
setLazy
public void setLazy(boolean lazy)Description copied from interface:ServerMessage.MutableA 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:
setLazyin interfaceServerMessage.Mutable- Parameters:
lazy- whether the message is lazy
-
freeze
-
isFrozen
protected boolean isFrozen() -
getJSON
- Specified by:
getJSONin interfaceMessage- Overrides:
getJSONin classHashMapMessage- Returns:
- this message as a JSON string
-
getJSONBytes
public byte[] getJSONBytes() -
getData
Description copied from interface:MessageConvenience method to retrieve theMessage.DATA_FIELD- Specified by:
getDatain interfaceMessage- Overrides:
getDatain classHashMapMessage- Returns:
- the data of the message
- See Also:
Message.getDataAsMap()
-
put
-
entrySet
-
getDataAsMap
- Specified by:
getDataAsMapin interfaceMessage- Overrides:
getDataAsMapin classHashMapMessage- Returns:
- the data of the message as a map
- See Also:
Message.getData()
-
getExt
Description copied from interface:MessageConvenience method to retrieve theMessage.EXT_FIELD- Specified by:
getExtin interfaceMessage- Overrides:
getExtin classHashMapMessage- Returns:
- the ext of the message
-
getAdvice
Description copied from interface:MessageConvenience method to retrieve theMessage.ADVICE_FIELD- Specified by:
getAdvicein interfaceMessage- Overrides:
getAdvicein classHashMapMessage- Returns:
- the advice of the message
-