You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ml...@apache.org on 2007/01/08 18:17:43 UTC
svn commit: r494126 -
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/polling/PollingManager.java
Author: mlovett
Date: Mon Jan 8 09:17:40 2007
New Revision: 494126
URL: http://svn.apache.org/viewvc?view=rev&rev=494126
Log:
Avoid polling for terminated sequences
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/polling/PollingManager.java
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/polling/PollingManager.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/polling/PollingManager.java?view=diff&rev=494126&r1=494125&r2=494126
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/polling/PollingManager.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/polling/PollingManager.java Mon Jan 8 09:17:40 2007
@@ -148,6 +148,16 @@
private void pollForSequence(String sequenceId, String sequencePropertyKey, String referenceMsgKey) throws SandeshaException, SandeshaStorageException, AxisFault {
if(log.isDebugEnabled()) log.debug("Entry: PollingManager::pollForSequence, " + sequenceId + ", " + sequencePropertyKey + ", " + referenceMsgKey);
+ // Don't poll for a terminated sequence
+ // TODO once the 'terminated' flag is a property on the RMS / RMD bean, we should
+ // be able to filter out terminated sequences before we get here.
+ String terminated = SandeshaUtil.getSequenceProperty(sequencePropertyKey,
+ Sandesha2Constants.SequenceProperties.SEQUENCE_TERMINATED, storageManager);
+ if(terminated != null && "true".equals(terminated)) {
+ if(log.isDebugEnabled()) log.debug("Exit: PollingManager::pollForSequence, already terminated");
+ return;
+ }
+
//create a MakeConnection message
String replyTo = SandeshaUtil.getSequenceProperty(sequencePropertyKey,
Sandesha2Constants.SequenceProperties.REPLY_TO_EPR,storageManager);
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org