ws-sandesha-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chamik...@apache.org
Subject svn commit: r345762 [1/2] - in /webservices/sandesha/trunk/src/org/apache/sandesha2: ./ handlers/ msgprocessors/ msgreceivers/ policy/ storage/ storage/beanmanagers/ storage/beans/ storage/inmemory/ util/ workers/ wsrm/
Date Sun, 20 Nov 2005 16:27:30 GMT
Author: chamikara
Date: Sun Nov 20 08:23:27 2005
New Revision: 345762

URL: http://svn.apache.org/viewcvs?rev=345762&view=rev
Log:
Formatted code.

Modified:
    webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/FaultData.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/RMMsgContext.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/SOAPFaultEnvelopeCreator.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaDynamicProperties.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaException.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaModule.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessor.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessorFactory.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/policy/RMPolicyBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/Transaction.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RMBeanManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/NextMsgBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/RMBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/RetransmitterBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/StorageMapBean.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemoryCreateSeqBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemoryNextMsgBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemoryRetransmitterBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemorySequencePropertyBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemoryStorageMapBeanMgr.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/FaultManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/MessageRetransmissionAdjuster.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/MsgInitializer.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/MsgValidator.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/RMMsgCreator.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/RMPolicyManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/SOAPAbstractFactory.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/SandeshaUtil.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/util/SequenceManager.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/workers/InOrderInvoker.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/workers/Sender.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/Accept.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/AckRequested.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/AcknowledgementRange.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/AcksTo.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/Address.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/CreateSequence.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/CreateSequenceResponse.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/Expires.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/FaultCode.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/IOMRMElement.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/IOMRMPart.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/Identifier.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/LastMessage.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/MessageNumber.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/Nack.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/RMElements.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/Sequence.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/SequenceAcknowledgement.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/SequenceFault.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/SequenceOffer.java
    webservices/sandesha/trunk/src/org/apache/sandesha2/wsrm/TerminateSequence.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=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/AcknowledgementManager.java Sun Nov 20 08:23:27 2005
@@ -29,58 +29,71 @@
 import org.apache.sandesha2.storage.beans.SequencePropertyBean;
 import org.apache.sandesha2.util.MsgInitializer;
 import org.apache.sandesha2.util.SandeshaUtil;
-import org.apache.sandesha2.wsrm.IOMRMPart;
 import org.apache.sandesha2.wsrm.Sequence;
 import org.apache.sandesha2.wsrm.SequenceAcknowledgement;
 
 /**
- * @author chamikara
- * 
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
  */
+
 public class AcknowledgementManager {
 
-	public static void piggybackAckIfPresent (RMMsgContext applicationRMMsgContext) throws SandeshaException {
-		ConfigurationContext configurationContext = applicationRMMsgContext.getMessageContext().getSystemContext();
-		StorageManager storageManager = SandeshaUtil.getSandeshaStorageManager(configurationContext);
-		RetransmitterBeanMgr retransmitterBeanMgr = storageManager.getRetransmitterBeanMgr();
-		SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager.getSequencePropretyBeanMgr();
-		
-		RetransmitterBean findBean = new RetransmitterBean ();
-		
-		Sequence sequence = (Sequence) applicationRMMsgContext.getMessagePart(Constants.MessageParts.SEQUENCE);
-		if (sequence==null)
-			throw new SandeshaException ("Application message does not contain a sequence part");
-		
+	public static void piggybackAckIfPresent(
+			RMMsgContext applicationRMMsgContext) throws SandeshaException {
+		ConfigurationContext configurationContext = applicationRMMsgContext
+				.getMessageContext().getSystemContext();
+		StorageManager storageManager = SandeshaUtil
+				.getSandeshaStorageManager(configurationContext);
+		RetransmitterBeanMgr retransmitterBeanMgr = storageManager
+				.getRetransmitterBeanMgr();
+		SequencePropertyBeanMgr sequencePropertyBeanMgr = storageManager
+				.getSequencePropretyBeanMgr();
+
+		RetransmitterBean findBean = new RetransmitterBean();
+
+		Sequence sequence = (Sequence) applicationRMMsgContext
+				.getMessagePart(Constants.MessageParts.SEQUENCE);
+		if (sequence == null)
+			throw new SandeshaException(
+					"Application message does not contain a sequence part");
+
 		String sequenceId = sequence.getIdentifier().getIdentifier();
-		
-		SequencePropertyBean tempSequenceBean = sequencePropertyBeanMgr.retrieve(sequenceId,Constants.SequenceProperties.TEMP_SEQUENCE_ID);
-		if (tempSequenceBean==null)
-			throw new SandeshaException ("Temp Sequence is not set");
-		
+
+		SequencePropertyBean tempSequenceBean = sequencePropertyBeanMgr
+				.retrieve(sequenceId,
+						Constants.SequenceProperties.TEMP_SEQUENCE_ID);
+		if (tempSequenceBean == null)
+			throw new SandeshaException("Temp Sequence is not set");
+
 		String tempSequenceId = (String) tempSequenceBean.getValue();
 		findBean.setTempSequenceId(tempSequenceId);
 		findBean.setMessagetype(Constants.MessageTypes.ACK);
-		
+
 		Collection collection = retransmitterBeanMgr.find(findBean);
 		Iterator it = collection.iterator();
-		
+
 		if (it.hasNext()) {
 			RetransmitterBean ackBean = (RetransmitterBean) it.next();
-			
+
 			//deleting the ack entry.
 			retransmitterBeanMgr.delete(ackBean.getMessageId());
-			
+
 			//Adding the ack to the application message
-			MessageContext ackMsgContext = SandeshaUtil.getStoredMessageContext(ackBean.getKey());
-			RMMsgContext ackRMMsgContext = MsgInitializer.initializeMessage(ackMsgContext);
-			if (ackRMMsgContext.getMessageType()!=Constants.MessageTypes.ACK)
-				throw new SandeshaException ("Invalid ack message entry");
-			
-			SequenceAcknowledgement sequenceAcknowledgement = (SequenceAcknowledgement) ackRMMsgContext.getMessagePart(Constants.MessageParts.SEQ_ACKNOWLEDGEMENT);
-			applicationRMMsgContext.setMessagePart(Constants.MessageParts.SEQ_ACKNOWLEDGEMENT,sequenceAcknowledgement);
-			
+			MessageContext ackMsgContext = SandeshaUtil
+					.getStoredMessageContext(ackBean.getKey());
+			RMMsgContext ackRMMsgContext = MsgInitializer
+					.initializeMessage(ackMsgContext);
+			if (ackRMMsgContext.getMessageType() != Constants.MessageTypes.ACK)
+				throw new SandeshaException("Invalid ack message entry");
+
+			SequenceAcknowledgement sequenceAcknowledgement = (SequenceAcknowledgement) ackRMMsgContext
+					.getMessagePart(Constants.MessageParts.SEQ_ACKNOWLEDGEMENT);
+			applicationRMMsgContext.setMessagePart(
+					Constants.MessageParts.SEQ_ACKNOWLEDGEMENT,
+					sequenceAcknowledgement);
+
 			applicationRMMsgContext.addSOAPEnvelope();
 		}
-		
+
 	}
-}
+}
\ No newline at end of file

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java Sun Nov 20 08:23:27 2005
@@ -17,14 +17,10 @@
 
 package org.apache.sandesha2;
 
-import org.apache.axis2.soap.SOAPConstants;
-
-
-
 /**
- * @author Chamikara
- * @author Sanka
- * @author Jaliya
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
+ * @author Jaliya Ekanayaka <jaliya@opensource.lk>
  */
 
 public interface Constants {
@@ -34,18 +30,24 @@
 
 		String NS_URI_RM = "http://schemas.xmlsoap.org/ws/2005/02/rm";
 
-//		String ACTION_SEQ_ACK = "http://schemas.xmlsoap.org/ws/2005/02/rm/SequenceAcknowledgement";
-//
-//		String SOAP_ACTION_SEQ_ACK = "http://schemas.xmlsoap.org/ws/2005/02/rm/SequenceAcknowledgement";
-//		
-//		String ACTION_CREATE_SEQ = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequence";
-//
-//		String SOAP_ACTION_CREATE_SEQ = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequence";
-//		
-//		String ACTION_CREATE_SEQ_RESPONSE = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequenceResponse";
-//
-//		String SOAP_ACTION_CREATE_SEQ_RESPONSE = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequenceResponse";
-		
+		//		String ACTION_SEQ_ACK =
+		// "http://schemas.xmlsoap.org/ws/2005/02/rm/SequenceAcknowledgement";
+		//
+		//		String SOAP_ACTION_SEQ_ACK =
+		// "http://schemas.xmlsoap.org/ws/2005/02/rm/SequenceAcknowledgement";
+		//		
+		//		String ACTION_CREATE_SEQ =
+		// "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequence";
+		//
+		//		String SOAP_ACTION_CREATE_SEQ =
+		// "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequence";
+		//		
+		//		String ACTION_CREATE_SEQ_RESPONSE =
+		// "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequenceResponse";
+		//
+		//		String SOAP_ACTION_CREATE_SEQ_RESPONSE =
+		// "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequenceResponse";
+
 		String MSG_NUMBER = "MessageNumber";
 
 		String LAST_MSG = "LastMessage";
@@ -83,25 +85,25 @@
 		String IDENTIFIER = "Identifier";
 
 		String ACCEPT = "Accept";
-		
+
 		public interface Actions {
-			
+
 			String ACTION_CREATE_SEQUENCE = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequence";
-			
+
 			String ACTION_CREATE_SEQUENCE_RESPONSE = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequenceResponse";
-			
+
 			String ACTION_SEQUENCE_ACKNOWLEDGEMENT = "http://schemas.xmlsoap.org/ws/2005/02/rm/SequenceAcknowledgement";
-			
+
 			String ACTION_TERMINATE_SEQUENCE = "http://schemas.xmlsoap.org/ws/2005/02/rm/TerminateSequence";
-			
+
 			String SOAP_ACTION_CREATE_SEQUENCE = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequence";
-			
+
 			String SOAP_ACTION_CREATE_SEQUENCE_RESPONSE = "http://schemas.xmlsoap.org/ws/2005/02/rm/CreateSequenceResponse";
-			
+
 			String SOAP_ACTION_SEQUENCE_ACKNOWLEDGEMENT = "http://schemas.xmlsoap.org/ws/2005/02/rm/SequenceAcknowledgement";
-			
+
 			String SOAP_ACTION_TERMINATE_SEQUENCE = "http://schemas.xmlsoap.org/ws/2005/02/rm/TerminateSequence";
-			
+
 		}
 	}
 
