|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.engine.qos.PublishQosServer
public final class PublishQosServer
Handling of publish() quality of services in the server core.
This decorator hides the real qos data object and gives us a server specific view on it.
MsgQosData
,
MsgQosSaxFactory
Field Summary | |
---|---|
private ServerScope |
glob
|
private boolean |
isClusterUpdate
|
private MsgQosData |
msgQosData
|
private TopicEntry |
topicEntry
|
Constructor Summary | |
---|---|
PublishQosServer(ServerScope glob,
MsgQosData msgQosData,
boolean fromPersistenceStore)
Constructor which accepts parsed object. |
|
PublishQosServer(ServerScope glob,
QosData msgQosData)
Constructor which accepts parsed object. |
|
PublishQosServer(ServerScope glob,
java.lang.String xmlQos)
Constructs the specialized quality of service object for a publish() call, and parses the given XML string. |
|
PublishQosServer(ServerScope glob,
java.lang.String xmlQos,
boolean fromPersistenceStore)
Constructs the specialized quality of service object for a publish() call. |
Method Summary | |
---|---|
void |
addRouteInfo(RouteInfo routeInfo)
|
void |
clearRoutes()
|
private void |
completeDestinations()
Checks for relative destination names and completes them with our cluster node id |
int |
count(NodeId nodeId)
|
boolean |
dirtyRead(NodeId nodeId)
|
MsgQosData |
getData()
Access the internal data struct |
Destination[] |
getDestinationArr()
|
java.util.ArrayList |
getDestinations()
|
SessionName |
getFirstDestination()
Currently xmlBlaster handles only one Destination |
long |
getLifeTime()
|
int |
getNumDestinations()
|
PriorityEnum |
getPriority()
|
Timestamp |
getRcvTimestamp()
|
long |
getRemainingLife()
|
RouteInfo[] |
getRouteNodes()
|
SessionName |
getSender()
|
java.lang.String |
getState()
|
TopicEntry |
getTopicEntry()
|
TopicProperty |
getTopicProperty()
|
java.lang.String |
getXmlRcvTimestamp()
|
boolean |
hasTopicProperty()
|
boolean |
isClusterUpdate()
|
boolean |
isExpired()
|
boolean |
isForceUpdate()
|
boolean |
isFromPersistenceStore()
Internal use only, is this message sent from the persistence layer? |
boolean |
isPersistent()
|
boolean |
isPtp()
|
boolean |
isReadonly()
|
boolean |
isSubscribable()
|
boolean |
isVolatile()
|
void |
removeDestination(Destination destination)
|
void |
setClusterUpdate(boolean isClusterUpdate)
The PublishQosServer supports to transport information about cluster callbacks |
void |
setFromPersistenceStore(boolean fromPersistenceStore)
Internal use only, set if this message sent from the persistence layer |
void |
setLifeTime(long lifeTime)
|
void |
setPriority(PriorityEnum priority)
|
void |
setSender(SessionName sender)
|
void |
setSubscribable(boolean isSubscribable)
|
void |
setTopicEntry(TopicEntry topicEntry)
The PublishQosServer supports to transport a topicEntry instance |
void |
touchRcvTimestamp()
|
java.lang.String |
toXml()
|
java.lang.String |
toXml(java.lang.String extraOffset)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private final ServerScope glob
private final MsgQosData msgQosData
private boolean isClusterUpdate
private TopicEntry topicEntry
Constructor Detail |
---|
public PublishQosServer(ServerScope glob, QosData msgQosData) throws XmlBlasterException
XmlBlasterException
public PublishQosServer(ServerScope glob, MsgQosData msgQosData, boolean fromPersistenceStore) throws XmlBlasterException
fromPersistenceStore
- true if recovered from persistency
XmlBlasterException
public PublishQosServer(ServerScope glob, java.lang.String xmlQos) throws XmlBlasterException
the
- XML based ASCII string
XmlBlasterException
public PublishQosServer(ServerScope glob, java.lang.String xmlQos, boolean fromPersistenceStore) throws XmlBlasterException
xmlQos
- The XML based ASCII stringfromPersistenceStore
- true if recovered from persistency
XmlBlasterException
Method Detail |
---|
private void completeDestinations() throws XmlBlasterException
XmlBlasterException
public MsgQosData getData()
public boolean isClusterUpdate()
public void setClusterUpdate(boolean isClusterUpdate)
public TopicEntry getTopicEntry()
public void setTopicEntry(TopicEntry topicEntry)
public void setSubscribable(boolean isSubscribable)
isSubscribable
- true if Publish/Subscribe style is usedpublic boolean isSubscribable()
public boolean isPtp()
public boolean isVolatile()
public boolean isPersistent()
public boolean isForceUpdate()
public boolean isReadonly()
public SessionName getSender()
public void setSender(SessionName sender)
public java.lang.String getState()
public void addRouteInfo(RouteInfo routeInfo)
QosData.addRouteInfo(RouteInfo)
public RouteInfo[] getRouteNodes()
public void clearRoutes()
public int count(NodeId nodeId)
public boolean dirtyRead(NodeId nodeId)
public PriorityEnum getPriority()
public void setPriority(PriorityEnum priority)
public boolean isFromPersistenceStore()
public void setFromPersistenceStore(boolean fromPersistenceStore)
true/false
- public void setLifeTime(long lifeTime)
public long getLifeTime()
public boolean isExpired()
public Timestamp getRcvTimestamp()
public java.lang.String getXmlRcvTimestamp()
public void touchRcvTimestamp()
public long getRemainingLife()
public SessionName getFirstDestination()
public java.util.ArrayList getDestinations()
public Destination[] getDestinationArr()
public void removeDestination(Destination destination)
public int getNumDestinations()
public boolean hasTopicProperty()
public TopicProperty getTopicProperty()
public java.lang.String toXml()
public java.lang.String toXml(java.lang.String extraOffset)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |