svn commit: r926999 - /axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/FaultManager.java

2010-03-24 Thread parsonsd 
Author: parsonsd
Date: Wed Mar 24 10:03:18 2010
New Revision: 926999

URL: http://svn.apache.org/viewvc?rev=926999&view=rev
Log:
Update error msg to explain why the createSeqRefused fault is sent so as to aid 
diagnosis.

Modified:

axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/FaultManager.java

Modified: 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/FaultManager.java
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/FaultManager.java?rev=926999&r1=926998&r2=926999&view=diff
==
--- 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/FaultManager.java
 (original)
+++ 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/FaultManager.java
 Wed Mar 24 10:03:18 2010
@@ -319,7 +319,7 @@ public class FaultManager {

data.setExceptionString(SandeshaUtil.getStackTraceFromException(e));

if(log.isWarnEnabled())
-   
log.warn(SandeshaMessageHelper.getMessage(SandeshaMessageKeys.createSequenceRefused));
+   
log.warn(SandeshaMessageHelper.getMessage(SandeshaMessageKeys.createSequenceRefused)
 + ",  " + detail);
 
if (log.isDebugEnabled())
log.debug("Exit: 
FaultManager::makeCreateSequenceRefusedFault");

svn commit: r943443 - /axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java

2010-05-12 Thread parsonsd 
Author: parsonsd
Date: Wed May 12 10:48:20 2010
New Revision: 943443

URL: http://svn.apache.org/viewvc?rev=943443&view=rev
Log:
Removed copying of TRANSPORT_HEADERS property from referenced MsgCtx into newly 
created MsgCtx as relies on specific information being available
in future layers.

Modified:

axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java

Modified: 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java?rev=943443&r1=943442&r2=943443&view=diff
==
--- 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
 (original)
+++ 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
 Wed May 12 10:48:20 2010
@@ -442,8 +442,12 @@ public class SandeshaUtil {
 

newMessageContext.setProperty(Constants.OUT_TRANSPORT_INFO, referenceMessage

.getProperty(Constants.OUT_TRANSPORT_INFO));
+   
+   /*

newMessageContext.setProperty(MessageContext.TRANSPORT_HEADERS, referenceMessage

.getProperty(MessageContext.TRANSPORT_HEADERS));
+   */
+   

newMessageContext.setProperty(MessageContext.TRANSPORT_IN, referenceMessage

.getProperty(MessageContext.TRANSPORT_IN));

newMessageContext.setProperty(MessageContext.TRANSPORT_OUT, referenceMessage
@@ -454,6 +458,7 @@ public class SandeshaUtil {

newMessageContext.setProperty(AddressingConstants.DISABLE_ADDRESSING_FOR_OUT_MESSAGES,
 

referenceMessage.getProperty(AddressingConstants.DISABLE_ADDRESSING_FOR_OUT_MESSAGES));

+   
copyConfiguredProperties 
(referenceMessage,newMessageContext);
 
//copying the serverSide property

svn commit: r960008 - /axis/axis2/java/sandesha/trunk/pom.xml

2010-07-02 Thread parsonsd 
Author: parsonsd
Date: Fri Jul  2 14:37:31 2010
New Revision: 960008

URL: http://svn.apache.org/viewvc?rev=960008&view=rev
Log:
Update POM to point at new plugin maven repo.

Modified:
axis/axis2/java/sandesha/trunk/pom.xml

Modified: axis/axis2/java/sandesha/trunk/pom.xml
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/pom.xml?rev=960008&r1=960007&r2=960008&view=diff
==
--- axis/axis2/java/sandesha/trunk/pom.xml (original)
+++ axis/axis2/java/sandesha/trunk/pom.xml Fri Jul  2 14:37:31 2010
@@ -191,6 +191,18 @@
 
 
 
+ 
+snapshot-apache-2
+2nd Apache Snapshot repository
+http://repository.apache.org/snapshots
+
+true
+
+
+false
+
+
+

svn commit: r960903 - /axis/axis2/java/sandesha/trunk/pom.xml

2010-07-06 Thread parsonsd 
Author: parsonsd
Date: Tue Jul  6 14:24:05 2010
New Revision: 960903

URL: http://svn.apache.org/viewvc?rev=960903&view=rev
Log:
Update POM to point at new AXIOM SNAPSHOT branch

Modified:
axis/axis2/java/sandesha/trunk/pom.xml

Modified: axis/axis2/java/sandesha/trunk/pom.xml
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/pom.xml?rev=960903&r1=960902&r2=960903&view=diff
==
--- axis/axis2/java/sandesha/trunk/pom.xml (original)
+++ axis/axis2/java/sandesha/trunk/pom.xml Tue Jul  6 14:24:05 2010
@@ -278,7 +278,7 @@
 
 SNAPSHOT
 SNAPSHOT
-1.2.9-SNAPSHOT
+1.2.10-SNAPSHOT
 3.0.0-SNAPSHOT
 1.1.1
 1.0.1

svn commit: r1005095 - in /axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors: CloseSequenceProcessor.java TerminateSeqMsgProcessor.java

2010-10-06 Thread parsonsd 
Author: parsonsd
Date: Wed Oct  6 15:59:00 2010
New Revision: 1005095

URL: http://svn.apache.org/viewvc?rev=1005095&view=rev
Log:
PiggyBacked acks sent on closeSeq & terminateSeq with mustUnderstand set to 
true breaks RSP spec.  Fixed so that all piggybacked acks are sent with 
mustUnderstand set to false.

Modified:

axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java

axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java

Modified: 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java?rev=1005095&r1=1005094&r2=1005095&view=diff
==
--- 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
 (original)
+++ 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
 Wed Oct  6 15:59:00 2010
@@ -95,25 +95,18 @@ public class CloseSequenceProcessor exte
}
 
rmBean.setClosed(true);
-   Iterator sequenceAckIter = null;
+
+   RMMsgContext closeSeqResponseRMMsg = 
RMMsgCreator.createCloseSeqResponseMsg(rmMsgCtx, rmBean);
+   MessageContext closeSequenceResponseMsg = 
closeSeqResponseRMMsg.getMessageContext();
if(rmBean instanceof RMDBean){
storageManager.getRMDBeanMgr().update((RMDBean)rmBean);
-   RMMsgContext ackRMMsgCtx = 
AcknowledgementManager.generateAckMessage(rmMsgCtx, (RMDBean)rmBean, 
sequenceId, storageManager, true);
-   // adding the ack part(s) to the envelope.
-   sequenceAckIter = 
ackRMMsgCtx.getSequenceAcknowledgements();
+   //Piggyback an ack for the sequence being closed on the 
closeSequenceResponse
+   RMMsgCreator.addAckMessage(closeSeqResponseRMMsg, 
sequenceId, (RMDBean)rmBean, false, true);
}
else{
storageManager.getRMSBeanMgr().update((RMSBean)rmBean);
}
 
-   RMMsgContext closeSeqResponseRMMsg = 
RMMsgCreator.createCloseSeqResponseMsg(rmMsgCtx, rmBean);
-   MessageContext closeSequenceResponseMsg = 
closeSeqResponseRMMsg.getMessageContext();
-
-   while (sequenceAckIter!=null && sequenceAckIter.hasNext()) {
-   SequenceAcknowledgement sequenceAcknowledgement = 
(SequenceAcknowledgement) sequenceAckIter.next();
-   
closeSeqResponseRMMsg.addSequenceAcknowledgement(sequenceAcknowledgement);
-   }
-   
closeSeqResponseRMMsg.setFlow(MessageContext.OUT_FLOW);

closeSeqResponseRMMsg.setProperty(Sandesha2Constants.APPLICATION_PROCESSING_DONE,
 "true");
closeSequenceResponseMsg.setResponseWritten(true);

Modified: 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
URL: 
http://svn.apache.org/viewvc/axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java?rev=1005095&r1=1005094&r2=1005095&view=diff
==
--- 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
 (original)
+++ 
axis/axis2/java/sandesha/trunk/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
 Wed Oct  6 15:59:00 2010
@@ -328,15 +328,8 @@ public class TerminateSeqMsgProcessor ex
MessageContext outMessage = 
terminateSeqResponseRMMsg.getMessageContext();

if(rmBean instanceof RMDBean){
-   RMMsgContext ackRMMessage = 
AcknowledgementManager.generateAckMessage(terminateSeqRMMsg, (RMDBean)rmBean, 
-   sequenceId, storageManager, true);
-   
-   // copy over the ack parts
-   Iterator iter = 
ackRMMessage.getSequenceAcknowledgements();
-   while (iter.hasNext()) {
-   SequenceAcknowledgement seqAck = 
(SequenceAcknowledgement) iter.next();
-   
terminateSeqResponseRMMsg.addSequenceAcknowledgement(seqAck);
-   }
+   //Piggyback an ack for the sequence