You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ch...@apache.org on 2005/10/01 04:14:23 UTC
svn commit: r292904 - in
/webservices/sandesha/trunk/src/org/apache/sandesha2: ./ handlers/
msgprocessors/ storage/beanmanagers/ storage/beans/
Author: chamikara
Date: Fri Sep 30 19:12:44 2005
New Revision: 292904
URL: http://svn.apache.org/viewcvs?rev=292904&view=rev
Log:
Following message exchange is working for the Echo case.
--> create seq
<-- create seq response
--> app. message
<-- ack
--> terminate seq
<-- create seq
--> create seq response
<-- app. response message
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java
webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java
webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/ServerOutHandler.java
webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
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=292904&r1=292903&r2=292904&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/Constants.java Fri Sep 30 19:12:44 2005
@@ -137,6 +137,8 @@
String REPLY_TO_EPR = "ReplyToEPR";
String APP_MSG_PROCESSOR_LIST = "AppMsgProcessorList";
+
+ String OUT_CREATE_SEQUENCE_SENT = "OutCreateSeqSent";
}
public interface SOAPVersion {
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java?rev=292904&r1=292903&r2=292904&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/Sender.java Fri Sep 30 19:12:44 2005
@@ -28,11 +28,16 @@
import org.apache.axis2.context.AbstractContext;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.OperationContext;
import org.apache.axis2.engine.AxisEngine;
+import org.apache.sandesha2.msgreceivers.RMMessageReceiver;
import org.apache.sandesha2.storage.AbstractBeanMgrFactory;
import org.apache.sandesha2.storage.beanmanagers.RetransmitterBeanMgr;
import org.apache.sandesha2.storage.beans.RetransmitterBean;
import org.apache.sandesha2.util.SandeshaUtil;
+import org.apache.sandesha2.wsrm.Sequence;
+
+import com.sun.rsasign.m;
public class Sender extends Thread {
@@ -66,23 +71,14 @@
RetransmitterBean bean = (RetransmitterBean) iter.next();
String key = (String) bean.getKey();
MessageContext msgCtx = SandeshaUtil.getStoredMessageContext(key);
-
- try {
- System.out.println ("SERIALIZATION BEFORE SENDING....");
- XMLStreamWriter writer = XMLOutputFactory.newInstance().createXMLStreamWriter(System.out);
- msgCtx.getEnvelope().serialize(writer);
- } catch (XMLStreamException e2) {
- // TODO Auto-generated catch block
- e2.printStackTrace();
- } catch (FactoryConfigurationError e2) {
- // TODO Auto-generated catch block
- e2.printStackTrace();
- }
-
- try {
+
+ try {
+ updateMessage (msgCtx);
new AxisEngine(context).send(msgCtx);
} catch (AxisFault e1) {
e1.printStackTrace();
+ }catch (SandeshaException e2){
+ e2.printStackTrace();
}
//changing the values of the sent bean.
@@ -107,6 +103,28 @@
senderStarted = true;
this.context = context;
super.start();
+ }
+
+ private void updateMessage (MessageContext msgCtx) throws SandeshaException {
+ try {
+ RMMsgContext rmMsgCtx = MsgInitializer.initializeMessage(msgCtx);
+
+ if (rmMsgCtx.getMessageType()==Constants.MessageTypes.CREATE_SEQ) {
+ if (msgCtx.getOperationDescription()==null)
+ throw new SandeshaException ("Operation description is null");
+
+ msgCtx.getOperationDescription().setMessageReceiver(new RMMessageReceiver ());
+ OperationContext createSeqOpCtx = new OperationContext (msgCtx.getOperationDescription());
+ createSeqOpCtx.addMessageContext(msgCtx);
+ msgCtx.setOperationContext(createSeqOpCtx);
+ if (msgCtx.getSystemContext()!=null)
+ msgCtx.getSystemContext().registerOperationContext(msgCtx.getMessageID(),createSeqOpCtx);
+ else
+ throw new SandeshaException ("System context is null");
+ }
+ } catch (AxisFault e) {
+ throw new SandeshaException ("Exception in updating contexts");
+ }
}
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/ServerOutHandler.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/ServerOutHandler.java?rev=292904&r1=292903&r2=292904&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/ServerOutHandler.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/handlers/ServerOutHandler.java Fri Sep 30 19:12:44 2005
@@ -43,9 +43,11 @@
import org.apache.sandesha2.RMMsgCreator;
import org.apache.sandesha2.msgreceivers.RMMessageReceiver;
import org.apache.sandesha2.storage.AbstractBeanMgrFactory;
+import org.apache.sandesha2.storage.beanmanagers.CreateSeqBeanMgr;
import org.apache.sandesha2.storage.beanmanagers.RetransmitterBeanMgr;
import org.apache.sandesha2.storage.beanmanagers.SequencePropertyBeanMgr;
import org.apache.sandesha2.storage.beanmanagers.StorageMapBeanMgr;
+import org.apache.sandesha2.storage.beans.CreateSeqBean;
import org.apache.sandesha2.storage.beans.RetransmitterBean;
import org.apache.sandesha2.storage.beans.SequencePropertyBean;
import org.apache.sandesha2.storage.beans.StorageMapBean;
@@ -64,6 +66,9 @@
public void invoke(MessageContext msgCtx) throws AxisFault {
//log
System.out.println("In server OutHandler");
+ String DONE = (String) msgCtx.getProperty(Constants.APPLICATION_PROCESSING_DONE);
+ if (null!=DONE && "true".equals(DONE))
+ return;
//Strating the sender.
ConfigurationContext ctx = msgCtx.getSystemContext();
@@ -80,6 +85,10 @@
//getting the request message and rmMessage.
MessageContext reqMsgCtx = msgCtx.getOperationContext()
.getMessageContext(WSDLConstants.MESSAGE_LABEL_IN);
+// MessageContext temp = msgCtx.getOperationContext()
+// .getMessageContext(WSDLConstants.MESSAGE_LABEL_OUT);
+//
+
RMMsgContext requestRMMsgCtx;
try {
requestRMMsgCtx = MsgInitializer.initializeMessage(reqMsgCtx);
@@ -89,7 +98,7 @@
AbstractContext context = rmMsgCtx.getContext();
if (context == null)
throw new SandeshaException("Context is null");
-
+
Sequence sequence = (Sequence) requestRMMsgCtx
.getMessagePart(Constants.MessageParts.SEQUENCE);
if (sequence == null)
@@ -101,8 +110,9 @@
SequencePropertyBeanMgr seqPropMgr = AbstractBeanMgrFactory
.getInstance(context).getSequencePropretyBeanMgr();
- SequencePropertyBean acksToBean = seqPropMgr.retrieve(
- incomingSeqId, Constants.SequenceProperties.ACKS_TO_EPR);
+ SequencePropertyBean acksToBean = seqPropMgr
+ .retrieve(incomingSeqId,
+ Constants.SequenceProperties.ACKS_TO_EPR);
if (acksToBean == null
|| acksToBean.getValue() == null
|| !(acksToBean.getValue() instanceof EndpointReference))
@@ -117,8 +127,7 @@
SOAPEnvelope env = rmMsgCtx.getSOAPEnvelope();
if (env == null) {
SOAPEnvelope envelope = SOAPAbstractFactory.getSOAPFactory(
- Constants.SOAPVersion.DEFAULT)
- .getDefaultEnvelope();
+ Constants.SOAPVersion.DEFAULT).getDefaultEnvelope();
rmMsgCtx.setSOAPEnvelop(envelope);
}
SOAPBody soapBody = rmMsgCtx.getSOAPEnvelope().getBody();
@@ -210,15 +219,17 @@
if (context == null)
throw new SandeshaException("Context is null");
- SequencePropertyBeanMgr mgr = AbstractBeanMgrFactory.getInstance(
- context).getSequencePropretyBeanMgr();
-
- SequencePropertyBean toBean = mgr.retrieve(incomingSeqId,
- Constants.SequenceProperties.TO_EPR);
- SequencePropertyBean replyToBean = mgr.retrieve(incomingSeqId,
- Constants.SequenceProperties.REPLY_TO_EPR);
- SequencePropertyBean outSequenceBean = mgr.retrieve(incomingSeqId,
- Constants.SequenceProperties.OUT_SEQUENCE_ID);
+ SequencePropertyBeanMgr sequencePropertyMgr = AbstractBeanMgrFactory
+ .getInstance(context).getSequencePropretyBeanMgr();
+ RetransmitterBeanMgr retransmitterMgr = AbstractBeanMgrFactory
+ .getInstance(context).getRetransmitterBeanMgr();
+
+ SequencePropertyBean toBean = sequencePropertyMgr.retrieve(
+ incomingSeqId, Constants.SequenceProperties.TO_EPR);
+ SequencePropertyBean replyToBean = sequencePropertyMgr.retrieve(
+ incomingSeqId, Constants.SequenceProperties.REPLY_TO_EPR);
+ SequencePropertyBean outSequenceBean = sequencePropertyMgr.retrieve(
+ incomingSeqId, Constants.SequenceProperties.OUT_SEQUENCE_ID);
if (toBean == null)
throw new SandeshaException("To is null");
@@ -239,55 +250,68 @@
rmMsg.setTo(incomingReplyTo);
rmMsg.setReplyTo(incomingTo);
- if (outSequenceBean == null || outSequenceBean.getValue() == null) {
- RetransmitterBeanMgr retransmitterMgr = AbstractBeanMgrFactory
- .getInstance(context).getRetransmitterBeanMgr();
-
- rmMsg.getMessageContext().setPausedTrue(getName());
- RetransmitterBean appMsgEntry = new RetransmitterBean();
+ rmMsg.getMessageContext().setPausedTrue(getName());
- RMMsgContext copiedRMMsgCtx = SandeshaUtil.deepCopy(rmMsg);
- MessageContext copiedMsgCtx = copiedRMMsgCtx.getMessageContext();
- MessageContext msg = rmMsg.getMessageContext();
-
- Object val = msg.getOperationContext().getProperty(
- org.apache.axis2.Constants.RESPONSE_WRITTEN);
- copiedMsgCtx.setServiceGroupContext(msg.getServiceGroupContext());
- copiedMsgCtx.setServiceGroupContextId(msg
- .getServiceGroupContextId());
- copiedMsgCtx.setServiceContext(msg.getServiceContext());
- copiedMsgCtx.setServiceContextID(msg.getServiceContextID());
- copiedMsgCtx.setOperationContext(msg.getOperationContext());
-
- //TODO IF - may not work when op context is changed
- try {
- msg.getOperationContext().addMessageContext(copiedMsgCtx);
- } catch (AxisFault e) {
- e.printStackTrace();
- }
-
- String key = SandeshaUtil.storeMessageContext(rmMsg
- .getMessageContext());
- appMsgEntry.setKey(key);
- appMsgEntry.setLastSentTime(0);
- appMsgEntry.setTempSequenceId(incomingSeqId);
- appMsgEntry.setSend(false);
- appMsgEntry.setMessageId(rmMsg.getMessageId());
+ RMMsgContext copiedRMMsgCtx = SandeshaUtil.deepCopy(rmMsg);
+ MessageContext copiedMsgCtx = copiedRMMsgCtx.getMessageContext();
+ MessageContext msg = rmMsg.getMessageContext();
+
+ Object val = msg.getOperationContext().getProperty(
+ org.apache.axis2.Constants.RESPONSE_WRITTEN);
+ copiedMsgCtx.setServiceGroupContext(msg.getServiceGroupContext());
+ copiedMsgCtx.setServiceGroupContextId(msg
+ .getServiceGroupContextId());
+ copiedMsgCtx.setServiceContext(msg.getServiceContext());
+ copiedMsgCtx.setServiceContextID(msg.getServiceContextID());
+ copiedMsgCtx.setOperationContext(msg.getOperationContext());
+ //TODO IF - may not work when op context is changed
+ try {
+ msg.getOperationContext().addMessageContext(copiedMsgCtx);
+ } catch (AxisFault e) {
+ e.printStackTrace();
+ }
+
+ copiedMsgCtx.setProperty(Constants.APPLICATION_PROCESSING_DONE,"true");
- retransmitterMgr.insert(appMsgEntry);
+ //Retransmitter bean entry for the application message
+ RetransmitterBean appMsgEntry = new RetransmitterBean();
+ String key = SandeshaUtil
+ .storeMessageContext(copiedMsgCtx);
+ appMsgEntry.setKey(key);
+ appMsgEntry.setLastSentTime(0);
+ appMsgEntry.setTempSequenceId(incomingSeqId);
+ appMsgEntry.setMessageId(rmMsg.getMessageId());
+
+ if (outSequenceBean == null || outSequenceBean.getValue() == null) {
+
- addCreateSequenceMessage(rmMsg);
+ SequencePropertyBean responseCreateSeqAdded = sequencePropertyMgr.retrieve(
+ incomingSeqId,
+ Constants.SequenceProperties.OUT_CREATE_SEQUENCE_SENT);
+
+ if (responseCreateSeqAdded == null || responseCreateSeqAdded.getValue() == null
+ || "".equals(responseCreateSeqAdded.getValue())) {
+ responseCreateSeqAdded = new SequencePropertyBean(incomingSeqId,
+ Constants.SequenceProperties.OUT_CREATE_SEQUENCE_SENT,
+ "true");
+ sequencePropertyMgr.insert(responseCreateSeqAdded);
+ addCreateSequenceMessage(rmMsg,incomingSeqId);
+ }
+ appMsgEntry.setSend(false);
} else {
//Sequence id is present
//set sequence part
//add message to retransmitter table with send=true;
+ appMsgEntry.setSend(true);
}
+ retransmitterMgr.insert(appMsgEntry);
+
}
- public void addCreateSequenceMessage(RMMsgContext applicationRMMsg)
+ public void addCreateSequenceMessage(RMMsgContext applicationRMMsg,String incomingSequenceId)
throws SandeshaException {
MessageContext applicationMsg = applicationRMMsg.getMessageContext();
if (applicationMsg == null)
@@ -299,8 +323,11 @@
if (context == null)
throw new SandeshaException("Context is null");
- StorageMapBeanMgr storageMapMgr = AbstractBeanMgrFactory.getInstance(
- context).getStorageMapBeanMgr();
+ CreateSeqBeanMgr createSeqMgr =
+ AbstractBeanMgrFactory.getInstance(context).getCreateSeqBeanMgr();
+ CreateSeqBean createSeqBean = new CreateSeqBean (incomingSequenceId,createSeqMsg.getMessageID(),null);
+ createSeqMgr.insert(createSeqBean);
+
RetransmitterBeanMgr retransmitterMgr = AbstractBeanMgrFactory
.getInstance(context).getRetransmitterBeanMgr();
String key = SandeshaUtil.storeMessageContext(createSeqRMMessage
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=292904&r1=292903&r2=292904&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/msgprocessors/CreateSeqResponseMsgProcessor.java Fri Sep 30 19:12:44 2005
@@ -1,51 +1,115 @@
/*
- * Copyright 1999-2004 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
+ * Copyright 1999-2004 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ *
*/
package org.apache.sandesha2.msgprocessors;
+import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.MsgInitializer;
import org.apache.sandesha2.RMMsgContext;
import org.apache.sandesha2.SandeshaException;
import org.apache.sandesha2.storage.AbstractBeanMgrFactory;
+import org.apache.sandesha2.storage.beans.CreateSeqBean;
import org.apache.sandesha2.storage.beans.RetransmitterBean;
+import org.apache.sandesha2.storage.beans.SequencePropertyBean;
+import org.apache.sandesha2.storage.beanmanagers.CreateSeqBeanMgr;
import org.apache.sandesha2.storage.beanmanagers.RetransmitterBeanMgr;
+import org.apache.sandesha2.storage.beanmanagers.SequencePropertyBeanMgr;
+import org.apache.sandesha2.util.SandeshaUtil;
+import org.apache.sandesha2.wsrm.CreateSequenceResponse;
+import org.apache.sandesha2.wsrm.Identifier;
+import org.apache.sandesha2.wsrm.MessageNumber;
+import org.apache.sandesha2.wsrm.Sequence;
import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
import java.util.Iterator;
-
public class CreateSeqResponseMsgProcessor implements MsgProcessor {
- public void processMessage(RMMsgContext rmMsgCtx) throws SandeshaException {
+ public void processMessage(RMMsgContext createSeqResponseRMMsgCtx)
+ throws SandeshaException {
+
+ System.out.println("IN CREATE SEQ RESPONSE PROCESSOR");
- System.out.println("IN CREATE SEQ RESPONSE PROCESSOR");
- ConfigurationContext configCtx = rmMsgCtx.getMessageContext().getSystemContext();
- String msgId = rmMsgCtx.getMessageContext().getRelatesTo().getValue();
- RetransmitterBeanMgr mgr =
- AbstractBeanMgrFactory.getInstance(configCtx).getRetransmitterBeanMgr();
-
- RetransmitterBean createSeqBean = mgr.retrieve(msgId);
- String tempSeqId = createSeqBean.getTempSequenceId();
- mgr.delete(msgId);
-
- RetransmitterBean target = new RetransmitterBean();
- target.setTempSequenceId(tempSeqId);
-
- Iterator iterator = mgr.find(target).iterator();
- while (iterator.hasNext()) {
- ((RetransmitterBean) iterator.next()).setSend(true);
- }
- }
-}
+ CreateSequenceResponse createSeqResponsePart = (CreateSequenceResponse) createSeqResponseRMMsgCtx
+ .getMessagePart(Constants.MessageParts.CREATE_SEQ_RESPONSE);
+ if (createSeqResponsePart == null)
+ throw new SandeshaException("Create Sequence Response part is null");
+
+ String newOutSequenceId = createSeqResponsePart.getIdentifier()
+ .getIdentifier();
+ if (newOutSequenceId == null)
+ throw new SandeshaException("New sequence Id is null");
+
+ ConfigurationContext configCtx = createSeqResponseRMMsgCtx
+ .getMessageContext().getSystemContext();
+ String createSeqMsgId = createSeqResponseRMMsgCtx.getMessageContext()
+ .getRelatesTo().getValue();
+ RetransmitterBeanMgr retransmitterMgr = AbstractBeanMgrFactory
+ .getInstance(configCtx).getRetransmitterBeanMgr();
+ CreateSeqBeanMgr createSeqMgr = AbstractBeanMgrFactory.getInstance(
+ configCtx).getCreateSeqBeanMgr();
+
+ CreateSeqBean createSeqBean = createSeqMgr.retrieve(createSeqMsgId);
+ if (createSeqBean == null)
+ throw new SandeshaException("Create Sequence entry is not found");
+
+ String incomingSequenceId = createSeqBean.getTempSequenceId();
+ if (incomingSequenceId == null || "".equals(incomingSequenceId))
+ throw new SandeshaException("Incoming sequence ID has is not set");
+
+ //deleting the create sequence entry.
+ retransmitterMgr.delete(createSeqMsgId);
+
+ //storing new out sequence id
+ SequencePropertyBeanMgr sequencePropMgr = AbstractBeanMgrFactory
+ .getInstance(configCtx).getSequencePropretyBeanMgr();
+ SequencePropertyBean outSequenceBean = new SequencePropertyBean(
+ incomingSequenceId,
+ Constants.SequenceProperties.OUT_SEQUENCE_ID, newOutSequenceId);
+ sequencePropMgr.insert(outSequenceBean);
+
+ RetransmitterBean target = new RetransmitterBean();
+ target.setTempSequenceId(incomingSequenceId);
+
+ Iterator iterator = retransmitterMgr.find(target).iterator();
+ while (iterator.hasNext()) {
+ RetransmitterBean tempBean = (RetransmitterBean) iterator.next();
+
+ //updating the application message
+ String key = tempBean.getKey();
+ MessageContext applicationMsg = SandeshaUtil
+ .getStoredMessageContext(key);
+ RMMsgContext applicaionRMMsg = MsgInitializer
+ .initializeMessage(applicationMsg);
+
+ Sequence sequence = new Sequence();
+ Identifier identifier = new Identifier ();
+ identifier.setIndentifer(newOutSequenceId);
+ sequence.setIdentifier(identifier);
+
+ //FIXME set a correct message number.
+ MessageNumber msgNumber = new MessageNumber ();
+ msgNumber.setMessageNumber(1);
+ sequence.setMessageNumber(msgNumber);
+ applicaionRMMsg.setMessagePart(Constants.MessageParts.SEQUENCE,sequence);
+
+ //asking to send the application msssage
+ tempBean.setSend(true);
+ retransmitterMgr.update(tempBean);
+ }
+ }
+}
\ No newline at end of file
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=292904&r1=292903&r2=292904&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 Fri Sep 30 19:12:44 2005
@@ -86,7 +86,7 @@
*
* beans.add(temp); }
*/
- boolean add = false;
+ boolean add = true;
if (bean.getKey() != null && bean.getKey() != temp.getKey())
add = false;
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=292904&r1=292903&r2=292904&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 Fri Sep 30 19:12:44 2005
@@ -9,6 +9,15 @@
private String SequenceId;
+ public CreateSeqBean (){
+
+ }
+
+ public CreateSeqBean (String tempSeqId, String CreateSeqMsgId, String sequenceId) {
+ this.tempSequenceId = tempSeqId;
+ this.CreateSeqMsgId = CreateSeqMsgId;
+ this.SequenceId = sequenceId;
+ }
/**
* @return Returns the createSeqMsgId.
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org