ws-sandesha-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chamik...@apache.org
Subject svn commit: r471982 - in /webservices/sandesha/trunk/java/src/org/apache/sandesha2: ./ storage/ storage/beans/
Date Tue, 07 Nov 2006 04:48:07 GMT
Author: chamikara
Date: Mon Nov  6 20:48:06 2006
New Revision: 471982

URL: http://svn.apache.org/viewvc?view=rev&rev=471982
Log:
Patch from Andrew for Sandesha2-41

Modified:
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/SandeshaException.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/SandeshaStorageException.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/InvokerBean.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/NextMsgBean.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SenderBean.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/SandeshaException.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/SandeshaException.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/SandeshaException.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/SandeshaException.java Mon Nov
 6 20:48:06 2006
@@ -1,45 +1,44 @@
-/*
- * 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;
-
-import javax.xml.namespace.QName;
-
-import org.apache.axiom.om.OMElement;
-import org.apache.axis2.AxisFault;
-
-/**
- * Exception class of Sandesa2.
- */
-
-public class SandeshaException extends AxisFault  {
-
-	public SandeshaException (String message) {
-		super (message);
-	}
-	
-	public SandeshaException (Exception e) {
-		super (e);
-	}
-
-	public SandeshaException (String message,Exception e) {
-		super (message,e);
-	}
-	
-	
-	
-}
+/*
+ * 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;
+
+import org.apache.axis2.AxisFault;
+
+/**
+ * Exception class of Sandesa2.
+ */
+
+public class SandeshaException extends AxisFault  {
+
+	private static final long serialVersionUID = 730653663339985226L;
+
+	public SandeshaException (String message) {
+		super (message);
+	}
+	
+	public SandeshaException (Exception e) {
+		super (e);
+	}
+
+	public SandeshaException (String message,Exception e) {
+		super (message,e);
+	}
+	
+	
+	
+}

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/SandeshaStorageException.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/SandeshaStorageException.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/SandeshaStorageException.java
(original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/SandeshaStorageException.java
Mon Nov  6 20:48:06 2006
@@ -1,39 +1,42 @@
-/*
- * 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.storage;
-
-import org.apache.sandesha2.SandeshaException;
-
-/**
- * To easily track exceptions happening in the storage area.
- */
-
-public class SandeshaStorageException extends SandeshaException {
-	public SandeshaStorageException (String message) {
-		super (message);
-	}
-	
-	public SandeshaStorageException (Exception e) {
-		super (e);
-	}
-	
-	public SandeshaStorageException (String m,Exception e) {
-		super (m,e);
-	}
-	
-}
+/*
+ * 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.storage;
+
+import org.apache.sandesha2.SandeshaException;
+
+/**
+ * To easily track exceptions happening in the storage area.
+ */
+
+public class SandeshaStorageException extends SandeshaException {
+	
+	private static final long serialVersionUID = -8620608387173070005L;
+
+	public SandeshaStorageException (String message) {
+		super (message);
+	}
+	
+	public SandeshaStorageException (Exception e) {
+		super (e);
+	}
+	
+	public SandeshaStorageException (String m,Exception e) {
+		super (m,e);
+	}
+	
+}

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
(original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/CreateSeqBean.java
Mon Nov  6 20:48:06 2006
@@ -1,125 +1,127 @@
-/*
- * 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.storage.beans;
-
-/**
- * This bean is used at the sending side (of both server and client)
- * There is on object of this for each sequence.
- */
-
-public class CreateSeqBean extends RMBean {
-	
-	/**
-	 * Comment for <code>internalSequenceID</code>
-	 * This property is a unique identifier that can be used to identify the messages of a certain
sequence.
-	 * This is specially used by the sending side, since sequence id is not available in the
begining.
-	 * For the client side, indernal sequence id is a concantination of wsa:To and SEQUENCE_KEY
(SEQUENCE_KEY can be set as a property).
-	 * For the server side, this is the sequenceId of the incoming sequence.
-	 */
-	private String internalSequenceID;
-
-	/**
-	 * Comment for <code>createSeqMsgID</code>
-	 * This is the message ID of the create sequence message.
-	 */
-	private String createSeqMsgID;
-
-	/**
-	 * Comment for <code>sequenceID</code>
-	 * This is the actual Sequence ID of the sequence.
-	 */
-	private String sequenceID;
-	
-	/**
-	 * Comment for <code>securityTokenData</code>
-	 * This is the security token data needed to reconstruct the token that secures this sequence.
-	 */
-	private String securityTokenData;
-	
-
-//	private boolean pollingMode;
-
-	
-	/**
-	 * The key that is used to store the CreateSequence message in the Message Storage.
-	 * This is stored here, so that the CreateSequence message can be used as a reference when
Sandesha
-	 * want the generate new messages. (e.g. MakeConnection)
-	 */
-	private String createSequenceMsgStoreKey;
-	
-	/**
-	 * This is stored here, so that the message pointed by this can be used as a reference when
Sandesha
-	 * want the generate new messages. (e.g. MakeConnection). Create sequence message could
not be used 
-	 * here since it may be subjected to things like encryption.
-	 */
-	private String referenceMessageStoreKey;
-	
-	public CreateSeqBean() {
-	}
-
-
-	public String getCreateSeqMsgID() {
-		return createSeqMsgID;
-	}
-
-	public void setCreateSeqMsgID(String createSeqMsgID) {
-		this.createSeqMsgID = createSeqMsgID;
-	}
-
-	public String getSequenceID() {
-		return sequenceID;
-	}
-
-	public void setSequenceID(String sequenceID) {
-		this.sequenceID = sequenceID;
-	}
-
-	public String getInternalSequenceID() {
-		return internalSequenceID;
-	}
-
-	public void setInternalSequenceID(String internalSequenceID) {
-		this.internalSequenceID = internalSequenceID;
-	}
-
-	public String getSecurityTokenData() {
-		return securityTokenData;
-	}
-
-	public void setSecurityTokenData(String securityTokenData) {
-		this.securityTokenData = securityTokenData;
-	}
-
-	public String getCreateSequenceMsgStoreKey() {
-		return createSequenceMsgStoreKey;
-	}
-
-	public void setCreateSequenceMsgStoreKey(String createSequenceMsgStoreKey) {
-		this.createSequenceMsgStoreKey = createSequenceMsgStoreKey;
-	}
-
-
-	public String getReferenceMessageStoreKey() {
-		return referenceMessageStoreKey;
-	}
-
-	public void setReferenceMessageStoreKey(String referenceMessageStoreKey) {
-		this.referenceMessageStoreKey = referenceMessageStoreKey;
-	}
-	
-}
+/*
+ * 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.storage.beans;
+
+/**
+ * This bean is used at the sending side (of both server and client)
+ * There is on object of this for each sequence.
+ */
+
+public class CreateSeqBean extends RMBean {
+	
+	private static final long serialVersionUID = 7051201094510208784L;
+
+	/**
+	 * Comment for <code>internalSequenceID</code>
+	 * This property is a unique identifier that can be used to identify the messages of a certain
sequence.
+	 * This is specially used by the sending side, since sequence id is not available in the
begining.
+	 * For the client side, indernal sequence id is a concantination of wsa:To and SEQUENCE_KEY
(SEQUENCE_KEY can be set as a property).
+	 * For the server side, this is the sequenceId of the incoming sequence.
+	 */
+	private String internalSequenceID;
+
+	/**
+	 * Comment for <code>createSeqMsgID</code>
+	 * This is the message ID of the create sequence message.
+	 */
+	private String createSeqMsgID;
+
+	/**
+	 * Comment for <code>sequenceID</code>
+	 * This is the actual Sequence ID of the sequence.
+	 */
+	private String sequenceID;
+	
+	/**
+	 * Comment for <code>securityTokenData</code>
+	 * This is the security token data needed to reconstruct the token that secures this sequence.
+	 */
+	private String securityTokenData;
+	
+
+//	private boolean pollingMode;
+
+	
+	/**
+	 * The key that is used to store the CreateSequence message in the Message Storage.
+	 * This is stored here, so that the CreateSequence message can be used as a reference when
Sandesha
+	 * want the generate new messages. (e.g. MakeConnection)
+	 */
+	private String createSequenceMsgStoreKey;
+	
+	/**
+	 * This is stored here, so that the message pointed by this can be used as a reference when
Sandesha
+	 * want the generate new messages. (e.g. MakeConnection). Create sequence message could
not be used 
+	 * here since it may be subjected to things like encryption.
+	 */
+	private String referenceMessageStoreKey;
+	
+	public CreateSeqBean() {
+	}
+
+
+	public String getCreateSeqMsgID() {
+		return createSeqMsgID;
+	}
+
+	public void setCreateSeqMsgID(String createSeqMsgID) {
+		this.createSeqMsgID = createSeqMsgID;
+	}
+
+	public String getSequenceID() {
+		return sequenceID;
+	}
+
+	public void setSequenceID(String sequenceID) {
+		this.sequenceID = sequenceID;
+	}
+
+	public String getInternalSequenceID() {
+		return internalSequenceID;
+	}
+
+	public void setInternalSequenceID(String internalSequenceID) {
+		this.internalSequenceID = internalSequenceID;
+	}
+
+	public String getSecurityTokenData() {
+		return securityTokenData;
+	}
+
+	public void setSecurityTokenData(String securityTokenData) {
+		this.securityTokenData = securityTokenData;
+	}
+
+	public String getCreateSequenceMsgStoreKey() {
+		return createSequenceMsgStoreKey;
+	}
+
+	public void setCreateSequenceMsgStoreKey(String createSequenceMsgStoreKey) {
+		this.createSequenceMsgStoreKey = createSequenceMsgStoreKey;
+	}
+
+
+	public String getReferenceMessageStoreKey() {
+		return referenceMessageStoreKey;
+	}
+
+	public void setReferenceMessageStoreKey(String referenceMessageStoreKey) {
+		this.referenceMessageStoreKey = referenceMessageStoreKey;
+	}
+	
+}

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/InvokerBean.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/InvokerBean.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/InvokerBean.java
(original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/InvokerBean.java
Mon Nov  6 20:48:06 2006
@@ -1,115 +1,117 @@
-/*
- * 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.storage.beans;
-
-/**
- * This bean is used at the receiving side (of both server and client)
- * There is one object for each application message to be invoked.
- */
-
-public class InvokerBean extends RMBean {
-
-	/**
-	 * Comment for <code>messageContextRefKey</code>
-	 * 
-	 * This is the messageContextRefKey that is obtained after saving a message context in a
storage.
-	 */
-	private String messageContextRefKey;
-
-	/**
-	 * Comment for <code>msgNo</code>
-	 * The message number of the message.
-	 */
-	private long msgNo;
-
-	/**
-	 * Comment for <code>sequenceID</code>
-	 * The sequence ID of the sequence the message belong to.
-	 */
-	private String sequenceID;
-	
-	/**
-	 * Comment for <code>invoked</code>
-	 * Weather the message has been invoked by the invoker.
-	 */
-	private boolean invoked = false;
-	
-
-	public InvokerBean() {
-
-	}
-
-	public InvokerBean(String key, long msgNo, String sequenceId) {
-		this.messageContextRefKey = key;
-		this.msgNo = msgNo;
-		this.sequenceID = sequenceId;
-	}
-
-	/**
-	 * @return Returns the messageContextRefKey.
-	 */
-	public String getMessageContextRefKey() {
-		return messageContextRefKey;
-	}
-
-	/**
-	 * @param messageContextRefKey
-	 *            The messageContextRefKey to set.
-	 */
-	public void setMessageContextRefKey(String messageContextRefKey) {
-		this.messageContextRefKey = messageContextRefKey;
-	}
-
-	/**
-	 * @return Returns the msgNo.
-	 */
-	public long getMsgNo() {
-		return msgNo;
-	}
-
-	/**
-	 * @param msgNo
-	 *            The msgNo to set.
-	 */
-	public void setMsgNo(long msgNo) {
-		this.msgNo = msgNo;
-	}
-
-	/**
-	 * @return Returns the sequenceID.
-	 */
-	public String getSequenceID() {
-		return sequenceID;
-	}
-
-	/**
-	 * @param sequenceID
-	 *            The sequenceID to set.
-	 */
-	public void setSequenceID(String sequenceId) {
-		this.sequenceID = sequenceId;
-	}
-	
-	public boolean isInvoked() {
-		return invoked;
-	}
-	
-	public void setInvoked(boolean invoked) {
-		this.invoked = invoked;
-	}
+/*
+ * 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.storage.beans;
+
+/**
+ * This bean is used at the receiving side (of both server and client)
+ * There is one object for each application message to be invoked.
+ */
+
+public class InvokerBean extends RMBean {
+
+	private static final long serialVersionUID = -7839397509697276257L;
+
+	/**
+	 * Comment for <code>messageContextRefKey</code>
+	 * 
+	 * This is the messageContextRefKey that is obtained after saving a message context in a
storage.
+	 */
+	private String messageContextRefKey;
+
+	/**
+	 * Comment for <code>msgNo</code>
+	 * The message number of the message.
+	 */
+	private long msgNo;
+
+	/**
+	 * Comment for <code>sequenceID</code>
+	 * The sequence ID of the sequence the message belong to.
+	 */
+	private String sequenceID;
+	
+	/**
+	 * Comment for <code>invoked</code>
+	 * Weather the message has been invoked by the invoker.
+	 */
+	private boolean invoked = false;
+	
+
+	public InvokerBean() {
+
+	}
+
+	public InvokerBean(String key, long msgNo, String sequenceId) {
+		this.messageContextRefKey = key;
+		this.msgNo = msgNo;
+		this.sequenceID = sequenceId;
+	}
+
+	/**
+	 * @return Returns the messageContextRefKey.
+	 */
+	public String getMessageContextRefKey() {
+		return messageContextRefKey;
+	}
+
+	/**
+	 * @param messageContextRefKey
+	 *            The messageContextRefKey to set.
+	 */
+	public void setMessageContextRefKey(String messageContextRefKey) {
+		this.messageContextRefKey = messageContextRefKey;
+	}
+
+	/**
+	 * @return Returns the msgNo.
+	 */
+	public long getMsgNo() {
+		return msgNo;
+	}
+
+	/**
+	 * @param msgNo
+	 *            The msgNo to set.
+	 */
+	public void setMsgNo(long msgNo) {
+		this.msgNo = msgNo;
+	}
+
+	/**
+	 * @return Returns the sequenceID.
+	 */
+	public String getSequenceID() {
+		return sequenceID;
+	}
+
+	/**
+	 * @param sequenceID
+	 *            The sequenceID to set.
+	 */
+	public void setSequenceID(String sequenceId) {
+		this.sequenceID = sequenceId;
+	}
+	
+	public boolean isInvoked() {
+		return invoked;
+	}
+	
+	public void setInvoked(boolean invoked) {
+		this.invoked = invoked;
+	}
 }

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/NextMsgBean.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/NextMsgBean.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/NextMsgBean.java
(original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/NextMsgBean.java
Mon Nov  6 20:48:06 2006
@@ -1,107 +1,109 @@
-/*
- * 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.storage.beans;
-
-/**
- * This bean is used at the receiving side (of both server and client)
- * There is one entry for each sequence.
- */
-
-public class NextMsgBean extends RMBean {
-	
-	/**
-	 * Comment for <code>sequenceID</code>
-	 * The sequenceID of the representing sequence.
-	 */
-	private String sequenceID;
-
-	/**
-	 * Comment for <code>nextMsgNoToProcess</code>
-	 * The next message to be invoked of the representing sequence.
-	 */
-	private long nextMsgNoToProcess;
-	
-	/**
-	 * This tells weather this sequence is in the polling mode or not.
-	 * PollingManager will use this property decide the sequences that need
-	 * polling and will do MakeConnections on them.
-	 */
-	private boolean pollingMode=false;
-	
-	/**
-	 * This will be used as a referenced 
-	 */
-	private String referenceMessageKey;
-	
-
-	public NextMsgBean() {
-
-	}
-
-	public NextMsgBean(String sequenceID, long nextNsgNo) {
-		this.sequenceID = sequenceID;
-		this.nextMsgNoToProcess = nextNsgNo;
-	}
-
-	/**
-	 * @return Returns the nextMsgNoToProcess.
-	 */
-	public long getNextMsgNoToProcess() {
-		return nextMsgNoToProcess;
-	}
-
-	/**
-	 * @param nextMsgNoToProcess
-	 *            The nextMsgNoToProcess to set.
-	 */
-	public void setNextMsgNoToProcess(long nextMsgNoToProcess) {
-		this.nextMsgNoToProcess = nextMsgNoToProcess;
-	}
-
-	/**
-	 * @return Returns the sequenceId.
-	 */
-	public String getSequenceID() {
-		return sequenceID;
-	}
-
-	/**
-	 * @param sequenceId
-	 *            The sequenceId to set.
-	 */
-	public void setSequenceID(String sequenceID) {
-		this.sequenceID = sequenceID;
-	}
-
-	public boolean isPollingMode() {
-		return pollingMode;
-	}
-
-	public void setPollingMode(boolean pollingMode) {
-		this.pollingMode = pollingMode;
-	}
-
-	public String getReferenceMessageKey() {
-		return referenceMessageKey;
-	}
-
-	public void setReferenceMessageKey(String referenceMessageKey) {
-		this.referenceMessageKey = referenceMessageKey;
-	}
-	
+/*
+ * 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.storage.beans;
+
+/**
+ * This bean is used at the receiving side (of both server and client)
+ * There is one entry for each sequence.
+ */
+
+public class NextMsgBean extends RMBean {
+	
+	private static final long serialVersionUID = -2976123838615087562L;
+
+	/**
+	 * Comment for <code>sequenceID</code>
+	 * The sequenceID of the representing sequence.
+	 */
+	private String sequenceID;
+
+	/**
+	 * Comment for <code>nextMsgNoToProcess</code>
+	 * The next message to be invoked of the representing sequence.
+	 */
+	private long nextMsgNoToProcess;
+	
+	/**
+	 * This tells weather this sequence is in the polling mode or not.
+	 * PollingManager will use this property decide the sequences that need
+	 * polling and will do MakeConnections on them.
+	 */
+	private boolean pollingMode=false;
+	
+	/**
+	 * This will be used as a referenced 
+	 */
+	private String referenceMessageKey;
+	
+
+	public NextMsgBean() {
+
+	}
+
+	public NextMsgBean(String sequenceID, long nextNsgNo) {
+		this.sequenceID = sequenceID;
+		this.nextMsgNoToProcess = nextNsgNo;
+	}
+
+	/**
+	 * @return Returns the nextMsgNoToProcess.
+	 */
+	public long getNextMsgNoToProcess() {
+		return nextMsgNoToProcess;
+	}
+
+	/**
+	 * @param nextMsgNoToProcess
+	 *            The nextMsgNoToProcess to set.
+	 */
+	public void setNextMsgNoToProcess(long nextMsgNoToProcess) {
+		this.nextMsgNoToProcess = nextMsgNoToProcess;
+	}
+
+	/**
+	 * @return Returns the sequenceId.
+	 */
+	public String getSequenceID() {
+		return sequenceID;
+	}
+
+	/**
+	 * @param sequenceId
+	 *            The sequenceId to set.
+	 */
+	public void setSequenceID(String sequenceID) {
+		this.sequenceID = sequenceID;
+	}
+
+	public boolean isPollingMode() {
+		return pollingMode;
+	}
+
+	public void setPollingMode(boolean pollingMode) {
+		this.pollingMode = pollingMode;
+	}
+
+	public String getReferenceMessageKey() {
+		return referenceMessageKey;
+	}
+
+	public void setReferenceMessageKey(String referenceMessageKey) {
+		this.referenceMessageKey = referenceMessageKey;
+	}
+	
 }

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SenderBean.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SenderBean.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SenderBean.java
(original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SenderBean.java
Mon Nov  6 20:48:06 2006
@@ -1,213 +1,215 @@
-/*
- * 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.storage.beans;
-
-/**
- * This bean is used at the sending side (of both server and client)
- * There is one eatry for each message to be sent.
- */
-
-public class SenderBean extends RMBean {
-
-	/**
-	 * Comment for <code>messageID</code>
-	 * The message id of the representing message.
-	 * 
-	 */
-	private String messageID;
-
-	/**
-	 * Comment for <code>messageContextRefKey</code>
-	 * Key retrieved by the storage mechanism after storing the message.
-	 */
-	private String messageContextRefKey;
-
-	/**
-	 * Comment for <code>send</code>
-	 * The sender will not send the message unless this property is true.
-	 */
-	private boolean send;
-
-	/**
-	 * Comment for <code>internalSequenceID</code>
-	 * Please see the comment of CreateSeqBean.
-	 */
-	private String internalSequenceID;
-
-	/**
-	 * Comment for <code>sentCount</code>
-	 * The number of times current message has been sent.
-	 */
-	private int sentCount = 0;
-
-	/**
-	 * Comment for <code>messageNumber</code>
-	 * The message number of the current message.
-	 */
-	private long messageNumber = 0;
-
-	/**
-	 * Comment for <code>reSend</code>
-	 * If this property if false. The message has to be sent only once. The entry has to be
deleted after sending.
-	 */
-	private boolean reSend = true;
-
-	/**
-	 * Comment for <code>timeToSend</code>
-	 * Message has to be sent only after this time.
-	 */
-	private long timeToSend = 0;
-	
-	/**
-	 * Comment for <code>messageType</code>
-	 * The type of the current message.
-	 * Possible types are given in Sandesha2Constants.MessageTypes interface.
-	 */
-	private int messageType =0;
-	
-	/**
-	 * The sequenceID of the sequence this message belong to.
-	 * this may be null for some messages (e.g. create sequence);
-	 */
-	//TODO fill this property correctly
-	private String sequenceID;
-	
-	/**
-	 * TODO use the value in CreateSequenceBean.
-	 */
-	private String wsrmAnonURI;
-	
-	/**
-	 * Destination URL of the message to be sent. This can be used to decide weather the message
cannot be sent,
-	 * before actyally reading the message from the storage.
-	 */
-	private String toAddress;
-	
-	public SenderBean() {
-
-	}
-
-	public SenderBean(String messageID, String key,
-			boolean send,long timeToSend, String internalSequenceID, long messageNumber) {
-		this.messageID = messageID;
-		this.messageContextRefKey = key;
-		//this.LastSentTime = lastSentTime;
-		this.timeToSend = timeToSend;
-		this.send = send;
-		this.internalSequenceID = internalSequenceID;
-		this.messageNumber = messageNumber;
-	}
-
-	public String getMessageContextRefKey() {
-		return messageContextRefKey;
-	}
-
-	public void setMessageContextRefKey(String messageContextRefKey) {
-		this.messageContextRefKey = messageContextRefKey;
-	}
-
-	public String getMessageID() {
-		return messageID;
-	}
-
-	public void setMessageID(String messageID) {
-		this.messageID = messageID;
-	}
-
-	public boolean isSend() {
-		return send;
-	}
-
-	public void setSend(boolean send) {
-		this.send = send;
-	}
-
-	public String getInternalSequenceID() {
-		return internalSequenceID;
-	}
-
-	public void setInternalSequenceID(String internalSequenceId) {
-		this.internalSequenceID = internalSequenceId;
-	}
-
-	public int getSentCount() {
-		return sentCount;
-	}
-
-	public void setSentCount(int sentCount) {
-		this.sentCount = sentCount;
-	}
-
-	public long getMessageNumber() {
-		return messageNumber;
-	}
-
-	public void setMessageNumber(long messageNumber) {
-		this.messageNumber = messageNumber;
-	}
-
-	public boolean isReSend() {
-		return reSend;
-	}
-
-	public void setReSend(boolean reSend) {
-		this.reSend = reSend;
-	}
-	
-	public long getTimeToSend() {
-		return timeToSend;
-	}
-	
-	public void setTimeToSend(long timeToSend) {
-		this.timeToSend = timeToSend;
-	}
-	
-	
-	public int getMessageType() {
-		return messageType;
-	}
-	
-	public void setMessageType(int messagetype) {
-		this.messageType = messagetype;
-	}
-
-	public String getSequenceID() {
-		return sequenceID;
-	}
-
-	public void setSequenceID(String sequenceID) {
-		this.sequenceID = sequenceID;
-	}
-
-	public String getWsrmAnonURI() {
-		return wsrmAnonURI;
-	}
-
-	public void setWsrmAnonURI(String wsrmAnonURI) {
-		this.wsrmAnonURI = wsrmAnonURI;
-	}
-
-	public String getToAddress() {
-		return toAddress;
-	}
-
-	public void setToAddress(String toAddress) {
-		this.toAddress = toAddress;
-	}
-	
+/*
+ * 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.storage.beans;
+
+/**
+ * This bean is used at the sending side (of both server and client)
+ * There is one eatry for each message to be sent.
+ */
+
+public class SenderBean extends RMBean {
+
+	private static final long serialVersionUID = 5776347847725156786L;
+
+	/**
+	 * Comment for <code>messageID</code>
+	 * The message id of the representing message.
+	 * 
+	 */
+	private String messageID;
+
+	/**
+	 * Comment for <code>messageContextRefKey</code>
+	 * Key retrieved by the storage mechanism after storing the message.
+	 */
+	private String messageContextRefKey;
+
+	/**
+	 * Comment for <code>send</code>
+	 * The sender will not send the message unless this property is true.
+	 */
+	private boolean send;
+
+	/**
+	 * Comment for <code>internalSequenceID</code>
+	 * Please see the comment of CreateSeqBean.
+	 */
+	private String internalSequenceID;
+
+	/**
+	 * Comment for <code>sentCount</code>
+	 * The number of times current message has been sent.
+	 */
+	private int sentCount = 0;
+
+	/**
+	 * Comment for <code>messageNumber</code>
+	 * The message number of the current message.
+	 */
+	private long messageNumber = 0;
+
+	/**
+	 * Comment for <code>reSend</code>
+	 * If this property if false. The message has to be sent only once. The entry has to be
deleted after sending.
+	 */
+	private boolean reSend = true;
+
+	/**
+	 * Comment for <code>timeToSend</code>
+	 * Message has to be sent only after this time.
+	 */
+	private long timeToSend = 0;
+	
+	/**
+	 * Comment for <code>messageType</code>
+	 * The type of the current message.
+	 * Possible types are given in Sandesha2Constants.MessageTypes interface.
+	 */
+	private int messageType =0;
+	
+	/**
+	 * The sequenceID of the sequence this message belong to.
+	 * this may be null for some messages (e.g. create sequence);
+	 */
+	//TODO fill this property correctly
+	private String sequenceID;
+	
+	/**
+	 * TODO use the value in CreateSequenceBean.
+	 */
+	private String wsrmAnonURI;
+	
+	/**
+	 * Destination URL of the message to be sent. This can be used to decide weather the message
cannot be sent,
+	 * before actyally reading the message from the storage.
+	 */
+	private String toAddress;
+	
+	public SenderBean() {
+
+	}
+
+	public SenderBean(String messageID, String key,
+			boolean send,long timeToSend, String internalSequenceID, long messageNumber) {
+		this.messageID = messageID;
+		this.messageContextRefKey = key;
+		//this.LastSentTime = lastSentTime;
+		this.timeToSend = timeToSend;
+		this.send = send;
+		this.internalSequenceID = internalSequenceID;
+		this.messageNumber = messageNumber;
+	}
+
+	public String getMessageContextRefKey() {
+		return messageContextRefKey;
+	}
+
+	public void setMessageContextRefKey(String messageContextRefKey) {
+		this.messageContextRefKey = messageContextRefKey;
+	}
+
+	public String getMessageID() {
+		return messageID;
+	}
+
+	public void setMessageID(String messageID) {
+		this.messageID = messageID;
+	}
+
+	public boolean isSend() {
+		return send;
+	}
+
+	public void setSend(boolean send) {
+		this.send = send;
+	}
+
+	public String getInternalSequenceID() {
+		return internalSequenceID;
+	}
+
+	public void setInternalSequenceID(String internalSequenceId) {
+		this.internalSequenceID = internalSequenceId;
+	}
+
+	public int getSentCount() {
+		return sentCount;
+	}
+
+	public void setSentCount(int sentCount) {
+		this.sentCount = sentCount;
+	}
+
+	public long getMessageNumber() {
+		return messageNumber;
+	}
+
+	public void setMessageNumber(long messageNumber) {
+		this.messageNumber = messageNumber;
+	}
+
+	public boolean isReSend() {
+		return reSend;
+	}
+
+	public void setReSend(boolean reSend) {
+		this.reSend = reSend;
+	}
+	
+	public long getTimeToSend() {
+		return timeToSend;
+	}
+	
+	public void setTimeToSend(long timeToSend) {
+		this.timeToSend = timeToSend;
+	}
+	
+	
+	public int getMessageType() {
+		return messageType;
+	}
+	
+	public void setMessageType(int messagetype) {
+		this.messageType = messagetype;
+	}
+
+	public String getSequenceID() {
+		return sequenceID;
+	}
+
+	public void setSequenceID(String sequenceID) {
+		this.sequenceID = sequenceID;
+	}
+
+	public String getWsrmAnonURI() {
+		return wsrmAnonURI;
+	}
+
+	public void setWsrmAnonURI(String wsrmAnonURI) {
+		this.wsrmAnonURI = wsrmAnonURI;
+	}
+
+	public String getToAddress() {
+		return toAddress;
+	}
+
+	public void setToAddress(String toAddress) {
+		this.toAddress = toAddress;
+	}
+	
 }

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java?view=diff&rev=471982&r1=471981&r2=471982
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java
(original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java
Mon Nov  6 20:48:06 2006
@@ -1,81 +1,83 @@
-/*
- * Copyright 2004,2005 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.storage.beans;
-
-/**
- * This bean is used to store properties of a certain sequence.
- * Used by both sending and receiving sides.
- */
-
-public class SequencePropertyBean extends RMBean {
-
-	/**
-	 * Comment for <code>sequencePropertyKey</code>
-	 * The key used to store properties of this sequence.
-	 * The value depends on the endpoint as given below.
-	 * 
-	 * RMS (sending side) - internalSequenceId
-	 * RMD - sequenceId
-	 */
-	private String sequencePropertyKey;
-
-	/**
-	 * Comment for <code>name</code>
-	 * The name of the property. Possible names are given in the Sandesha2Constants.SequenceProperties
interface.
-	 */
-	private String name;
-
-	/**
-	 * Comment for <code>value</code>
-	 * The value of the property.
-	 */
-	private String value;
-
-	public SequencePropertyBean(String seqID, String propertyName, String value) {
-		this.sequencePropertyKey = seqID;
-		this.name = propertyName;
-		this.value = value;
-	}
-
-	public SequencePropertyBean() {
-
-	}
-
-	public String getName() {
-		return name;
-	}
-
-	public void setName(String name) {
-		this.name = name;
-	}
-
-	public String getSequencePropertyKey() {
-		return sequencePropertyKey;
-	}
-
-	public void setSequencePropertyKey(String sequencePropertyKey) {
-		this.sequencePropertyKey = sequencePropertyKey;
-	}
-
-	public String getValue() {
-		return value;
-	}
-
-	public void setValue(String value) {
-		this.value = value;
-	}
+/*
+ * Copyright 2004,2005 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.storage.beans;
+
+/**
+ * This bean is used to store properties of a certain sequence.
+ * Used by both sending and receiving sides.
+ */
+
+public class SequencePropertyBean extends RMBean {
+
+	private static final long serialVersionUID = 8266532177909565832L;
+
+	/**
+	 * Comment for <code>sequencePropertyKey</code>
+	 * The key used to store properties of this sequence.
+	 * The value depends on the endpoint as given below.
+	 * 
+	 * RMS (sending side) - internalSequenceId
+	 * RMD - sequenceId
+	 */
+	private String sequencePropertyKey;
+
+	/**
+	 * Comment for <code>name</code>
+	 * The name of the property. Possible names are given in the Sandesha2Constants.SequenceProperties
interface.
+	 */
+	private String name;
+
+	/**
+	 * Comment for <code>value</code>
+	 * The value of the property.
+	 */
+	private String value;
+
+	public SequencePropertyBean(String seqID, String propertyName, String value) {
+		this.sequencePropertyKey = seqID;
+		this.name = propertyName;
+		this.value = value;
+	}
+
+	public SequencePropertyBean() {
+
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public String getSequencePropertyKey() {
+		return sequencePropertyKey;
+	}
+
+	public void setSequencePropertyKey(String sequencePropertyKey) {
+		this.sequencePropertyKey = sequencePropertyKey;
+	}
+
+	public String getValue() {
+		return value;
+	}
+
+	public void setValue(String value) {
+		this.value = value;
+	}
 }



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


Mime
View raw message