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