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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
