Examples of PollingManager

org.apache.sandesha2.polling.PollingManager
This class is responsible for sending MakeConnection requests. This is a seperate thread that keeps running. Will do MakeConnection based on the request queue or randomly.

Examples of org.apache.sandesha2.polling.PollingManager

    if (rmsBean.getOfferedSequence()!=null) {
      RMDBeanMgr rMDBeanMgr = storageManager.getRMDBeanMgr();
      RMDBean rMDBean = rMDBeanMgr.retrieve(sequenceId);
      
      if (rMDBean!=null && rMDBean.isPollingMode()) {
        PollingManager manager = storageManager.getPollingManager();
        if(manager != null) manager.schedulePollingRequest(rMDBean.getSequenceID(), false);
      }
    }


    TerminateManager.terminateSendingSide (rmsBean, storageManager);

View Full Code Here

Examples of org.apache.sandesha2.polling.PollingManager

      if (pending) {
        SequenceEntry entry = (SequenceEntry) message.getProperty(Sandesha2Constants.MessageContextProperties.MAKECONNECTION_ENTRY);
        if(entry != null) {
          ConfigurationContext context = message.getConfigurationContext();
          StorageManager storage = SandeshaUtil.getSandeshaStorageManager(context, context.getAxisConfiguration());
          PollingManager pollingManager = storage.getPollingManager();
          if(pollingManager != null) pollingManager.schedulePollingRequest(entry.getSequenceId(), entry.isRmSource());
        }
      }
    }

View Full Code Here

Examples of org.apache.sandesha2.polling.PollingManager


      RMDBeanMgr rMDBeanMgr = storageManager.getRMDBeanMgr();
      RMDBean rMDBean = rMDBeanMgr.retrieve(outSequenceId);


      if (rMDBean!=null && rMDBean.isPollingMode()) {
        PollingManager manager = storageManager.getPollingManager();
        if(manager != null) manager.schedulePollingRequest(rMDBean.getSequenceID(), false);
      }
    }


    while(ackRangeIterator.hasNext()) {
      Range ackRange = (Range) ackRangeIterator.next();

View Full Code Here

Examples of org.apache.sandesha2.polling.PollingManager

    // invoker thread at this point. If we change this to be a sequence-level
    // property then we'll need to revisit this.
    SandeshaPolicyBean policy = SandeshaUtil.getPropertyBean(context.getAxisConfiguration());
    useSerialization = policy.isUseMessageSerialization();
    if (policy.isInOrder()) invoker = new Invoker();
    if (policy.isEnableMakeConnection()) pollingManager = new PollingManager();
    ModuleConfiguration mc = context.getAxisConfiguration().getModuleConfig("sandesha2");
        if (mc != null) {
            Parameter param = mc.getParameter("db.connectionstring");
            if (param != null) {
                dbConnectionString = (String) param.getValue();

View Full Code Here

Examples of org.apache.sandesha2.polling.PollingManager

    this.rMSBeanMgr = new InMemoryRMSBeanMgr (this, context);
    this.rMDBeanMgr = new InMemoryRMDBeanMgr (this, context);
    this.senderBeanMgr = new InMemorySenderBeanMgr (this, context);
    this.invokerBeanMgr = new InMemoryInvokerBeanMgr (this, context);
    this.sender = new Sender();
    if(polling) this.pollingManager = new PollingManager();
  }

View Full Code Here

Examples of org.apache.sandesha2.polling.PollingManager

    if (offeredSeq!=null) {
      RMDBeanMgr rMDBeanMgr = storageManager.getRMDBeanMgr();
      RMDBean rMDBean = rMDBeanMgr.retrieve(offeredSeq);
      
      if (rMDBean!=null && rMDBean.isPollingMode()) {
        PollingManager manager = storageManager.getPollingManager();
        if(manager != null) manager.schedulePollingRequest(rMDBean.getSequenceID(), false);
      }
    }


    TerminateManager.terminateSendingSide (rmsBean, storageManager, false, null);

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.