@@ -113,16 +115,19 @@
 		String NS_PREFIX_ADDRESSING = "wsa";
 
 		String ADDRESS = "Address";
-		
+
 		String SOAP_FAULT_ACTION = "http://schemas.xmlsoap.org/ws/2004/08/addressing/fault";
 	}
 
 	public interface WSP {
 		long RETRANSMISSION_INTERVAL = 20000;
+
 		long ACKNOWLEDGEMENT_INTERVAL = 4000;
+
 		boolean EXPONENTION_BACKOFF = true;
+
 		long INACTIVITY_TIMEOUT_INTERVAL = 5000000;
-		
+
 		String RM_POLICY_BEAN = "RMPolicyBean";
 	}
 
@@ -163,8 +168,11 @@
 	}
 
 	public interface SequenceProperties {
-		
-		String ALL_SEQUENCES = "AllSequences";  //this is not a sequence property. This is used as the sequenceId to share data b/w sequences
+
+		String ALL_SEQUENCES = "AllSequences"; //this is not a sequence
+											   // property. This is used as the
+											   // sequenceId to share data b/w
+											   // sequences
 
 		String RECEIVED_MESSAGES = "SeqMsgListProperty";
 
@@ -173,28 +181,28 @@
 		String ACKS_TO_EPR = "acksToEPR";
 
 		String OUT_SEQUENCE_ID = "OutSequenceId";
-		
+
 		//FIXME - rema
 		//String INCOMING_SEQUENCE_ID = "IncomingSequenceId";
-		
+
 		String TEMP_SEQUENCE_ID = "TempSequenceId";
 
 		String REPLY_TO_EPR = "ReplyToEPR";
-		
+
 		String APP_MSG_PROCESSOR_LIST = "AppMsgProcessorList";
-		
+
 		String OUT_CREATE_SEQUENCE_SENT = "OutCreateSeqSent";
-		
+
 		String NEXT_MESSAGE_NUMBER = "NextMsgNo";
-		
+
 		String LAST_OUT_MESSAGE = "LastOutMessage";
-		
+
 		String INCOMING_SEQUENCE_LIST = "IncomingSequenceList";
-		
+
 		String CHECK_RESPONSE = "CheckResponse";
-		
+
 		String OFFERED_SEQUENCE = "OfferedSequence";
-		
+
 		String TERMINATE_ADDED = "TerminateAdded";
 	}
 
@@ -205,18 +213,18 @@
 	}
 
 	public interface QOS {
-		
+
 		public interface DeliveryAssurance {
-		
+
 			String IN_ORDER = "InOrder";
 
 			String NOT_IN_ORDER = "NotInOrder";
 
 			String DEFAULT_DELIVERY_ASSURANCE = IN_ORDER;
 		}
-		
+
 		public interface InvocationType {
-			
+
 			//invocation types
 			String EXACTLY_ONCE = "ExactlyOnce";
 
@@ -224,8 +232,7 @@
 
 			String DEFAULT_INVOCATION_TYPE = EXACTLY_ONCE;
 		}
-		
-		
+
 	}
 
 	public interface BeanMAPs {
@@ -243,41 +250,40 @@
 	public interface ClientProperties {
 		String AcksTo = "AcksToStr";
 	}
-	
+
 	public interface SOAPFaults {
-		
+
 		public interface Subcodes {
-			
+
 			String SEQUENCE_TERMINATED = "wsrm:SequenceTerminated";
-				
+
 			String UNKNOWN_SEQUENCE = "wsrm:UnknownSequence";
-				
+
 			String INVALID_ACKNOWLEDGEMENT = "wsrm:InvalidAcknowledgement";
-				
-		    String MESSAGE_NUMBER_ROLEOVER = "wsrm:MessageNumberRollover";
-				
+
+			String MESSAGE_NUMBER_ROLEOVER = "wsrm:MessageNumberRollover";
+
 			String LAST_MESSAGE_NO_EXCEEDED = "wsrm:LastMessageNumberExceeded";
-				
+
 			String CREATE_SEQUENCE_REFUSED = "wsrm:CreateSequenceRefused";
-			
+
 		}
 
-		
 		public interface FaultType {
-			
+
 			public static final int UNKNOWN_SEQUENCE = 1;
 
 			public static final int MESSAGE_NUMBER_ROLLOVER = 2;
 
 			public static final int INVALID_ACKNOWLEDGEMENT = 3;
-			
+
 			public static final int CREATE_SEQUENCE_REFUSED = 4;
-			
-			//public static final int 
-			
+
+			//public static final int
+
 		}
 	}
-	
+
 	//TODO remove following three
 	int STORAGE_TYPE_IN_MEMORY = 1;
 
@@ -288,40 +294,40 @@
 	String IN_HANDLER_NAME = "SandeshaInHandler";
 
 	String OUT_HANDLER_NAME = "SandeshaOutHandler";
-	
-	String GLOBAL_IN_HANDLER_NAME= "GlobalInHandler";
-	
+
+	String GLOBAL_IN_HANDLER_NAME = "GlobalInHandler";
+
 	String SEQUENCE_KEY = "SequenceKey";
 
 	//message context properties
 	String APPLICATION_PROCESSING_DONE = "AppProcessingDone";
-	
+
 	String ACK_WRITTEN = "AckWritten";
 
 	int INVOKER_SLEEP_TIME = 1000;
 
 	int SENDER_SLEEP_TIME = 1000;
-	
+
 	int CLIENT_SLEEP_TIME = 10000;
 
 	int TERMINATE_DELAY = 1000;
-	
+
 	String LAST_MESSAGE = "WSRMLastMessage";
-	
+
 	String TEMP_SEQUENCE_ID = "uuid:tempID";
-	
+
 	String AcksTo = "AcksToProperty";
-	
+
 	String OFFERED_SEQUENCE_ID = "OfferedSequenceId";
-	
+
 	String ACK_PROCSSED = "AckProcessed";
-	
+
 	String RM_ENABLE_KEY = "RMEnabled";
-	
+
 	String SANDESHA_DEBUG_MODE = "SandeshaDebugMode";
-	
+
 	String STORAGE_MANAGER_IMPL = "org.apache.sandesha2.storage.inmemory.InMemoryStorageManager";
-	
+
 	int MAXIMUM_RETRANSMISSION_ATTEMPTS = 5;
-	
+
 }

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/FaultData.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/FaultData.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/FaultData.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/FaultData.java Sun Nov 20 08:23:27 2005
@@ -17,12 +17,15 @@
 
 package org.apache.sandesha2;
 
-import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.om.OMElement;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
+ */
 
 public class FaultData {
-	
+
 	private int type;
 
 	private String code;
@@ -34,53 +37,52 @@
 	private OMElement detail;
 
 	private String sequenceId;
-	
-	
+
 	public OMElement getDetail() {
 		return detail;
 	}
-	
+
 	public void setDetail(OMElement detail) {
 		this.detail = detail;
 	}
-	
+
 	public String getReason() {
 		return reason;
 	}
-	
+
 	public void setReason(String reason) {
 		this.reason = reason;
 	}
-	
+
 	public String getSubcode() {
 		return subcode;
 	}
-	
+
 	public void setSubcode(String subcode) {
 		this.subcode = subcode;
 	}
-	
+
 	public int getType() {
 		return type;
 	}
-	
+
 	public void setType(int type) {
 		this.type = type;
 	}
-	
+
 	public String getCode() {
 		return code;
 	}
-	
+
 	public void setCode(String code) {
 		this.code = code;
 	}
-	
+
 	public String getSequenceId() {
 		return sequenceId;
 	}
-	
+
 	public void setSequenceId(String sequenceId) {
 		this.sequenceId = sequenceId;
 	}
-}
+}
\ No newline at end of file

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/RMMsgContext.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/RMMsgContext.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/RMMsgContext.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/RMMsgContext.java Sun Nov 20 08:23:27 2005
@@ -29,15 +29,14 @@
 import org.apache.axis2.context.AbstractContext;
 import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.soap.SOAPEnvelope;
