Author: chamikara
Date: Sat Jul 29 21:29:29 2006
New Revision: 426867
URL: http://svn.apache.org/viewvc?rev=426867&view=rev
Log:
A correction in the resources.properties file.
Corrected Terminate Manager to clean the NextMsg Beans.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties?rev=426867&r1=426866&r2=426867&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
Sat Jul 29 21:29:29 2006
@@ -108,7 +108,7 @@
cannotSendAckRequestNotActive=Cannot send the ackRequest message since the
sequence with internal ID {0} is not active.
cannotSendAckRequestException=Could not send the ackRequest message on
sequence {0} due to an exception: {1}
cannotCloseSequenceNotActive=Cannot close the sequence with internal ID {0}
since it is not active.
-noSequenceEstablished=A sequence with the given internal sequence ID {0} has
not been established, has been terminated or could not be found.
+noSequenceEstablished=A sequence with the given sequence ID {0} has not been
established, has been terminated or could not be found.
invalidInternalSequenceID=Sandesha2 Internal Error: The internal sequence ID
{0} is not valid.
tempNotSetOnReceivedMsg=''TempSequenceId'' is not set correctly in the
received message.
completedMsgBeanIsNull=Completed messages bean is null for the sequence {0}.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java?rev=426867&r1=426866&r2=426867&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
Sat Jul 29 21:29:29 2006
@@ -367,10 +367,6 @@
if (log.isDebugEnabled())
log.debug("Enter:
ApplicationMsgProcessor::sendAckIfNeeded");
- MessageContext msgCtx = rmMsgCtx.getMessageContext();
-
- SequencePropertyBeanMgr seqPropMgr =
storageManager.getSequencePropertyBeanMgr();
-
Sequence sequence = (Sequence)
rmMsgCtx.getMessagePart(Sandesha2Constants.MessageParts.SEQUENCE);
String sequenceId = sequence.getIdentifier().getIdentifier();
ConfigurationContext configCtx =
rmMsgCtx.getMessageContext().getConfigurationContext();
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java?rev=426867&r1=426866&r2=426867&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
Sat Jul 29 21:29:29 2006
@@ -151,7 +151,7 @@
Iterator iterator = collection.iterator();
while (iterator.hasNext()) {
NextMsgBean nextMsgBean = (NextMsgBean) iterator.next();
- // nextMsgBeanMgr.delete(nextMsgBean.getSequenceID());
+ nextMsgBeanMgr.delete(nextMsgBean.getSequenceID());
}
// removing the HighestInMessage entry.
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
