xmlBlaster 1.6.2 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
(package private)  SubscriptionInfo TopicHandler.removeSubscriber(java.lang.String subscriptionInfoUniqueKey)
          A client wants to unSubscribe from this topic.
 SubscriptionInfo[] TopicHandler.getSubscriptionInfoArr()
          Get a snapshot of all subscriptions
 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[] ClientSubscriptions.getSubscriptions(SessionInfo sessionInfo)
          Access all subscriptions of a client
 SubscriptionInfo SubscriptionEvent.getSubscriptionInfo()
          Returns the originator of the event.
 SubscriptionInfo[] TopicAccessor.getSubscriptionInfoArrDirtyRead(java.lang.String topicId)
           
 

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.
private  boolean TopicHandler.checkIfAllowedToSend(SessionInfo publisherSessionInfo, SubscriptionInfo sub)
          Checks if it is allowed to send the entry to the callback queue.
 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
static boolean TopicHandler.isDirtyRead(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper)
          Checks if the subscriber is a cluster and the message has the 'dirtyRead' flag set.
static MsgQueueUpdateEntry TopicHandler.createEntryFromWrapper(MsgUnitWrapper msgUnitWrapper, SubscriptionInfo sub)
           
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.subscriberMayReceiveIt(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper)
           
 void SubscriptionInfo.addSubscription(SubscriptionInfo subs)
          For this query subscription remember all resulted child subscriptions
 void SubscriptionInfo.removeChildSubscription(SubscriptionInfo subs)
          For this query subscription remember all resulted subscriptions
private  void RequestBroker.subscribeToOid(SubscriptionInfo subs, boolean calleeIsXPathMatchCheck)
          Low level subscribe, is called when the to subscribe is exactly known.
(package private)  void RequestBroker.fireUnSubscribeEvent(SubscriptionInfo subscriptionInfo)
           
(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().
 

Constructors in org.xmlBlaster.engine with parameters of type SubscriptionInfo
SubscriptionInfo(ServerScope glob, SessionInfo sessionInfo, SubscriptionInfo querySub, KeyData keyData)
          Use this constructor it the subscription is a result of a XPath subscription
SubscriptionEvent(SubscriptionInfo subscriptionInfo)
          Constructs a SubscriptionEvent object.
 

Uses of SubscriptionInfo in org.xmlBlaster.engine.distributor.plugins
 

Methods in org.xmlBlaster.engine.distributor.plugins with parameters of type SubscriptionInfo
private  DispatchManager ConsumableQueuePlugin.getDispatchManager(SubscriptionInfo subscriptionInfo)
           
private  void ConsumableQueuePlugin.givingUpDistribution(SubscriptionInfo sub, MsgUnitWrapper msgUnitWrapper, MsgQueueEntry entry, java.lang.Throwable e)
           
private  UpdateReturnQosServer ConsumableQueuePlugin.doDistribute(SubscriptionInfo sub, MsgQueueUpdateEntry entry)
          Enforced by the I_DistributionInterceptor interface.
 


xmlBlaster 1.6.2 API

Copyright © 1999-2007 The xmlBlaster.org contributers.