|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use SubscriptionInfo | |
---|---|
org.xmlBlaster.engine | The core implementation. |
org.xmlBlaster.engine.distributor.plugins |
Uses of SubscriptionInfo in org.xmlBlaster.engine |
---|
Fields in org.xmlBlaster.engine declared as SubscriptionInfo | |
---|---|
private SubscriptionInfo |
SubscriptionInfo.querySub
A reference to the query subscription (XPATH), which created this subscription If the subscription was EXACT, querySub is null |
Methods in org.xmlBlaster.engine that return SubscriptionInfo | |
---|---|
SubscriptionInfo[] |
TopicHandler.findSubscriber(SessionInfo sessionInfo)
Returns SubscriptionInfo instances of this session (a session may subscribe the same message multiple times). |
SubscriptionInfo[] |
SubscriptionInfo.getChildrenSubscriptions()
For this query subscription return all resulted subscriptions |
SubscriptionInfo |
ClientSubscriptions.getSubscription(SessionInfo sessionInfo,
java.lang.String subscriptionInfoUniqueKey)
If you have the unique id of a subscription, you may access the SubscriptionInfo object here. |
SubscriptionInfo |
ClientSubscriptions.getSubscription(java.lang.String subscriptionInfoUniqueKey)
If you have the unique id of a subscription, you may access the SubscriptionInfo object here. |
SubscriptionInfo |
SubscriptionEvent.getSubscriptionInfo()
Returns the originator of the event. |
SubscriptionInfo[] |
TopicHandler.getSubscriptionInfoArr()
Get a snapshot of all subscriptions |
SubscriptionInfo[] |
TopicAccessor.getSubscriptionInfoArrDirtyRead(java.lang.String topicId)
|
SubscriptionInfo[] |
ClientSubscriptions.getSubscriptions(SessionInfo sessionInfo)
Access all subscriptions of a client |
(package private) SubscriptionInfo |
TopicHandler.removeSubscriber(java.lang.String subscriptionInfoUniqueKey)
A client wants to unSubscribe from this topic. |
Methods in org.xmlBlaster.engine that return types with arguments of type SubscriptionInfo | |
---|---|
java.util.ArrayList<SubscriptionInfo> |
ClientSubscriptions.getSubscription(SessionInfo sessionInfo,
QueryKeyData queryKey,
QueryQosData queryQos)
|
java.util.Vector<SubscriptionInfo> |
ClientSubscriptions.getSubscriptionByOid(SessionInfo sessionInfo,
java.lang.String keyOid,
boolean exactOnly)
|
Methods in org.xmlBlaster.engine with parameters of type SubscriptionInfo | |
---|---|
void |
TopicHandler.addSubscriber(SubscriptionInfo sub,
boolean calleeIsXPathMatchCheck)
A client subscribed to this message, multiple subscriptions from the same client are OK. |
void |
SubscriptionInfo.addSubscription(SubscriptionInfo subs)
For this query subscription remember all resulted child subscriptions |
boolean |
TopicHandler.checkFilter(SessionInfo publisherSessionInfo,
SubscriptionInfo sub,
MsgUnitWrapper msgUnitWrapper,
boolean handleException)
Checks if the filters allow this message to be sent to the specified session |
private boolean |
TopicHandler.checkIfAllowedToSend(SessionInfo publisherSessionInfo,
SubscriptionInfo sub)
Checks if it is allowed to send the entry to the callback queue. |
static MsgQueueUpdateEntry |
TopicHandler.createEntryFromWrapper(MsgUnitWrapper msgUnitWrapper,
SubscriptionInfo sub)
|
(package private) void |
RequestBroker.fireSubscribeEvent(SubscriptionInfo subscriptionInfo)
|
private void |
RequestBroker.fireSubscriptionEvent(SubscriptionInfo subscriptionInfo,
boolean subscribe)
Is fired on subscribe(), unSubscribe() and several times on erase(). |
(package private) void |
RequestBroker.fireUnSubscribeEvent(SubscriptionInfo subscriptionInfo)
|
private int |
TopicHandler.invokeCallback(SessionInfo publisherSessionInfo,
SubscriptionInfo sub,
MsgUnitWrapper msgUnitWrapper,
boolean doErrorHandling)
Put the message into the callback queue of the subscribed client (Pub/Sub mode only). |
static boolean |
TopicHandler.isDirtyRead(SubscriptionInfo sub,
MsgUnitWrapper msgUnitWrapper)
Checks if the subscriber is a cluster and the message has the 'dirtyRead' flag set. |
void |
SubscriptionInfo.removeChildSubscription(SubscriptionInfo subs)
For this query subscription remember all resulted subscriptions |
static boolean |
TopicHandler.subscriberMayReceiveIt(SubscriptionInfo sub,
MsgUnitWrapper msgUnitWrapper)
|
private void |
RequestBroker.subscribeToOid(SubscriptionInfo subs,
boolean calleeIsXPathMatchCheck)
Low level subscribe, is called when the |
Constructors in org.xmlBlaster.engine with parameters of type SubscriptionInfo | |
---|---|
SubscriptionEvent(SubscriptionInfo subscriptionInfo)
Constructs a SubscriptionEvent object. |
|
SubscriptionInfo(ServerScope glob,
SessionInfo sessionInfo,
SubscriptionInfo querySub,
KeyData keyData)
Use this constructor it the subscription is a result of a XPath subscription |
Uses of SubscriptionInfo in org.xmlBlaster.engine.distributor.plugins |
---|
Methods in org.xmlBlaster.engine.distributor.plugins with parameters of type SubscriptionInfo | |
---|---|
private UpdateReturnQosServer |
ConsumableQueuePlugin.doDistribute(SubscriptionInfo sub,
MsgQueueUpdateEntry entry)
Enforced by the I_DistributionInterceptor interface. |
private I_DispatchManager |
ConsumableQueuePlugin.getDispatchManager(SubscriptionInfo subscriptionInfo)
|
private void |
ConsumableQueuePlugin.givingUpDistribution(SubscriptionInfo sub,
MsgUnitWrapper msgUnitWrapper,
MsgQueueEntry entry,
java.lang.Throwable e)
|
|
xmlBlaster 2.2.0 API | |||||||||
PREV NEXT | FRAMES NO FRAMES |