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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
