public class SharedObjectMessage extends BaseEvent implements ISharedObjectMessage
IEvent.Type
header, object, refcount, source, timestamp
HANDSHAKE_SIZE, HEADER_CONTINUE, HEADER_NEW, HEADER_SAME_SOURCE, HEADER_TIMER_CHANGE, MEDIUM_INT_MAX, SO_CLIENT_CLEAR_DATA, SO_CLIENT_DELETE_DATA, SO_CLIENT_INITIAL_DATA, SO_CLIENT_SEND_MESSAGE, SO_CLIENT_STATUS, SO_CLIENT_UPDATE_ATTRIBUTE, SO_CLIENT_UPDATE_DATA, SO_CONNECT, SO_DELETE_ATTRIBUTE, SO_DISCONNECT, SO_SEND_MESSAGE, SO_SET_ATTRIBUTE, SOURCE_TYPE_LIVE, SOURCE_TYPE_VOD, TYPE_ABORT, TYPE_AGGREGATE, TYPE_AUDIO_DATA, TYPE_BYTES_READ, TYPE_CHUNK_SIZE, TYPE_CLIENT_BANDWIDTH, TYPE_EDGE_ORIGIN, TYPE_FLEX_MESSAGE, TYPE_FLEX_SHARED_OBJECT, TYPE_FLEX_STREAM_SEND, TYPE_INVOKE, TYPE_NOTIFY, TYPE_PING, TYPE_SERVER_BANDWIDTH, TYPE_SHARED_OBJECT, TYPE_STREAM_METADATA, TYPE_VIDEO_DATA
Constructor and Description |
---|
SharedObjectMessage() |
SharedObjectMessage(IEventListener source,
String name,
int version,
boolean persistent)
Creates Shared Object event with given listener, name, SO version and
persistence flag
|
SharedObjectMessage(String name,
int version,
boolean persistent)
Creates Shared Object event with given name, version and persistence flag
|
Modifier and Type | Method and Description |
---|---|
void |
addEvent(ISharedObjectEvent.Type type,
String key,
Object value)
Addition event handler
|
void |
addEvent(ISharedObjectEvent event)
Add event handler
|
void |
addEvents(List<ISharedObjectEvent> events) |
void |
addEvents(Queue<ISharedObjectEvent> events) |
void |
clear()
Clear shared object
|
byte |
getDataType()
Getter for data type
|
ConcurrentLinkedQueue<ISharedObjectEvent> |
getEvents()
Returns a set of ISharedObjectEvent objects containing informations what
to change.
|
String |
getName()
Returns the name of the shared object this message belongs to.
|
Object |
getObject()
Returns event context object
|
IEvent.Type |
getType()
Returns even type
|
int |
getVersion()
Returns the version to modify.
|
boolean |
isEmpty()
Is empty?
|
boolean |
isPersistent()
Does the message affect a persistent shared object?
|
void |
readExternal(ObjectInput in) |
protected void |
releaseInternal()
Release event
|
protected void |
setName(String name)
Setter for name
|
protected void |
setPersistent(boolean persistent)
Setter for persistence flag
|
protected void |
setVersion(int version)
Setter for version
|
String |
toString() |
void |
writeExternal(ObjectOutput out) |
getHeader, getSource, getSourceType, getTimestamp, hasSource, release, retain, setHeader, setSource, setSourceType, setTimestamp, setType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getHeader, getSourceType, getTimestamp, release, retain, setHeader, setSource, setSourceType, setTimestamp
public SharedObjectMessage()
public SharedObjectMessage(String name, int version, boolean persistent)
name
- Event nameversion
- SO versionpersistent
- SO persistence flagpublic SharedObjectMessage(IEventListener source, String name, int version, boolean persistent)
source
- Event listenername
- Event nameversion
- SO versionpersistent
- SO persistence flagpublic byte getDataType()
getDataType
in interface IRTMPEvent
getDataType
in class BaseEvent
public int getVersion()
getVersion
in interface ISharedObjectMessage
protected void setVersion(int version)
version
- New versionpublic String getName()
getName
in interface ISharedObjectMessage
protected void setName(String name)
name
- Event namepublic boolean isPersistent()
isPersistent
in interface ISharedObjectMessage
protected void setPersistent(boolean persistent)
persistent
- Persistence flagpublic void addEvent(ISharedObjectEvent event)
addEvent
in interface ISharedObjectMessage
event
- SO eventpublic void addEvents(List<ISharedObjectEvent> events)
public void addEvents(Queue<ISharedObjectEvent> events)
public ConcurrentLinkedQueue<ISharedObjectEvent> getEvents()
getEvents
in interface ISharedObjectMessage
public void addEvent(ISharedObjectEvent.Type type, String key, Object value)
addEvent
in interface ISharedObjectMessage
type
- Event typekey
- Handler keyvalue
- Event value (like arguments)public void clear()
clear
in interface ISharedObjectMessage
public boolean isEmpty()
isEmpty
in interface ISharedObjectMessage
true
if shared object is empty, false
otherwisepublic IEvent.Type getType()
public Object getObject()
protected void releaseInternal()
releaseInternal
in class BaseEvent
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class BaseEvent
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class BaseEvent
IOException
Copyright © 2006-2012 The Red5 Project