-import org.apache.axis2.soap.SOAPProcessingException;
 import org.apache.sandesha2.util.SOAPAbstractFactory;
 import org.apache.sandesha2.wsrm.IOMRMElement;
 import org.apache.sandesha2.wsrm.IOMRMPart;
 
 /**
- * @author Chamikara
- * @author Sanka
- * @author Jaliya
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
+ * @author Jaliya Ekanayaka <jaliya@opensource.lk>
  */
 
 public class RMMsgContext {
@@ -66,15 +65,16 @@
 
 	public void addSOAPEnvelope() throws SandeshaException {
 		int SOAPVersion = Constants.SOAPVersion.v1_1;
-		
-		if (!msgContext.isSOAP11()) 
+
+		if (!msgContext.isSOAP11())
 			SOAPVersion = Constants.SOAPVersion.v1_2;
-		
+
 		if (msgContext.getEnvelope() == null) {
 			try {
-				msgContext.setEnvelope(SOAPAbstractFactory.getSOAPFactory(SOAPVersion).getDefaultEnvelope());
+				msgContext.setEnvelope(SOAPAbstractFactory.getSOAPFactory(
+						SOAPVersion).getDefaultEnvelope());
 			} catch (AxisFault e) {
-				throw new SandeshaException (e.getMessage());
+				throw new SandeshaException(e.getMessage());
 			}
 		}
 

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/SOAPFaultEnvelopeCreator.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/SOAPFaultEnvelopeCreator.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/SOAPFaultEnvelopeCreator.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/SOAPFaultEnvelopeCreator.java Sun Nov 20 08:23:27 2005
@@ -18,7 +18,6 @@
 package org.apache.sandesha2;
 
 import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.AddressingConstants;
 import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.om.OMConstants;
 import org.apache.axis2.om.OMElement;
@@ -38,67 +37,70 @@
 import org.apache.sandesha2.wsrm.SequenceFault;
 
 /**
- * @author chamikara
- * 
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
  */
 
 public class SOAPFaultEnvelopeCreator {
 
-	public static void addSOAPFaultEnvelope (MessageContext faultMsgContext, int SOAPVersion, FaultData faultData) throws SandeshaException {
-		
+	public static void addSOAPFaultEnvelope(MessageContext faultMsgContext,
+			int SOAPVersion, FaultData faultData) throws SandeshaException {
+
 		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SOAPVersion);
 		SOAPEnvelope env = factory.getDefaultFaultEnvelope();
-		
+
 		try {
-			faultMsgContext.setEnvelope (env);
+			faultMsgContext.setEnvelope(env);
 		} catch (AxisFault e) {
-			throw new SandeshaException (e.getMessage());
+			throw new SandeshaException(e.getMessage());
 		}
-		
-		if (SOAPVersion==Constants.SOAPVersion.v1_1)
-			doSOAP11Encoding(faultMsgContext,faultData);
+
+		if (SOAPVersion == Constants.SOAPVersion.v1_1)
+			doSOAP11Encoding(faultMsgContext, faultData);
 		else
-			doSOAP12Encoding(faultMsgContext,faultData);
-		
+			doSOAP12Encoding(faultMsgContext, faultData);
+
 	}
-	
-	private static boolean isSequenceFault (FaultData faultData) {
-		
+
+	private static boolean isSequenceFault(FaultData faultData) {
+
 		boolean sequenceFault = false;
-		
+
 		int faultType = faultData.getType();
-		
-		if (faultType<=0)
+
+		if (faultType <= 0)
 			return false;
-		
-		if (faultType==Constants.SOAPFaults.FaultType.CREATE_SEQUENCE_REFUSED)
+
+		if (faultType == Constants.SOAPFaults.FaultType.CREATE_SEQUENCE_REFUSED)
 			sequenceFault = true;
-		
-		if (faultType==Constants.SOAPFaults.FaultType.UNKNOWN_SEQUENCE)
+
+		if (faultType == Constants.SOAPFaults.FaultType.UNKNOWN_SEQUENCE)
 			sequenceFault = true;
-		
+
 		return sequenceFault;
-		
+
 	}
-	
-	private static void addSequenceFaultHeader (MessageContext faultMessageContext, FaultData faultData,SOAPFactory factory) {
-		
-		
-		SequenceFault sequenceFault = new SequenceFault (factory);
-		
-		FaultCode faultCode = new FaultCode (factory);
+
+	private static void addSequenceFaultHeader(
+			MessageContext faultMessageContext, FaultData faultData,
+			SOAPFactory factory) {
+
+		SequenceFault sequenceFault = new SequenceFault(factory);
+
+		FaultCode faultCode = new FaultCode(factory);
 		faultCode.setFaultCode(faultData.getSubcode());
 		sequenceFault.setFaultCode(faultCode);
 	}
-	
-	private static void doSOAP11Encoding(MessageContext faultMsgContext,FaultData data) throws SandeshaException {
-		
-		//MessageContext faultMsgContext = faultRMMsgContext.getMessageContext();
+
+	private static void doSOAP11Encoding(MessageContext faultMsgContext,
+			FaultData data) throws SandeshaException {
+
+		//MessageContext faultMsgContext =
+		// faultRMMsgContext.getMessageContext();
 
 		SOAPEnvelope faultMsgEnvelope = faultMsgContext.getEnvelope();
-		if (faultMsgEnvelope==null)
-			throw new SandeshaException ("SOAP Envelope is null");
-		
+		if (faultMsgEnvelope == null)
+			throw new SandeshaException("SOAP Envelope is null");
+
 		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil
 				.getSOAPVersion(faultMsgEnvelope));
 
@@ -107,40 +109,41 @@
 
 		if (isSequenceFault(data)) {
 			faultCode.setText(data.getCode());
-		}else {
+		} else {
 			faultCode.setText(data.getSubcode());
 		}
-		
+
 		SOAPFaultReason faultReason = fault.getReason();
-		
+
 		OMNamespace namespace = factory.createOMNamespace(
 				OMConstants.XMLNS_URI, OMConstants.XMLNS_PREFIX);
 		faultReason.getSOAPText().addAttribute("lang", "en", namespace);
-		
+
 		faultReason.setText(data.getReason());
 		faultCode.getValue().setText(data.getSubcode());
 		faultReason.getSOAPText().setText(data.getReason());
-		
+
 		//SequenceFault header is added only for SOAP 1.1
 		if (isSequenceFault(data))
-			addSequenceFaultHeader (faultMsgContext,data,factory);
-		
+			addSequenceFaultHeader(faultMsgContext, data, factory);
+
 	}
 
-	private static void doSOAP12Encoding(MessageContext faultMsgContext, FaultData data) throws SandeshaException {
+	private static void doSOAP12Encoding(MessageContext faultMsgContext,
+			FaultData data) throws SandeshaException {
 		//MessageContext faultMsgCtx = faultRMMsgContext.getMessageContext();
-		
+
 		SOAPEnvelope faultEnvelope = faultMsgContext.getEnvelope();
-		if (faultEnvelope==null)
-			throw new SandeshaException ("SOAP Envelope is null");
-		
+		if (faultEnvelope == null)
+			throw new SandeshaException("SOAP Envelope is null");
+
 		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil
-				.getSOAPVersion (faultEnvelope));
-		
+				.getSOAPVersion(faultEnvelope));
+
 		SOAPFault fault = faultEnvelope.getBody().getFault();
-		if (fault==null)
-			throw new SandeshaException ("Fault part is null");
-		
+		if (fault == null)
+			throw new SandeshaException("Fault part is null");
+
 		SOAPFaultCode faultCode = fault.getCode();
 		SOAPFaultValue codeValue = faultCode.getValue();
 		codeValue.setText(data.getCode());
@@ -158,84 +161,92 @@
 		SOAPFaultDetail faultDetail = fault.getDetail();
 
 		OMElement detailElement = data.getDetail();
-		
-		if (detailElement!=null)
+
+		if (detailElement != null)
 			faultDetail.addChild(detailElement);
-		
+
 		faultMsgContext.setWSAAction(Constants.WSA.SOAP_FAULT_ACTION);
-		
-//		if (detailElement!=null) {
-//			String subcode = data.getSubcode();
-//			
-//			if (Constants.SOAPFaults.Subcodes.SequenceTerminated.equals(subcode)) {
-//				
-//			}else if (Constants.SOAPFaults.Subcodes.UnknownSequence.equals(subcode)) {
-//				
-//			}else if (Constants.SOAPFaults.Subcodes.InvalidAcknowledgement.equals(subcode)) {
-//				
-//			}else if (Constants.SOAPFaults.Subcodes.MessageNumberRoleover.equals(subcode)) {
-//				
-//			}else if (Constants.SOAPFaults.Subcodes.LastMessageNumberExceeded.equals(subcode)) {
-//				
-//			}else if (Constants.SOAPFaults.Subcodes.CreateSequenceRefused.equals(subcode)) {
-//				
-//			}
-		
-//		switch (data.type) {
-//		case Constants.MessageTypes.APPLICATION:
-//
-//			/* Sequence */
-//			OMElement sequence = ienvelope.getHeader()
-//					.getFirstChildWithName(
-//							new QName(Constants.WSRM.NS_URI_RM,
-//									Constants.WSRM.SEQUENCE));
-//			OMElement sidentifier = sequence.getFirstChildWithName(new QName(
-//					Constants.WSRM.NS_URI_RM, Constants.WSRM.IDENTIFIER));
-//
-//			OMNamespace snamespace = factory.createOMNamespace(
-//					Constants.WSRM.NS_URI_RM, Constants.WSRM.NS_PREFIX_RM);
-//			OMElement selement = factory.createOMElement(
-//					Constants.WSRM.IDENTIFIER, snamespace);
-//
-//			selement.setText(sidentifier.getText());
-//			faultDetail.addChild(selement);
-//			break;
-//
-//		case Constants.MessageTypes.ACK:
-//
-//			/* SequenceAcknowledge */
-//
-//			OMElement sequenceAck = ienvelope.getHeader()
-//					.getFirstChildWithName(
-//							new QName(Constants.WSRM.NS_URI_RM,
-//									Constants.WSRM.SEQUENCE_ACK));
-//			OMElement aidentifier = sequenceAck
-//					.getFirstChildWithName(new QName(Constants.WSRM.NS_URI_RM,
-//							Constants.WSRM.IDENTIFIER));
-//			OMNamespace anamespace = factory.createOMNamespace(
-//					Constants.WSRM.NS_URI_RM, Constants.WSRM.NS_PREFIX_RM);
-//			OMElement aelement = factory.createOMElement(
-//					Constants.WSRM.IDENTIFIER, anamespace);
-//
-//			aelement.setText(aidentifier.getText());
-//			faultDetail.addChild(aelement);
-//			break;
-//
-//		default:
-//
-//			/* TODO for other message types */
-//			break;
-//
-//		}
-//		}
-
-		
-
-//		try {
-//			msgCtx.setEnvelope(envelope);
-//		} catch (AxisFault e) {
-//			throw new SandeshaException(e.getMessage());
-//		}
+
+		//		if (detailElement!=null) {
+		//			String subcode = data.getSubcode();
+		//			
+		//			if (Constants.SOAPFaults.Subcodes.SequenceTerminated.equals(subcode))
+		// {
+		//				
+		//			}else if
+		// (Constants.SOAPFaults.Subcodes.UnknownSequence.equals(subcode)) {
+		//				
+		//			}else if
+		// (Constants.SOAPFaults.Subcodes.InvalidAcknowledgement.equals(subcode))
+		// {
+		//				
+		//			}else if
+		// (Constants.SOAPFaults.Subcodes.MessageNumberRoleover.equals(subcode))
+		// {
+		//				
+		//			}else if
+		// (Constants.SOAPFaults.Subcodes.LastMessageNumberExceeded.equals(subcode))
+		// {
+		//				
+		//			}else if
+		// (Constants.SOAPFaults.Subcodes.CreateSequenceRefused.equals(subcode))
+		// {
+		//				
+		//			}
+
+		//		switch (data.type) {
+		//		case Constants.MessageTypes.APPLICATION:
+		//
+		//			/* Sequence */
+		//			OMElement sequence = ienvelope.getHeader()
+		//					.getFirstChildWithName(
+		//							new QName(Constants.WSRM.NS_URI_RM,
+		//									Constants.WSRM.SEQUENCE));
+		//			OMElement sidentifier = sequence.getFirstChildWithName(new QName(
+		//					Constants.WSRM.NS_URI_RM, Constants.WSRM.IDENTIFIER));
+		//
+		//			OMNamespace snamespace = factory.createOMNamespace(
+		//					Constants.WSRM.NS_URI_RM, Constants.WSRM.NS_PREFIX_RM);
+		//			OMElement selement = factory.createOMElement(
+		//					Constants.WSRM.IDENTIFIER, snamespace);
+		//
+		//			selement.setText(sidentifier.getText());
+		//			faultDetail.addChild(selement);
+		//			break;
+		//
+		//		case Constants.MessageTypes.ACK:
+		//
+		//			/* SequenceAcknowledge */
+		//
+		//			OMElement sequenceAck = ienvelope.getHeader()
+		//					.getFirstChildWithName(
+		//							new QName(Constants.WSRM.NS_URI_RM,
+		//									Constants.WSRM.SEQUENCE_ACK));
+		//			OMElement aidentifier = sequenceAck
+		//					.getFirstChildWithName(new QName(Constants.WSRM.NS_URI_RM,
+		//							Constants.WSRM.IDENTIFIER));
+		//			OMNamespace anamespace = factory.createOMNamespace(
+		//					Constants.WSRM.NS_URI_RM, Constants.WSRM.NS_PREFIX_RM);
+		//			OMElement aelement = factory.createOMElement(
+		//					Constants.WSRM.IDENTIFIER, anamespace);
+		//
+		//			aelement.setText(aidentifier.getText());
+		//			faultDetail.addChild(aelement);
+		//			break;
+		//
+		//		default:
+		//
+		//			/* TODO for other message types */
+		//			break;
+		//
+		//		}
+		//		}
+
+		//		try {
+		//			msgCtx.setEnvelope(envelope);
+		//		} catch (AxisFault e) {
+		//			throw new SandeshaException(e.getMessage());
+		//		}
 	}
-	
-}
+
+}
\ No newline at end of file

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaDynamicProperties.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaDynamicProperties.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaDynamicProperties.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaDynamicProperties.java Sun Nov 20 08:23:27 2005
@@ -16,65 +16,68 @@
 
 package org.apache.sandesha2;
 
-import org.apache.axis2.soap.SOAP11Constants;
-import org.apache.axis2.soap.SOAP12Constants;
 import org.apache.sandesha2.policy.RMPolicyBean;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
 
 public class SandeshaDynamicProperties {
 
 	private String storageManagerImpl = Constants.STORAGE_MANAGER_IMPL;
+
 	private RMPolicyBean policyBean = null;
+
 	//private String SOAPVersionURI = null;
-	
-	public SandeshaDynamicProperties () {
-	
-		loadPolicyBeanFromConstants ();
-	}
-	
-	private void loadPolicyBeanFromConstants () {
-		//loading default properties. these will be overriden later (most of the time).
-		policyBean = new RMPolicyBean ();
-		policyBean.setAcknowledgementInterval(Constants.WSP.ACKNOWLEDGEMENT_INTERVAL);
-		policyBean.setRetransmissionInterval(Constants.WSP.RETRANSMISSION_INTERVAL);
+
+	public SandeshaDynamicProperties() {
+
+		loadPolicyBeanFromConstants();
+	}
+
+	private void loadPolicyBeanFromConstants() {
+		//loading default properties. these will be overriden later (most of
+		// the time).
+		policyBean = new RMPolicyBean();
+		policyBean
+				.setAcknowledgementInterval(Constants.WSP.ACKNOWLEDGEMENT_INTERVAL);
+		policyBean
+				.setRetransmissionInterval(Constants.WSP.RETRANSMISSION_INTERVAL);
 		policyBean.setExponentialBackoff(Constants.WSP.EXPONENTION_BACKOFF);
-		policyBean.setInactiveTimeoutInterval(Constants.WSP.INACTIVITY_TIMEOUT_INTERVAL);
-		
-//		if (Constants.SOAPVersion.DEFAULT==Constants.SOAPVersion.v1_1){
-//			SOAPVersionURI = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;
-//		}else {
-//			SOAPVersionURI = SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI;
-//		}
-		
+		policyBean
+				.setInactiveTimeoutInterval(Constants.WSP.INACTIVITY_TIMEOUT_INTERVAL);
+
+		//		if (Constants.SOAPVersion.DEFAULT==Constants.SOAPVersion.v1_1){
+		//			SOAPVersionURI = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;
+		//		}else {
+		//			SOAPVersionURI = SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI;
+		//		}
+
 		//default is SOAP 1.1
 		//SOAPVersionURI = SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI;
 	}
-	
-	
-	
-	
-	
+
 	public RMPolicyBean getPolicyBean() {
 		return policyBean;
 	}
-	
+
 	public void setPolicyBean(RMPolicyBean policyBean) {
 		this.policyBean = policyBean;
 	}
-	
-//	public String getSOAPVersionURI() {
-//		return SOAPVersionURI;
-//	}
-//	
-//	public void setSOAPVersionURI(String versionURI) {
-//		SOAPVersionURI = versionURI;
-//	}
-	
+
+	//	public String getSOAPVersionURI() {
+	//		return SOAPVersionURI;
+	//	}
+	//	
+	//	public void setSOAPVersionURI(String versionURI) {
+	//		SOAPVersionURI = versionURI;
+	//	}
+
 	public String getStorageManagerImpl() {
 		return storageManagerImpl;
 	}
-	
+
 	public void setStorageManagerImpl(String storageManagerImpl) {
 		this.storageManagerImpl = storageManagerImpl;
 	}
-}
+}
\ No newline at end of file

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaException.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaException.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaException.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaException.java Sun Nov 20 08:23:27 2005
@@ -20,8 +20,8 @@
 import org.apache.axis2.AxisFault;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
 
 //FIXME - extends AxisFault and clean code (remove unnecessary try-catches )

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaModule.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaModule.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaModule.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/SandeshaModule.java Sun Nov 20 08:23:27 2005
@@ -21,21 +21,25 @@
 import org.apache.axis2.engine.AxisConfiguration;
 import org.apache.axis2.modules.Module;
 
-public class SandeshaModule implements Module{
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
+
+public class SandeshaModule implements Module {
 
 	//private InOrderInvoker inorderInvoker = new InOrderInvoker ();
-	
-    // initialize the module
-    public void init(AxisConfiguration axisSystem) throws AxisFault {
-       
-    	//Start invoker thread
-    	//axisSystem.get
-    	//inorderInvoker.start();
-    	
-    }
-
-    // shutdown the module
-    public void shutdown(AxisConfiguration axisSystem) throws AxisFault {
-    	//inorderInvoker.stopWork();
-    }
-}
+
+	// initialize the module
+	public void init(AxisConfiguration axisSystem) throws AxisFault {
+
+		//Start invoker thread
+		//axisSystem.get
+		//inorderInvoker.start();
+
+	}
+
+	// shutdown the module
+	public void shutdown(AxisConfiguration axisSystem) throws AxisFault {
+		//inorderInvoker.stopWork();
+	}
+}
\ No newline at end of file

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java Sun Nov 20 08:23:27 2005
@@ -18,7 +18,9 @@
 package org.apache.sandesha2.handlers;
 
 import java.util.ArrayList;
+
 import javax.xml.namespace.QName;
+
 import org.apache.axis2.AxisFault;
 import org.apache.axis2.context.ConfigurationContext;
 import org.apache.axis2.context.MessageContext;
@@ -26,11 +28,8 @@
 import org.apache.axis2.engine.AxisEngine;
 import org.apache.axis2.handlers.AbstractHandler;
 import org.apache.axis2.soap.SOAPBody;
-import org.apache.axis2.transport.http.SimpleHTTPServer;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.apache.log4j.BasicConfigurator;
-import org.apache.log4j.PropertyConfigurator;
 import org.apache.sandesha2.Constants;
 import org.apache.sandesha2.RMMsgContext;
 import org.apache.sandesha2.SandeshaException;
@@ -44,51 +43,51 @@
 import org.apache.sandesha2.wsrm.Sequence;
 
 /**
- * 
- * @author chamikara
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
  */
 
 public class SandeshaGlobalInHandler extends AbstractHandler {
 
-	
-    protected Log log = LogFactory.getLog(SandeshaGlobalInHandler.class.getName());
-	   
+	protected Log log = LogFactory.getLog(SandeshaGlobalInHandler.class
+			.getName());
+
 	public void invoke(MessageContext msgContext) throws AxisFault {
-	
+
 		//try {
-		
+
 		//Quit the message with minimum processing if not intended for RM.
-		boolean isRMGlobalMessage = SandeshaUtil.isRMGlobalMessage (msgContext);
+		boolean isRMGlobalMessage = SandeshaUtil.isRMGlobalMessage(msgContext);
 		if (!isRMGlobalMessage) {
 			return;
 		}
-		
-		FaultManager faultManager = new FaultManager ();
-		RMMsgContext faultMessageContext = faultManager.checkForPossibleFaults(msgContext);
-	    if (faultMessageContext!=null){
-	    	ConfigurationContext configurationContext = msgContext.getSystemContext();
-	    	AxisEngine engine = new AxisEngine (configurationContext);
-	    	engine.send(faultMessageContext.getMessageContext());
-	    	return;
-	    }
-		
+
+		FaultManager faultManager = new FaultManager();
+		RMMsgContext faultMessageContext = faultManager
+				.checkForPossibleFaults(msgContext);
+		if (faultMessageContext != null) {
+			ConfigurationContext configurationContext = msgContext
+					.getSystemContext();
+			AxisEngine engine = new AxisEngine(configurationContext);
+			engine.send(faultMessageContext.getMessageContext());
+			return;
+		}
+
 		RMMsgContext rmMessageContext = MsgInitializer
 				.initializeMessage(msgContext);
 
-		
 		ConfigurationContext context = rmMessageContext.getMessageContext()
 				.getSystemContext();
 
 		//context.setProperty (Constants.SANDESHA_DEBUG_MODE,"on");
-		
+
 		ServiceContext serviceContext = msgContext.getServiceContext();
 		Object debug = null;
-		if (serviceContext!=null) {
+		if (serviceContext != null) {
 			debug = serviceContext.getProperty(Constants.SANDESHA_DEBUG_MODE);
 			if (debug != null && "on".equals(debug)) {
 				System.out.println("DEBUG: SandeshaGlobalInHandler got a '"
-					+ SandeshaUtil.getMessageTypeString(rmMessageContext
-							.getMessageType()) + "' message.");
+						+ SandeshaUtil.getMessageTypeString(rmMessageContext
+								.getMessageType()) + "' message.");
 			}
 		}
 
@@ -111,10 +110,11 @@
 			doGlobalProcessing(rmMessageContext);
 		}
 
-//		}catch (Exception e) {
-//			e.getStackTrace();
-//			throw new AxisFault ("Sandesha got an exception. See logs for details");
-//		}
+		//		}catch (Exception e) {
+		//			e.getStackTrace();
+		//			throw new AxisFault ("Sandesha got an exception. See logs for
+		// details");
+		//		}
 	}
 
 	private boolean dropIfDuplicate(RMMsgContext rmMsgContext)
@@ -123,7 +123,7 @@
 		boolean drop = false;
 
 		if (rmMsgContext.getMessageType() == Constants.MessageTypes.APPLICATION) {
-			
+
 			Sequence sequence = (Sequence) rmMsgContext
 					.getMessagePart(Constants.MessageParts.SEQUENCE);
 			String sequenceId = null;
@@ -153,41 +153,47 @@
 						drop = true;
 					}
 				}
-				
-				
-				if (drop==false) {
+
+				if (drop == false) {
 					//Checking for RM specific EMPTY_BODY LASTMESSAGE.
 					SOAPBody body = rmMsgContext.getSOAPEnvelope().getBody();
 					boolean emptyBody = false;
-					if (body.getChildElements().hasNext()==false) {
-						emptyBody = true;	
+					if (body.getChildElements().hasNext() == false) {
+						emptyBody = true;
 					}
-				
+
 					if (emptyBody) {
 						boolean lastMessage = false;
-						if (sequence.getLastMessage()!=null) {
-							System.out.println("Empty Body Last Message Received");
+						if (sequence.getLastMessage() != null) {
+							System.out
+									.println("Empty Body Last Message Received");
 							drop = true;
-						
-							if (receivedMsgsBean==null) {
-								receivedMsgsBean = new SequencePropertyBean (sequenceId,Constants.SequenceProperties.RECEIVED_MESSAGES,"");
+
+							if (receivedMsgsBean == null) {
+								receivedMsgsBean = new SequencePropertyBean(
+										sequenceId,
+										Constants.SequenceProperties.RECEIVED_MESSAGES,
+										"");
 								seqPropMgr.insert(receivedMsgsBean);
 							}
-							
-							String receivedMsgStr = (String) receivedMsgsBean.getValue();
+
+							String receivedMsgStr = (String) receivedMsgsBean
+									.getValue();
 							if (receivedMsgStr != "" && receivedMsgStr != null)
-								receivedMsgStr = receivedMsgStr + "," + Long.toString(msgNo);
+								receivedMsgStr = receivedMsgStr + ","
+										+ Long.toString(msgNo);
 							else
 								receivedMsgStr = Long.toString(msgNo);
-								
+
 							receivedMsgsBean.setValue(receivedMsgStr);
 							seqPropMgr.update(receivedMsgsBean);
-								
-							ApplicationMsgProcessor ackProcessor = new ApplicationMsgProcessor ();
-							ackProcessor.sendAckIfNeeded(rmMsgContext,receivedMsgStr);
-							
+
+							ApplicationMsgProcessor ackProcessor = new ApplicationMsgProcessor();
+							ackProcessor.sendAckIfNeeded(rmMsgContext,
+									receivedMsgStr);
+
+						}
 					}
-				}
 				}
 				//if (rmMsgContext.get)
 			}

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaInHandler.java Sun Nov 20 08:23:27 2005
@@ -38,39 +38,39 @@
 import org.apache.sandesha2.util.SandeshaUtil;
 
 /**
- * 
- * @author chamikara
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
  */
 
 public class SandeshaInHandler extends AbstractHandler {
 
-	
 	protected Log log = LogFactory.getLog(SandeshaInHandler.class.getName());
-	
+
 	public QName getName() {
 		return new QName(Constants.IN_HANDLER_NAME);
 	}
 
 	public void invoke(MessageContext msgCtx) throws AxisFault {
-		
+
 		//try {
-			
+
 		ConfigurationContext context = msgCtx.getSystemContext();
 		if (context == null)
 			throw new AxisFault("ConfigurationContext is null");
 
-		String DONE = (String) msgCtx.getProperty(Constants.APPLICATION_PROCESSING_DONE);
+		String DONE = (String) msgCtx
+				.getProperty(Constants.APPLICATION_PROCESSING_DONE);
 		if (null != DONE && "true".equals(DONE))
 			return;
-		
-		FaultManager faultManager = new FaultManager ();
-		RMMsgContext faultMessageContext = faultManager.checkForPossibleFaults(msgCtx);
-	    if (faultMessageContext!=null){
-	    	AxisEngine engine = new AxisEngine (context);
-	    	engine.send(faultMessageContext.getMessageContext());
-	    	return;
-	    }
-	    
+
+		FaultManager faultManager = new FaultManager();
+		RMMsgContext faultMessageContext = faultManager
+				.checkForPossibleFaults(msgCtx);
+		if (faultMessageContext != null) {
+			AxisEngine engine = new AxisEngine(context);
+			engine.send(faultMessageContext.getMessageContext());
+			return;
+		}
+
 		AxisService axisService = msgCtx.getAxisService();
 		if (axisService == null)
 			throw new AxisFault("AxisService is null");
@@ -94,12 +94,12 @@
 
 		ServiceContext serviceContext = msgCtx.getServiceContext();
 		Object debug = null;
-		if (serviceContext!=null) {
+		if (serviceContext != null) {
 			debug = serviceContext.getProperty(Constants.SANDESHA_DEBUG_MODE);
 			if (debug != null && "on".equals(debug)) {
 				System.out.println("DEBUG: SandeshaInHandler got a '"
-					+ SandeshaUtil.getMessageTypeString(rmMsgCtx
-							.getMessageType()) + "' message.");
+						+ SandeshaUtil.getMessageTypeString(rmMsgCtx
+								.getMessageType()) + "' message.");
 			}
 		}
 
@@ -115,11 +115,12 @@
 			se.printStackTrace();
 			throw new AxisFault("Error in processing the message");
 		}
-		
-//		}catch (Exception e) {
-//			e.getStackTrace();
-//			throw new AxisFault ("Sandesha got an exception. See logs for details");
-//		}
+
+		//		}catch (Exception e) {
+		//			e.getStackTrace();
+		//			throw new AxisFault ("Sandesha got an exception. See logs for
+		// details");
+		//		}
 
 	}
 

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java Sun Nov 20 08:23:27 2005
@@ -18,6 +18,7 @@
 package org.apache.sandesha2.handlers;
 
 import javax.xml.namespace.QName;
+
 import org.apache.axis2.AxisFault;
 import org.apache.axis2.addressing.EndpointReference;
 import org.apache.axis2.client.ListenerManager;
@@ -31,17 +32,14 @@
 import org.apache.axis2.description.Parameter;
 import org.apache.axis2.description.ParameterImpl;
 import org.apache.axis2.handlers.AbstractHandler;
-import org.apache.axis2.soap.SOAP11Constants;
-import org.apache.axis2.soap.SOAP12Constants;
 import org.apache.axis2.soap.SOAPBody;
 import org.apache.axis2.soap.SOAPEnvelope;
 import org.apache.axis2.soap.SOAPFactory;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.sandesha2.Constants;
-import org.apache.sandesha2.SandeshaDynamicProperties;
-import org.apache.sandesha2.SandeshaException;
 import org.apache.sandesha2.RMMsgContext;
+import org.apache.sandesha2.SandeshaException;
 import org.apache.sandesha2.policy.RMPolicyBean;
 import org.apache.sandesha2.storage.StorageManager;
 import org.apache.sandesha2.storage.beanmanagers.CreateSeqBeanMgr;
@@ -65,26 +63,22 @@
 import org.apache.sandesha2.wsrm.SequenceOffer;
 import org.apache.wsdl.WSDLConstants;
 
-
 /**
- * 
- * @author chamikara
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
  */
 
 public class SandeshaOutHandler extends AbstractHandler {
 
 	protected Log log = LogFactory.getLog(SandeshaOutHandler.class.getName());
-	
+
 	public void invoke(MessageContext msgCtx) throws AxisFault {
-		
+
 		//try {
-			
+
 		ConfigurationContext context = msgCtx.getSystemContext();
 		if (context == null)
 			throw new AxisFault("ConfigurationContext is null");
 
-		
-		
 		AxisService axisService = msgCtx.getAxisService();
 		if (axisService == null)
 			throw new AxisFault("AxisService is null");
@@ -104,7 +98,7 @@
 
 		//getting rm message
 		RMMsgContext rmMsgCtx = MsgInitializer.initializeMessage(msgCtx);
-		
+
 		Parameter keyParam = axisService.getParameter(Constants.RM_ENABLE_KEY);
 		Object keyValue = null;
 		if (keyParam != null)
@@ -124,7 +118,7 @@
 
 		ServiceContext serviceContext = msgCtx.getServiceContext();
 		Object debug = null;
-		if (serviceContext!=null) {
+		if (serviceContext != null) {
 			debug = serviceContext.getProperty(Constants.SANDESHA_DEBUG_MODE);
 			if (debug != null && "on".equals(debug)) {
 				System.out.println("DEBUG: SandeshaOutHandler got a '"
@@ -142,12 +136,10 @@
 		//Strating the sender.
 		SandeshaUtil.startSenderIfStopped(context);
 
-		
 		//Adding the policy bean
 		RMPolicyBean policyBean = RMPolicyManager.getPolicyBean(rmMsgCtx);
-		rmMsgCtx.setProperty(Constants.WSP.RM_POLICY_BEAN,policyBean);
-		
-		
+		rmMsgCtx.setProperty(Constants.WSP.RM_POLICY_BEAN, policyBean);
+
 		StorageManager storageManager = SandeshaUtil
 				.getSandeshaStorageManager(context);
 
@@ -212,19 +204,20 @@
 
 		SequencePropertyBean outSeqBean = seqPropMgr.retrieve(tempSequenceId,
 				Constants.SequenceProperties.OUT_SEQUENCE_ID);
-		
-		if (messageNumber==1) {
-			if (outSeqBean==null) {
+
+		if (messageNumber == 1) {
+			if (outSeqBean == null) {
 				sendCreateSequence = true;
 			}
-			
-//			SandeshaDynamicProperties dynamicProperties = SandeshaUtil.getDynamicProperties();
-//			if (msgCtx.isSOAP11()) {
-//				dynamicProperties.setSOAPVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI);
-//			}else {
-//				dynamicProperties.setSOAPVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
-//			}
-			
+
+			//			SandeshaDynamicProperties dynamicProperties =
+			// SandeshaUtil.getDynamicProperties();
+			//			if (msgCtx.isSOAP11()) {
+			//				dynamicProperties.setSOAPVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+			//			}else {
+			//				dynamicProperties.setSOAPVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+			//			}
+
 			//TODO: set the policy bean
 			//dynamicProperties.setPolicyBean();
 		}
@@ -249,13 +242,14 @@
 				seqPropMgr.insert(responseCreateSeqAdded);
 
 				String acksTo = null;
-				if (serviceContext!=null) {
-					acksTo = (String) serviceContext.getProperty(Constants.AcksTo);
+				if (serviceContext != null) {
+					acksTo = (String) serviceContext
+							.getProperty(Constants.AcksTo);
 				}
-				
-				if (acksTo==null)
+
+				if (acksTo == null)
 					acksTo = Constants.WSA.NS_URI_ANONYMOUS;
-				
+
 				//If acksTo is not anonymous. Start the listner TODO: verify
 				if (!Constants.WSA.NS_URI_ANONYMOUS.equals(acksTo)
 						&& !serverSide) {
@@ -276,11 +270,12 @@
 						if (acksToEPR != null)
 							acksTo = (String) acksToEPR.getAddress();
 					}
-				}else if (Constants.WSA.NS_URI_ANONYMOUS.equals(acksTo)){
+				} else if (Constants.WSA.NS_URI_ANONYMOUS.equals(acksTo)) {
 					//set transport in.
-					Object trIn = msgCtx.getProperty(MessageContext.TRANSPORT_IN);
-					if (trIn==null) {
-					
+					Object trIn = msgCtx
+							.getProperty(MessageContext.TRANSPORT_IN);
+					if (trIn == null) {
+
 					}
 				}
 
@@ -293,7 +288,8 @@
 
 		SOAPEnvelope env = rmMsgCtx.getSOAPEnvelope();
 		if (env == null) {
-			SOAPEnvelope envelope = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil.getSOAPVersion(env)).getDefaultEnvelope();
+			SOAPEnvelope envelope = SOAPAbstractFactory.getSOAPFactory(
+					SandeshaUtil.getSOAPVersion(env)).getDefaultEnvelope();
 			rmMsgCtx.setSOAPEnvelop(envelope);
 		}
 
@@ -407,13 +403,12 @@
 			//pausing the message
 			msgCtx.setPausedTrue(getName());
 		}
-		
-		
-		
-//		}catch (Exception e) {
-//			e.getStackTrace();
-//			throw new AxisFault ("Sandesha got an exception. See logs for details");
-//		}
+
+		//		}catch (Exception e) {
+		//			e.getStackTrace();
+		//			throw new AxisFault ("Sandesha got an exception. See logs for
+		// details");
+		//		}
 
 	}
 
@@ -431,7 +426,6 @@
 			throw new SandeshaException(
 					"Create Sequence part is null for a CreateSequence message");
 
-	
 		SequenceOffer offer = createSequencePart.getSequenceOffer();
 		if (offer != null) {
 			//Offer processing
@@ -478,10 +472,10 @@
 				createSeqMsg.getMessageID(), null);
 		createSeqMgr.insert(createSeqBean);
 
-		if (createSeqMsg.getReplyTo()==null)
-			createSeqMsg.setReplyTo(new EndpointReference (Constants.WSA.NS_URI_ANONYMOUS));
-		
-		
+		if (createSeqMsg.getReplyTo() == null)
+			createSeqMsg.setReplyTo(new EndpointReference(
+					Constants.WSA.NS_URI_ANONYMOUS));
+
 		RetransmitterBeanMgr retransmitterMgr = storageManager
 				.getRetransmitterBeanMgr();
 
@@ -501,8 +495,9 @@
 
 		MessageContext msg = rmMsg.getMessageContext();
 
-		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil.getSOAPVersion(rmMsg.getSOAPEnvelope()));
-		
+		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil
+				.getSOAPVersion(rmMsg.getSOAPEnvelope()));
+
 		if (rmMsg == null)
 			throw new SandeshaException("Message or reques message is null");
 
@@ -616,20 +611,18 @@
 
 		} else {
 			//client side
-			
-			
+
 			ServiceContext serviceContext = msg.getServiceContext();
-			if (serviceContext!=null) {
-				Object obj = serviceContext.getProperty(
-					Constants.LAST_MESSAGE);
+			if (serviceContext != null) {
+				Object obj = serviceContext.getProperty(Constants.LAST_MESSAGE);
 				if (obj != null && "true".equals(obj)) {
 					lastMessage = true;
 					sequence.setLastMessage(new LastMessage(factory));
 					//saving the last message no.
 					SequencePropertyBean lastOutMsgBean = new SequencePropertyBean(
-						tempSequenceId,
-						Constants.SequenceProperties.LAST_OUT_MESSAGE,
-						new Long(messageNumber));
+							tempSequenceId,
+							Constants.SequenceProperties.LAST_OUT_MESSAGE,
+							new Long(messageNumber));
 					sequencePropertyMgr.insert(lastOutMsgBean);
 				}
 			}

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=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java Sun Nov 20 08:23:27 2005
@@ -37,14 +37,18 @@
 import org.apache.sandesha2.wsrm.Nack;
 import org.apache.sandesha2.wsrm.SequenceAcknowledgement;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
+
 public class AcknowledgementProcessor implements MsgProcessor {
 
 	public void processMessage(RMMsgContext rmMsgCtx) throws SandeshaException {
 
-//		boolean b = true;
-//		if (b)
-//			return;
-		
+		//		boolean b = true;
+		//		if (b)
+		//			return;
+
 		SequenceAcknowledgement sequenceAck = (SequenceAcknowledgement) rmMsgCtx
 				.getMessagePart(Constants.MessageParts.SEQ_ACKNOWLEDGEMENT);
 		if (sequenceAck == null)
@@ -88,7 +92,7 @@
 		//So we set relatesTo value to null for ackMessages. (this happens in
 		// the SandeshaGlobal handler)
 		//Do this only if this is a standalone ACK.
-		if (rmMsgCtx.getMessageType()==Constants.MessageTypes.ACK)
+		if (rmMsgCtx.getMessageType() == Constants.MessageTypes.ACK)
 			rmMsgCtx.setRelatesTo(null);
 
 		RetransmitterBean input = new RetransmitterBean();
@@ -172,26 +176,26 @@
 	public void addTerminateSequenceMessage(RMMsgContext incomingAckRMMsg,
 			String outSequenceId, String tempSequenceId)
 			throws SandeshaException {
-		
+
 		StorageManager storageManager = SandeshaUtil
-		.getSandeshaStorageManager(incomingAckRMMsg.getMessageContext()
-				.getSystemContext());
-		
+				.getSandeshaStorageManager(incomingAckRMMsg.getMessageContext()
+						.getSystemContext());
+
 		SequencePropertyBeanMgr seqPropMgr = storageManager
-		.getSequencePropretyBeanMgr();
-		
-		SequencePropertyBean terminated = seqPropMgr.retrieve(outSequenceId,Constants.SequenceProperties.TERMINATE_ADDED);
-		
-		if (terminated!=null && terminated.getValue()!=null && "true".equals(terminated.getValue())) {
+				.getSequencePropretyBeanMgr();
+
+		SequencePropertyBean terminated = seqPropMgr.retrieve(outSequenceId,
+				Constants.SequenceProperties.TERMINATE_ADDED);
+
+		if (terminated != null && terminated.getValue() != null
+				&& "true".equals(terminated.getValue())) {
 			System.out.println("TERMINATE WAS ADDED PREVIOUSLY....");
 			return;
 		}
-		
+
 		RMMsgContext terminateRMMessage = RMMsgCreator
 				.createTerminateSequenceMessage(incomingAckRMMsg, outSequenceId);
 
-
-
 		//SequencePropertyBean replyToBean =
 		// seqPropMgr.retrieve(tempSequenceId,Constants.SequenceProperties.REPLY_TO_EPR);
 		SequencePropertyBean toBean = seqPropMgr.retrieve(tempSequenceId,
@@ -210,7 +214,8 @@
 		// (replyToEPR.getAddress()));
 		terminateRMMessage
 				.setWSAAction(Constants.WSRM.Actions.ACTION_TERMINATE_SEQUENCE);
-		terminateRMMessage.setSOAPAction(Constants.WSRM.Actions.SOAP_ACTION_TERMINATE_SEQUENCE);
+		terminateRMMessage
+				.setSOAPAction(Constants.WSRM.Actions.SOAP_ACTION_TERMINATE_SEQUENCE);
 
 		try {
 			terminateRMMessage.addSOAPEnvelope();
@@ -236,14 +241,14 @@
 
 		RetransmitterBeanMgr retramsmitterMgr = storageManager
 				.getRetransmitterBeanMgr();
-		
-		SequencePropertyBean terminateAdded = new SequencePropertyBean ();
+
+		SequencePropertyBean terminateAdded = new SequencePropertyBean();
 		terminateAdded.setName(Constants.SequenceProperties.TERMINATE_ADDED);
 		terminateAdded.setSequenceId(outSequenceId);
 		terminateAdded.setValue("true");
-	    
+
 		seqPropMgr.insert(terminateAdded);
-		
+
 		retramsmitterMgr.insert(terminateBean);
 
 	}

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java Sun Nov 20 08:23:27 2005
@@ -22,6 +22,7 @@
 import java.util.Iterator;
 
 import javax.xml.namespace.QName;
+
 import org.apache.axis2.AxisFault;
 import org.apache.axis2.addressing.EndpointReference;
 import org.apache.axis2.context.ConfigurationContext;
@@ -37,7 +38,6 @@
 import org.apache.axis2.engine.AxisEngine;
 import org.apache.axis2.soap.SOAPEnvelope;
 import org.apache.axis2.soap.SOAPFactory;
-import org.apache.derby.tools.sysinfo;
 import org.apache.sandesha2.Constants;
 import org.apache.sandesha2.RMMsgContext;
 import org.apache.sandesha2.SandeshaException;
@@ -60,7 +60,9 @@
 import org.apache.sandesha2.wsrm.SequenceAcknowledgement;
 import org.apache.wsdl.WSDLConstants;
 
-import com.sun.rsasign.p;
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
 
 public class ApplicationMsgProcessor implements MsgProcessor {
 
@@ -68,8 +70,9 @@
 
 	public void processMessage(RMMsgContext rmMsgCtx) throws SandeshaException {
 
-		//Object obj = rmMsgCtx.getProperty(Constants.APPLICATION_PROCESSING_DONE);
-		
+		//Object obj =
+		// rmMsgCtx.getProperty(Constants.APPLICATION_PROCESSING_DONE);
+
 		//Processing for ack if any
 		SequenceAcknowledgement sequenceAck = (SequenceAcknowledgement) rmMsgCtx
 				.getMessagePart(Constants.MessageParts.SEQ_ACKNOWLEDGEMENT);
@@ -252,8 +255,9 @@
 			throws SandeshaException {
 
 		MessageContext msgCtx = rmMsgCtx.getMessageContext();
-		
-		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil.getSOAPVersion(msgCtx.getEnvelope()));
+
+		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil
+				.getSOAPVersion(msgCtx.getEnvelope()));
 		StorageManager storageManager = SandeshaUtil
 				.getSandeshaStorageManager(msgCtx.getSystemContext());
 		SequencePropertyBeanMgr seqPropMgr = storageManager
@@ -267,9 +271,10 @@
 		if (configCtx == null)
 			throw new SandeshaException("Configuration Context is null");
 
-		AckRequested ackRequested = (AckRequested) rmMsgCtx.getMessagePart(Constants.MessageParts.ACK_REQUEST);
+		AckRequested ackRequested = (AckRequested) rmMsgCtx
+				.getMessagePart(Constants.MessageParts.ACK_REQUEST);
 		LastMessage lastMessage = (LastMessage) sequence.getLastMessage();
-		
+
 		//Setting the ack depending on AcksTo.
 		//TODO: Stop sending askc for every message.
 		SequencePropertyBean acksToBean = seqPropMgr.retrieve(sequenceId,
@@ -283,13 +288,14 @@
 					"Seqeunce properties are not set correctly");
 
 		//if (acksToStr.equals(Constants.WSA.NS_URI_ANONYMOUS)) {
-		
+
 		if (Constants.WSA.NS_URI_ANONYMOUS.equals(acksTo.getAddress())) {
-			// send ack in the sync case, only if the last message or the ackRequested tag is present.
+			// send ack in the sync case, only if the last message or the
+			// ackRequested tag is present.
 			boolean ackRequired = false;
-			if (ackRequested!=null || lastMessage!=null)
-					ackRequired = true;
-		
+			if (ackRequested != null || lastMessage != null)
+				ackRequired = true;
+
 			if (!ackRequired) {
 				return;
 			}
@@ -298,9 +304,9 @@
 		AxisConfiguration axisConfig = configCtx.getAxisConfiguration();
 		AxisServiceGroup serviceGroup = new AxisServiceGroup(axisConfig);
 		AxisService service = new AxisService(new QName("RMClientService")); // This
-																			 // is a
-																			 // dummy
-																			 // service.
+		// is a
+		// dummy
+		// service.
 		ServiceGroupContext serviceGroupContext = new ServiceGroupContext(
 				configCtx, serviceGroup);
 		ServiceContext serviceContext = new ServiceContext(service,
@@ -310,7 +316,7 @@
 		MessageContext ackMsgCtx = ackRMMsgCtx.getMessageContext();
 
 		ackMsgCtx.setMessageID(SandeshaUtil.getUUID());
-		
+
 		ackMsgCtx.setAxisServiceGroup(serviceGroup);
 		ackMsgCtx.setServiceGroupContext(serviceGroupContext);
 		ackMsgCtx.setAxisService(service);
@@ -352,31 +358,32 @@
 		ackMsgCtx.setReplyTo(msgCtx.getTo());
 		RMMsgCreator.addAckMessage(ackRMMsgCtx, sequenceId);
 
-//		Object obj = rmMsgCtx.getMessageContext().getOperationContext().getProperty(org.apache.axis2.Constants.RESPONSE_WRITTEN);
-		
-		
+		//		Object obj =
+		// rmMsgCtx.getMessageContext().getOperationContext().getProperty(org.apache.axis2.Constants.RESPONSE_WRITTEN);
+
 		if (Constants.WSA.NS_URI_ANONYMOUS.equals(acksTo.getAddress())) {
-			
-			
+
 			AxisEngine engine = new AxisEngine(ackRMMsgCtx.getMessageContext()
 					.getSystemContext());
 
 			//set CONTEXT_WRITTEN since acksto is anonymous
-			if (rmMsgCtx.getMessageContext().getOperationContext()==null) {
-				//operation context will be null when doing in a GLOBAL handler.
+			if (rmMsgCtx.getMessageContext().getOperationContext() == null) {
+				//operation context will be null when doing in a GLOBAL
+				// handler.
 				try {
-					AxisOperation op = AxisOperationFactory.getAxisOperation(AxisOperationFactory.MEP_CONSTANT_IN_OUT);
-					OperationContext opCtx = new OperationContext (op);
+					AxisOperation op = AxisOperationFactory
+							.getAxisOperation(AxisOperationFactory.MEP_CONSTANT_IN_OUT);
+					OperationContext opCtx = new OperationContext(op);
 					rmMsgCtx.getMessageContext().setAxisOperation(op);
 					rmMsgCtx.getMessageContext().setOperationContext(opCtx);
 				} catch (AxisFault e2) {
-					throw new SandeshaException (e2.getMessage());
+					throw new SandeshaException(e2.getMessage());
 				}
 			}
-			
+
 			rmMsgCtx.getMessageContext().getOperationContext().setProperty(
 					org.apache.axis2.Constants.RESPONSE_WRITTEN, "true");
-			
+
 			rmMsgCtx.getMessageContext().setProperty(Constants.ACK_WRITTEN,
 					"true");
 			try {
@@ -386,8 +393,8 @@
 			}
 		} else {
 			//rmMsgCtx.getMessageContext().getOperationContext().setProperty(
-				//	org.apache.axis2.Constants.RESPONSE_WRITTEN, "false");
-			
+			//	org.apache.axis2.Constants.RESPONSE_WRITTEN, "false");
+
 			RetransmitterBeanMgr retransmitterBeanMgr = storageManager
 					.getRetransmitterBeanMgr();
 
@@ -398,34 +405,36 @@
 			ackBean.setReSend(false);
 			ackBean.setSend(true);
 			ackBean.setMessagetype(Constants.MessageTypes.ACK);
-			
-			//the tempSequenceId value of the retransmitter Table for the messages related to an incoming
+
+			//the tempSequenceId value of the retransmitter Table for the
+			// messages related to an incoming
 			//sequence is the actual sequence ID - TODO document this.
 			ackBean.setTempSequenceId(sequenceId);
-			
-			RMPolicyBean policyBean = (RMPolicyBean) rmMsgCtx.getProperty(Constants.WSP.RM_POLICY_BEAN);
+
+			RMPolicyBean policyBean = (RMPolicyBean) rmMsgCtx
+					.getProperty(Constants.WSP.RM_POLICY_BEAN);
 			long ackInterval = Constants.WSP.ACKNOWLEDGEMENT_INTERVAL;
-			if (policyBean!=null) {
+			if (policyBean != null) {
 				ackInterval = policyBean.getAcknowledgementInaterval();
 			}
-			
-			//Ack will be sent as stand alone, only after the retransmitter interval.
-			long timeToSend = System.currentTimeMillis()+ackInterval;
+
+			//Ack will be sent as stand alone, only after the retransmitter
+			// interval.
+			long timeToSend = System.currentTimeMillis() + ackInterval;
 			ackBean.setTimeToSend(timeToSend);
-			
-			
+
 			//removing old acks.
-			RetransmitterBean findBean = new RetransmitterBean ();
+			RetransmitterBean findBean = new RetransmitterBean();
 			findBean.setMessagetype(Constants.MessageTypes.ACK);
 			findBean.setTempSequenceId(sequenceId);
 			Collection coll = retransmitterBeanMgr.find(findBean);
 			Iterator it = coll.iterator();
 			while (it.hasNext()) {
-				RetransmitterBean retransmitterBean = (RetransmitterBean) it.next();
+				RetransmitterBean retransmitterBean = (RetransmitterBean) it
+						.next();
 				retransmitterBeanMgr.delete(retransmitterBean.getMessageId());
 			}
-			
-			
+
 			//inserting the new ack.
 			retransmitterBeanMgr.insert(ackBean);
 

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqMsgProcessor.java Sun Nov 20 08:23:27 2005
@@ -41,6 +41,10 @@
 import org.apache.sandesha2.wsrm.CreateSequenceResponse;
 import org.apache.sandesha2.wsrm.SequenceOffer;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
+
 public class CreateSeqMsgProcessor implements MsgProcessor {
 
 	public void processMessage(RMMsgContext createSeqRMMsg)
@@ -154,17 +158,22 @@
 			seqPropMgr.insert(seqPropBean);
 			outMessage.setResponseWritten(true);
 
-			Object obj1 = createSeqMsg.getOperationContext().getProperty(org.apache.axis2.Constants.RESPONSE_WRITTEN);
+			Object obj1 = createSeqMsg.getOperationContext().getProperty(
+					org.apache.axis2.Constants.RESPONSE_WRITTEN);
 
 			AxisEngine engine = new AxisEngine(context);
 			engine.send(outMessage);
-			
-			Object obj = createSeqMsg.getOperationContext().getProperty(org.apache.axis2.Constants.RESPONSE_WRITTEN);
-			if (Constants.WSA.NS_URI_ANONYMOUS.equals(createSeqMsg.getReplyTo().getAddress())) {
+
+			Object obj = createSeqMsg.getOperationContext().getProperty(
+					org.apache.axis2.Constants.RESPONSE_WRITTEN);
+			if (Constants.WSA.NS_URI_ANONYMOUS.equals(createSeqMsg.getReplyTo()
+					.getAddress())) {
 				//So that '202 OK' get sent instead of 200 OK.
-				createSeqMsg.getOperationContext().setProperty(org.apache.axis2.Constants.RESPONSE_WRITTEN,"true");
-			}else {
-				createSeqMsg.getOperationContext().setProperty(org.apache.axis2.Constants.RESPONSE_WRITTEN,"false");
+				createSeqMsg.getOperationContext().setProperty(
+						org.apache.axis2.Constants.RESPONSE_WRITTEN, "true");
+			} else {
+				createSeqMsg.getOperationContext().setProperty(
+						org.apache.axis2.Constants.RESPONSE_WRITTEN, "false");
 			}
 		} catch (AxisFault e1) {
 			throw new SandeshaException(e1.getMessage());

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java Sun Nov 20 08:23:27 2005
@@ -47,12 +47,17 @@
 import java.util.Iterator;
 import javax.xml.namespace.QName;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
+
 public class CreateSeqResponseMsgProcessor implements MsgProcessor {
 	public void processMessage(RMMsgContext createSeqResponseRMMsgCtx)
 			throws SandeshaException {
 
-		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil.getSOAPVersion(createSeqResponseRMMsgCtx.getSOAPEnvelope()));
-		
+		SOAPFactory factory = SOAPAbstractFactory.getSOAPFactory(SandeshaUtil
+				.getSOAPVersion(createSeqResponseRMMsgCtx.getSOAPEnvelope()));
+
 		//Processing for ack if any
 		SequenceAcknowledgement sequenceAck = (SequenceAcknowledgement) createSeqResponseRMMsgCtx
 				.getMessagePart(Constants.MessageParts.SEQ_ACKNOWLEDGEMENT);
@@ -163,14 +168,15 @@
 			identifier.setIndentifer(newOutSequenceId);
 
 			sequencePart.setIdentifier(identifier);
-			
-			AckRequested ackRequestedPart = (AckRequested) applicaionRMMsg.getMessagePart(Constants.MessageParts.ACK_REQUEST);
-			if (ackRequestedPart!=null) {
-				Identifier id1 = new Identifier (factory);
+
+			AckRequested ackRequestedPart = (AckRequested) applicaionRMMsg
+					.getMessagePart(Constants.MessageParts.ACK_REQUEST);
+			if (ackRequestedPart != null) {
+				Identifier id1 = new Identifier(factory);
 				id1.setIndentifer(newOutSequenceId);
 				ackRequestedPart.setIdentifier(id1);
 			}
-			
+
 			try {
 				applicaionRMMsg.addSOAPEnvelope();
 			} catch (AxisFault e) {

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessor.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessor.java Sun Nov 20 08:23:27 2005
@@ -20,12 +20,11 @@
 import org.apache.sandesha2.RMMsgContext;
 import org.apache.sandesha2.SandeshaException;
 
-
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
 
 public interface MsgProcessor {
 	public void processMessage(RMMsgContext rmMsgCtx) throws SandeshaException;
-}
+}
\ No newline at end of file

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessorFactory.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessorFactory.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessorFactory.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/MsgProcessorFactory.java Sun Nov 20 08:23:27 2005
@@ -19,6 +19,10 @@
 
 import org.apache.sandesha2.Constants;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
+
 public class MsgProcessorFactory {
 
 	public static MsgProcessor getMessageProcessor(int msgType) {

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/TerminateSeqMsgProcessor.java Sun Nov 20 08:23:27 2005
@@ -17,13 +17,16 @@
 
 package org.apache.sandesha2.msgprocessors;
 
-
 import javax.xml.namespace.QName;
 import org.apache.axis2.context.MessageContext;
 import org.apache.sandesha2.Constants;
 import org.apache.sandesha2.RMMsgContext;
 import org.apache.sandesha2.SandeshaException;
 import org.apache.sandesha2.wsrm.SequenceAcknowledgement;
+
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ */
 
 public class TerminateSeqMsgProcessor implements MsgProcessor {
 

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgreceivers/RMMessageReceiver.java Sun Nov 20 08:23:27 2005
@@ -22,6 +22,10 @@
 import org.apache.axis2.context.MessageContext;
 import org.apache.axis2.receivers.AbstractMessageReceiver;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Jaliya Ekanayaka <jaliya@opensource.lk>
+ */
 
 //Currently this is a dummy Msg Receiver.
 //All the necessary RM logic happens at MessageProcessors.

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/policy/RMPolicyBean.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/policy/RMPolicyBean.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/policy/RMPolicyBean.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/policy/RMPolicyBean.java Sun Nov 20 08:23:27 2005
@@ -16,8 +16,10 @@
 
 
 /**
- * @author Sanka Samaranayake (sanka@apache.org)
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
+
 package org.apache.sandesha2.policy;
 
 import org.apache.sandesha2.Constants;

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java Sun Nov 20 08:23:27 2005
@@ -25,9 +25,10 @@
 import org.apache.sandesha2.storage.beanmanagers.StorageMapBeanMgr;
 
 /**
- * @author Chamikara Jayalath <chamikara@wso2.com>
- * @author Sanka Samaranayake <ssanka@gmail.com>
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
+
 public abstract class StorageManager {
 
 	private ConfigurationContext context;

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/Transaction.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/Transaction.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/Transaction.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/Transaction.java Sun Nov 20 08:23:27 2005
@@ -17,6 +17,11 @@
 
 package org.apache.sandesha2.storage;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
+ */
+
 public interface Transaction {
 
 	public void commit ();

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java Sun Nov 20 08:23:27 2005
@@ -23,9 +23,10 @@
 import org.apache.sandesha2.storage.beans.CreateSeqBean;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
+
 
 public interface CreateSeqBeanMgr extends RMBeanManager {
 

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java Sun Nov 20 08:23:27 2005
@@ -22,9 +22,10 @@
 import org.apache.sandesha2.storage.beans.NextMsgBean;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
+
 public interface NextMsgBeanMgr extends RMBeanManager {
 
 	public boolean delete(String sequenceId);

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RMBeanManager.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RMBeanManager.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RMBeanManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RMBeanManager.java Sun Nov 20 08:23:27 2005
@@ -18,8 +18,8 @@
 package org.apache.sandesha2.storage.beanmanagers;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
 
 public interface RMBeanManager {

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java Sun Nov 20 08:23:27 2005
@@ -23,8 +23,8 @@
 import org.apache.sandesha2.storage.beans.RetransmitterBean;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
 
 public interface RetransmitterBeanMgr extends RMBeanManager {

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java Sun Nov 20 08:23:27 2005
@@ -22,8 +22,8 @@
 import org.apache.sandesha2.storage.beans.SequencePropertyBean;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
 
 public interface SequencePropertyBeanMgr extends RMBeanManager {

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java Sun Nov 20 08:23:27 2005
@@ -22,8 +22,8 @@
 import org.apache.sandesha2.storage.beans.StorageMapBean;
 
 /**
- * @author Chamikara
- * @author Sanka
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
 
 public interface StorageMapBeanMgr extends RMBeanManager {

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java Sun Nov 20 08:23:27 2005
@@ -17,6 +17,11 @@
 
 package org.apache.sandesha2.storage.beans;
 
+/**
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
+ */
+
 public class CreateSeqBean implements RMBean {
 	private String tempSequenceId;
 

Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/NextMsgBean.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/NextMsgBean.java?rev=345762&r1=345761&r2=345762&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/NextMsgBean.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/NextMsgBean.java Sun Nov 20 08:23:27 2005
@@ -18,8 +18,10 @@
 package org.apache.sandesha2.storage.beans;
 
 /**
- * @author
+ * @author Chamikara Jayalath <chamikaramj@gmail.com>
+ * @author Sanka Samaranayaka <ssanka@gmail.com>
  */
+
 public class NextMsgBean implements RMBean {
 	private String SequenceId;
 



---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org


Mime
View raw message