You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2005/11/20 17:27:30 UTC
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/
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 <ch...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@gmail.com>
+ * @author Jaliya Ekanayaka <ja...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@gmail.com>
+ * @author Jaliya Ekanayaka <ja...@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 <ch...@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 <ch...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@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 <ch...@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 <ch...@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 <ch...@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 <ch...@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 <ch...@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 <ch...@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 <ch...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@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 <ch...@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 <ch...@gmail.com>
+ * @author Jaliya Ekanayaka <ja...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@wso2.com>
- * @author Sanka Samaranayake <ss...@gmail.com>
+ * @author Chamikara Jayalath <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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 <ch...@gmail.com>
+ * @author Sanka Samaranayaka <ss...@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