xmlBlaster 2.2.0 API

Uses of Class
org.xmlBlaster.engine.SubscriptionInfo

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 to subscribe is exactly known.
 

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

Copyright © 1999-2014 The xmlBlaster.org contributers.