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/08/30 08:40:39 UTC
svn commit: r264711 - in
/webservices/sandesha/trunk/src/org/apache/sandesha2/storage: ./
beanmanagers/ beans/
Author: chamikara
Date: Mon Aug 29 23:39:57 2005
New Revision: 264711
URL: http://svn.apache.org/viewcvs?rev=264711&view=rev
Log:
Sankas updates to storage classes.
Added:
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java
Modified:
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/InMemoryStorageMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/PermanentStorageMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManagerFactory.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CRUD.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/RetransmitterBeanMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java
webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/StorageMapBean.java
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/InMemoryStorageMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/InMemoryStorageMgr.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/InMemoryStorageMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/InMemoryStorageMgr.java Mon Aug 29 23:39:57 2005
@@ -24,6 +24,7 @@
import org.apache.sandesha2.storage.beans.CreateSeqBean;
import org.apache.sandesha2.storage.beans.NextMsgBean;
import org.apache.sandesha2.storage.beans.RetransmitterBean;
+import org.apache.sandesha2.storage.beans.SequencePropertyBean;
import org.apache.sandesha2.storage.beans.StorageMapBean;
/**
@@ -37,7 +38,8 @@
Hashtable createSeqTable = new Hashtable(),
nextMsgTable = new Hashtable(),
retransmitterBeanTable = new Hashtable(),
- storageMapBeanTable = new Hashtable();
+ storageMapBeanTable = new Hashtable(),
+ sequencePropertyBeanTable = new Hashtable();
private InMemoryStorageMgr() {
}
@@ -62,7 +64,7 @@
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#retriveCreateSeq(java.lang.String)
*/
- public CreateSeqBean retriveCreateSeq(String key) {
+ public CreateSeqBean retrieveCreateSeq(String key) {
if (createSeqTable.containsKey(key)) {
return (CreateSeqBean) createSeqTable.get(key);
} else {
@@ -100,6 +102,11 @@
storageMapBeanTable.put(bean.getKey(), bean);
return true;
}
+
+ public boolean createSequencePropertyBean(SequencePropertyBean bean) {
+ sequencePropertyBeanTable.put(bean.getSequenceId() + bean.getName(), bean);
+ return true;
+ }
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#deleteNextMsgBean(java.lang.String)
*/
@@ -121,6 +128,11 @@
storageMapBeanTable.remove(key);
return true;
}
+
+ public boolean deleteSequencePropertyBean(String key) {
+ sequencePropertyBeanTable.remove(key);
+ return true;
+ }
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#retrieveNextMsgBean(java.lang.String)
*/
@@ -140,6 +152,10 @@
public StorageMapBean retrieveStorageMapBean(String key) {
return (StorageMapBean) storageMapBeanTable.get(key);
}
+
+ public SequencePropertyBean retrieveSequencePropertyBean(String key) {
+ return (SequencePropertyBean) sequencePropertyBeanTable.get(key);
+ }
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#updateCreateSeq(org.apache.sandesha2.storage.beans.CreateSeqBean)
*/
@@ -165,5 +181,11 @@
storageMapBeanTable.put(bean.getKey(), bean);
// TODO Auto-generated method stub
return false;
+ }
+
+ public boolean updateSequencePropertyBean(SequencePropertyBean bean) {
+ sequencePropertyBeanTable.put(bean.getSequenceId(), bean);
+ return true;
+
}
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/PermanentStorageMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/PermanentStorageMgr.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/PermanentStorageMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/PermanentStorageMgr.java Mon Aug 29 23:39:57 2005
@@ -20,6 +20,7 @@
import org.apache.sandesha2.storage.beans.CreateSeqBean;
import org.apache.sandesha2.storage.beans.NextMsgBean;
import org.apache.sandesha2.storage.beans.RetransmitterBean;
+import org.apache.sandesha2.storage.beans.SequencePropertyBean;
import org.apache.sandesha2.storage.beans.StorageMapBean;
/**
@@ -41,23 +42,27 @@
}
public boolean createCreateSeq(CreateSeqBean bean) {
- return false;
+ // TODO
+ throw new UnsupportedOperationException("not yet implemented");
}
- public CreateSeqBean retriveCreateSeq(String key) {
+ public CreateSeqBean retrieveCreateSeq(String key) {
// retrieve the appropriate tuple form the table
// use that data to create and return the Bean
- return null;
+ // TODO
+ throw new UnsupportedOperationException("not yet implemented");
}
public boolean updataCreateSeq(CreateSeqBean bean) {
// update the database using the data in bean
- return false;
+ // TODO
+ throw new UnsupportedOperationException("not yet implemented");
}
public boolean deleteCreateSeq(String key) {
// delete the recored which is identified by this key..
- return false;
+ // TODO
+ throw new UnsupportedOperationException("not yet implemented");
}
@@ -66,35 +71,39 @@
*/
public boolean createNextMsg(NextMsgBean bean) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
}
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#createRetransmitterBean(org.apache.sandesha2.storage.beans.RetransmitterBean)
*/
public boolean createRetransmitterBean(RetransmitterBean bean) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
}
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#createStorageMapBean(org.apache.sandesha2.storage.beans.StorageMapBean)
*/
public boolean createStorageMapBean(StorageMapBean bean) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
+ }
+ public boolean createSequencePropertyBean(SequencePropertyBean bean) {
+ // TODO
+ throw new UnsupportedOperationException("not yet implemented");
}
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#deleteNextMsgBean(java.lang.String)
*/
public boolean deleteNextMsgBean(String key) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
}
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#deleteRetransmitterBean(java.lang.String)
*/
public boolean deleteRetransmitterBean(String key) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
}
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#deleteStorageMapBean(java.lang.String)
@@ -103,6 +112,9 @@
// TODO Auto-generated method stub
return false;
}
+ public boolean deleteSequencePropertyBean(String key) {
+ throw new UnsupportedOperationException("not yet implemented ");
+ }
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#retrieveNextMsgBean(java.lang.String)
*/
@@ -124,6 +136,10 @@
// TODO Auto-generated method stub
return null;
}
+ public SequencePropertyBean retrieveSequencePropertyBean(String key) {
+ throw new UnsupportedOperationException("not yet implemented");
+
+ }
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#updateCreateSeq(org.apache.sandesha2.storage.beans.CreateSeqBean)
*/
@@ -143,13 +159,17 @@
*/
public boolean updateRetransmitterBean(RetransmitterBean bean) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
}
/* (non-Javadoc)
* @see org.apache.sandesha2.storage.StorageManager#updateStorageMapBean(org.apache.sandesha2.storage.beans.StorageMapBean)
*/
public boolean updateStorageMapBean(StorageMapBean bean) {
// TODO Auto-generated method stub
- return false;
+ throw new UnsupportedOperationException("not yet implemented");
}
+ public boolean updateSequencePropertyBean(SequencePropertyBean bean) {
+ throw new UnsupportedOperationException("not yet implemented");
+ }
+
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManager.java Mon Aug 29 23:39:57 2005
@@ -20,6 +20,7 @@
import org.apache.sandesha2.storage.beans.CreateSeqBean;
import org.apache.sandesha2.storage.beans.NextMsgBean;
import org.apache.sandesha2.storage.beans.RetransmitterBean;
+import org.apache.sandesha2.storage.beans.SequencePropertyBean;
import org.apache.sandesha2.storage.beans.StorageMapBean;
/**
@@ -30,7 +31,7 @@
public boolean createCreateSeq(CreateSeqBean bean);
- public CreateSeqBean retriveCreateSeq(String key);
+ public CreateSeqBean retrieveCreateSeq(String key);
public boolean updateCreateSeq(CreateSeqBean bean);
@@ -60,5 +61,11 @@
public boolean deleteStorageMapBean(String key);
+ public boolean createSequencePropertyBean(SequencePropertyBean bean);
+ public SequencePropertyBean retrieveSequencePropertyBean(String key);
+
+ public boolean updateSequencePropertyBean(SequencePropertyBean bean);
+
+ public boolean deleteSequencePropertyBean(String key);
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManagerFactory.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManagerFactory.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManagerFactory.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/StorageManagerFactory.java Mon Aug 29 23:39:57 2005
@@ -23,12 +23,16 @@
*/
public class StorageManagerFactory {
- public static StorageManager getInMemoryStorageManager() {
- return InMemoryStorageMgr.getInstance();
- }
+ public static final int IN_MEMORY_STORAGE_TYPE = 1;
+ public static final int PERSISTANT_STORAGE_TYPE = 2;
- public static StorageManager getPermanentStroageManager() {
- return PermanentStorageMgr.getInstance();
+ public static StorageManager getStorageManager(int storageType) {
+ if (storageType == IN_MEMORY_STORAGE_TYPE) {
+ return InMemoryStorageMgr.getInstance();
+ } else if (storageType == PERSISTANT_STORAGE_TYPE) {
+ return PermanentStorageMgr.getInstance();
+ } else {
+ throw new IllegalArgumentException("invalid storage type");
+ }
}
-
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CRUD.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CRUD.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CRUD.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CRUD.java Mon Aug 29 23:39:57 2005
@@ -24,11 +24,13 @@
*
*/
public interface CRUD {
-
- boolean create (RMBean object);
- RMBean retrieve (String primaryKey);
- boolean update (RMBean bean);
- boolean delete (String primaryKey);
+ public static final int IN_MEMORY_STORAGE_TYPE = 1;
+ public static final int PERSISTANT_STORAGE_TYPE = 2;
+
+ public boolean create (RMBean object);
+ public RMBean retrieve (String primaryKey);
+ public boolean update (RMBean bean);
+ public boolean delete (String primaryKey);
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/CreateSeqBeanMgr.java Mon Aug 29 23:39:57 2005
@@ -17,6 +17,9 @@
package org.apache.sandesha2.storage.beanmanagers;
+import org.apache.sandesha2.storage.StorageManager;
+import org.apache.sandesha2.storage.StorageManagerFactory;
+import org.apache.sandesha2.storage.beans.CreateSeqBean;
import org.apache.sandesha2.storage.beans.RMBean;
/**
@@ -24,25 +27,29 @@
*
*/
public class CreateSeqBeanMgr implements CRUD {
-
- private CreateSeqBeanMgr instance;
- private void CreateSeqBeanMgr (){
-
+ private StorageManager storageMgr;
+
+ public CreateSeqBeanMgr(int storageType) {
+ storageMgr = StorageManagerFactory.getStorageManager(storageType);
}
- public boolean create(RMBean object) {
- return false;
+
+ public boolean create(RMBean bean) {
+ if (!(bean instanceof CreateSeqBean)) {
+ throw new IllegalArgumentException("argument should be CreateSeqBean type");
+ }
+ return storageMgr.createCreateSeq((CreateSeqBean) bean);
}
- public boolean delete(String primaryKey) {
- return false;
+ public boolean delete(String key) {
+ return storageMgr.deleteCreateSeq(key);
}
- public RMBean retrieve(String primaryKey) {
- return null;
+ public RMBean retrieve(String key) {
+ return storageMgr.retrieveCreateSeq(key);
}
public boolean update(RMBean bean) {
- return false;
+ return storageMgr.updateCreateSeq((CreateSeqBean) bean);
}
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/NextMsgBeanMgr.java Mon Aug 29 23:39:57 2005
@@ -17,6 +17,9 @@
package org.apache.sandesha2.storage.beanmanagers;
+import org.apache.sandesha2.storage.StorageManager;
+import org.apache.sandesha2.storage.StorageManagerFactory;
+import org.apache.sandesha2.storage.beans.NextMsgBean;
import org.apache.sandesha2.storage.beans.RMBean;
/**
@@ -24,20 +27,32 @@
*
*/
public class NextMsgBeanMgr implements CRUD {
+
+ private StorageManager storageMgr;
+
+ public NextMsgBeanMgr(int storageType) {
+ storageMgr = StorageManagerFactory.getStorageManager(storageType);
+ }
- public boolean create(RMBean object) {
- return false;
+ public boolean create(RMBean bean) {
+ if (!(bean instanceof NextMsgBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.createNextMsg((NextMsgBean) bean);
}
- public boolean delete(String primaryKey) {
- return false;
+ public boolean delete(String key) {
+ return storageMgr.deleteNextMsgBean(key);
}
- public RMBean retrieve(String primaryKey) {
- return null;
+ public RMBean retrieve(String key) {
+ return storageMgr.retrieveNextMsgBean(key);
}
public boolean update(RMBean bean) {
- return false;
+ if (!(bean instanceof NextMsgBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.updateNextMsgBean((NextMsgBean) bean);
}
}
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=264711&r1=264710&r2=264711&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 Mon Aug 29 23:39:57 2005
@@ -17,27 +17,41 @@
package org.apache.sandesha2.storage.beanmanagers;
+import org.apache.sandesha2.storage.StorageManager;
+import org.apache.sandesha2.storage.StorageManagerFactory;
import org.apache.sandesha2.storage.beans.RMBean;
+import org.apache.sandesha2.storage.beans.RetransmitterBean;
/**
* @author
*
*/
public class RetransmitterBeanMgr implements CRUD {
-
- public boolean create(RMBean object) {
- return false;
+
+ private StorageManager storageMgr;
+
+ public RetransmitterBeanMgr(int storageType) {
+ storageMgr = StorageManagerFactory.getStorageManager(storageType);
+ }
+ public boolean create(RMBean bean) {
+ if (!(bean instanceof RetransmitterBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.createRetransmitterBean((RetransmitterBean) bean);
}
- public boolean delete(String primaryKey) {
- return false;
+ public boolean delete(String key) {
+ return storageMgr.deleteRetransmitterBean(key);
}
- public RMBean retrieve(String primaryKey) {
- return null;
+ public RMBean retrieve(String key) {
+ return storageMgr.retrieveRetransmitterBean(key);
}
public boolean update(RMBean bean) {
- return false;
+ if (!(bean instanceof RetransmitterBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.updateRetransmitterBean((RetransmitterBean) bean);
}
}
Added: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java?rev=264711&view=auto
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java (added)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/SequencePropertyBeanMgr.java Mon Aug 29 23:39:57 2005
@@ -0,0 +1,67 @@
+/*
+ * 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.beanmanagers;
+
+import org.apache.sandesha2.storage.StorageManager;
+import org.apache.sandesha2.storage.StorageManagerFactory;
+import org.apache.sandesha2.storage.beans.RMBean;
+import org.apache.sandesha2.storage.beans.SequencePropertyBean;
+
+/**
+ * @author Sanka Samaranayake <ss...@gmail.com>
+ */
+public class SequencePropertyBeanMgr implements CRUD {
+
+ private StorageManager storageMgr;
+
+ public SequencePropertyBeanMgr(int storageType){
+ storageMgr = StorageManagerFactory.getStorageManager(storageType);
+ }
+
+ public boolean create(RMBean key) {
+ if (!(key instanceof SequencePropertyBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.createSequencePropertyBean((SequencePropertyBean) key);
+ }
+
+ /* (non-Javadoc)
+ * @see org.apache.sandesha2.storage.beanmanagers.CRUD#retrieve(java.lang.String)
+ */
+ public RMBean retrieve(String key) {
+ return storageMgr.retrieveSequencePropertyBean(key);
+ }
+
+ public RMBean retrieve(String sequenceId, String name) {
+ return retrieve(sequenceId + name);
+ }
+
+ /* (non-Javadoc)
+ * @see org.apache.sandesha2.storage.beanmanagers.CRUD#update(org.apache.sandesha2.storage.beans.RMBean)
+ */
+ public boolean update(RMBean bean) {
+ if (!(bean instanceof SequencePropertyBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.updateSequencePropertyBean((SequencePropertyBean) bean);
+ }
+
+ public boolean delete(String key) {
+ return storageMgr.deleteSequencePropertyBean(key);
+ }
+
+}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beanmanagers/StorageMapBeanMgr.java Mon Aug 29 23:39:57 2005
@@ -17,27 +17,41 @@
package org.apache.sandesha2.storage.beanmanagers;
+import org.apache.sandesha2.storage.StorageManager;
+import org.apache.sandesha2.storage.StorageManagerFactory;
import org.apache.sandesha2.storage.beans.RMBean;
+import org.apache.sandesha2.storage.beans.StorageMapBean;
/**
* @author
*
*/
public class StorageMapBeanMgr implements CRUD {
+ private StorageManager storageMgr;
+
+ public StorageMapBeanMgr(int storageType) {
+ storageMgr = StorageManagerFactory.getStorageManager(storageType);
+ }
public boolean create(RMBean object) {
- return false;
+ if (!(object instanceof StorageMapBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.createStorageMapBean((StorageMapBean) object);
}
public boolean delete(String primaryKey) {
- return false;
+ return storageMgr.deleteStorageMapBean(primaryKey);
}
-
+
public RMBean retrieve(String primaryKey) {
- return null;
+ return storageMgr.retrieveStorageMapBean(primaryKey);
}
public boolean update(RMBean bean) {
- return false;
+ if (!(bean instanceof StorageMapBean)) {
+ throw new IllegalArgumentException();
+ }
+ return storageMgr.updateStorageMapBean((StorageMapBean) bean);
}
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/SequencePropertyBean.java Mon Aug 29 23:39:57 2005
@@ -17,37 +17,48 @@
package org.apache.sandesha2.storage.beans;
/**
- * @author
- *
+ * @author Sanka Samaranayake <ss...@gmail.com>
*/
-
-public class SequencePropertyBean {
+public class SequencePropertyBean implements RMBean{
private String sequenceId;
private String name;
private String value;
+ /**
+ * @return Returns the name.
+ */
public String getName() {
return name;
}
-
+ /**
+ * @param name The name to set.
+ */
public void setName(String name) {
this.name = name;
}
-
+ /**
+ * @return Returns the sequenceId.
+ */
public String getSequenceId() {
return sequenceId;
}
-
+ /**
+ * @param sequenceId The sequenceId to set.
+ */
public void setSequenceId(String sequenceId) {
this.sequenceId = sequenceId;
}
-
+ /**
+ * @return Returns the value.
+ */
public String getValue() {
return value;
}
-
+ /**
+ * @param value The value to set.
+ */
public void setValue(String value) {
this.value = value;
}
Modified: webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/StorageMapBean.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/StorageMapBean.java?rev=264711&r1=264710&r2=264711&view=diff
==============================================================================
--- webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/StorageMapBean.java (original)
+++ webservices/sandesha/trunk/src/org/apache/sandesha2/storage/beans/StorageMapBean.java Mon Aug 29 23:39:57 2005
@@ -18,7 +18,7 @@
package org.apache.sandesha2.storage.beans;
/**
- * @author
+ * @author
*
*/
public class StorageMapBean implements RMBean {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org