weborb.messaging.v3
Class Subscriber

java.lang.Object
  weborb.messaging.v3.Subscriber

public class Subscriber
extends java.lang.Object

Constructor Summary

Subscriber(java.lang.String selectorName, IDestination destination)

Method Summary

java.util.ArrayList	filterMessages(java.util.List messages)
int	getChannelId()
java.lang.String	getClientId()
org.red5.server.net.rtmp.RTMPConnection	getConnection()
IDestination	getDestination()
java.lang.String	getDSId()
long	getLastRequestTime()
java.lang.Object	getProperty(java.lang.String key)
IMessageSelector	getSelector()
java.lang.String	getStringSelector()
java.lang.String	getSubtopic()
void	removeProperty(java.lang.String key)
void	setChannelId(int value)
void	setClientId(java.lang.String clientId)
void	setConnection(org.red5.server.net.rtmp.RTMPConnection value)
void	setDSId(java.lang.String dsId)
void	setLastRequestTime(long time)
void	setProperty(java.lang.String key, java.lang.Object value)
void	setSelector(IMessageSelector selector)
void	setSubtopic(java.lang.String subtopic)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Subscriber

public Subscriber(java.lang.String selectorName,
                  IDestination destination)

Method Detail

getChannelId

public int getChannelId()

setChannelId

public void setChannelId(int value)

getConnection

public org.red5.server.net.rtmp.RTMPConnection getConnection()

setConnection

public void setConnection(org.red5.server.net.rtmp.RTMPConnection value)

getProperty

public java.lang.Object getProperty(java.lang.String key)

setProperty

public void setProperty(java.lang.String key,
                        java.lang.Object value)

removeProperty

public void removeProperty(java.lang.String key)

getStringSelector

public java.lang.String getStringSelector()

getDSId

public java.lang.String getDSId()

setDSId

public void setDSId(java.lang.String dsId)

getClientId

public java.lang.String getClientId()

setClientId

public void setClientId(java.lang.String clientId)

getSubtopic

public java.lang.String getSubtopic()

setSubtopic

public void setSubtopic(java.lang.String subtopic)

getDestination

public IDestination getDestination()

getSelector

public IMessageSelector getSelector()

setSelector

public void setSelector(IMessageSelector selector)

setLastRequestTime

public void setLastRequestTime(long time)

getLastRequestTime

public long getLastRequestTime()

filterMessages

public java.util.ArrayList filterMessages(java.util.List messages)