|
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.SubscribeQosServer
public final class SubscribeQosServer
Handling of subscribe() quality of services in the server core.
This decorator hides the real qos data object and gives us a server specific view on it.
QoS Informations sent from the client to the server via the subscribe() method
They are needed to control xmlBlaster
For the xml representation see QueryQosSaxFactory.
QueryQosData
,
QueryQosSaxFactory
Field Summary | |
---|---|
private boolean |
doInhibitInitialUpdates
|
private Global |
glob
|
private QueryQosData |
queryQosData
|
Constructor Summary | |
---|---|
SubscribeQosServer(Global glob,
QueryQosData queryQosData)
Constructor which accepts a raw data struct. |
|
SubscribeQosServer(Global glob,
java.lang.String xmlQos)
Constructs the specialized quality of service object for a subscribe() call. |
Method Summary | |
---|---|
AccessFilterQos[] |
getAccessFilterArr()
Return the subscribe filters or null if none is specified. |
QueryQosData |
getData()
Access the internal data struct |
Global |
getGlobal()
|
HistoryQos |
getHistoryQos()
Query the message history |
boolean |
getMultiSubscribe()
Are multiple subscribes allowed? Defaults to true. |
QuerySpecQos[] |
getQuerySpecArr()
Return the get querySpecs or null if none is specified. |
java.lang.String |
getSubscriptionId()
Get the identifier (unique handle) for this subscription. |
boolean |
getWantContent()
If false, the update contains not the content (it is a notify of change only) TODO: Implement in server!!! |
boolean |
getWantInitialUpdate()
|
boolean |
getWantLocal()
false Inhibit the delivery of messages to myself if i have published it. |
boolean |
getWantMeta()
|
boolean |
getWantNotify()
|
boolean |
getWantUpdateOneway()
|
void |
inhibitInitalUpdates(boolean doInhibit)
Inhibits the initial updates even if the qosData.wantInitialUpdates has been set. |
boolean |
isRecoveredFromPersistenceStore()
|
boolean |
newestOnly()
if __newestOnly client property is true remove older instances from callback queue of client |
void |
setSubscriptionId(java.lang.String subscriptionId)
|
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 QueryQosData queryQosData
private boolean doInhibitInitialUpdates
private final Global glob
Constructor Detail |
---|
public SubscribeQosServer(Global glob, QueryQosData queryQosData)
public SubscribeQosServer(Global glob, java.lang.String xmlQos) throws XmlBlasterException
the
- XML based ASCII string
XmlBlasterException
Method Detail |
---|
public QueryQosData getData()
public Global getGlobal()
public boolean isRecoveredFromPersistenceStore()
public final AccessFilterQos[] getAccessFilterArr()
public final QuerySpecQos[] getQuerySpecArr()
public HistoryQos getHistoryQos()
public boolean getWantInitialUpdate()
public boolean getWantUpdateOneway()
public boolean getWantNotify()
public boolean newestOnly()
public boolean getMultiSubscribe()
public boolean getWantLocal()
public boolean getWantMeta()
public boolean getWantContent()
public final void setSubscriptionId(java.lang.String subscriptionId)
public final java.lang.String getSubscriptionId()
public void inhibitInitalUpdates(boolean doInhibit)
doInhibit
- 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 |