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 ch...@apache.org on 2006/02/28 03:22:45 UTC
svn commit: r381542 - in
/webservices/sandesha/trunk/src/org/apache/sandesha2:
AcknowledgementManager.java TerminateManager.java
client/Sandesha2ClientAPI.java msgprocessors/AcknowledgementProcessor.java
Author: chamikara
Date: Mon Feb 27 18:22:44 2006
New Revision: 381542
URL: http://svn.apache.org/viewcvs?rev=381542&view=rev
Log:
Some corrections
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java
webservices/sandesha/trunk/src/org/apache/sandesha2/TerminateManager.java
webservices/sandesha/trunk/src/org/apache/sandesha2/client/Sandesha2ClientAPI.java
webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java?rev=381542&r1=381541&r2=381542&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java Mon Feb 27 18:22:44 2006
@@ -167,6 +167,9 @@
ArrayList completedMsgList = null;
if (completedMessagesBean!=null) {
completedMsgList = SandeshaUtil.getArrayListFromString(completedMessagesBean.getValue());
+ } else {
+ String message = "Completed messages bean is null, for the sequence " + sequenceIdentifier;
+ throw new SandeshaException (message);
}
return completedMsgList;
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/TerminateManager.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/TerminateManager.java?rev=381542&r1=381541&r2=381542&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/TerminateManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/TerminateManager.java Mon Feb 27 18:22:44 2006
@@ -241,7 +241,6 @@
iterator = collection.iterator();
while (iterator.hasNext()) {
SequencePropertyBean sequencePropertyBean = (SequencePropertyBean) iterator.next();
-
doUpdatesIfNeeded (sequenceID,sequencePropertyBean,sequencePropertyBeanMgr);
if (isProportyDeletable(sequencePropertyBean.getName())) {
@@ -265,7 +264,6 @@
newBean.setValue(propertyBean.getValue());
seqPropMgr.insert(newBean);
-
//TODO amazingly this property does not seem to get deleted without following - in the hibernate impl
//(even though the lines efter current methodcall do this).
seqPropMgr.delete (propertyBean.getSequenceID(),propertyBean.getName());
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/client/Sandesha2ClientAPI.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/client/Sandesha2ClientAPI.java?rev=381542&r1=381541&r2=381542&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/client/Sandesha2ClientAPI.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/client/Sandesha2ClientAPI.java Mon Feb 27 18:22:44 2006
@@ -120,4 +120,12 @@
RMReport rmReport = new RMReport ();
return rmReport;
}
+
+ public static String generateInternalSequenceIDForTheClientSide (String toEPR,String sequenceKey) {
+ return SandeshaUtil.getInternalSequenceID(toEPR,sequenceKey);
+ }
+
+ public static void endSequence (String internalSequenceID, ConfigurationContext configurationContext) {
+
+ }
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java?rev=381542&r1=381541&r2=381542&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java Mon Feb 27 18:22:44 2006
@@ -72,8 +72,7 @@
}
AbstractContext context = rmMsgCtx.getContext();
- if (context == null)
- {
+ if (context == null) {
String message = "Context is null";
log.debug(message);
throw new SandeshaException(message);
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org