[jboss-svn-commits] JBL Code SVN: r6835 - labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence

[jboss-svn-commits at lists.jboss.org]

Author: daniel.brum at jboss.com
Date: 2006-10-16 17:14:40 -0400 (Mon, 16 Oct 2006)
New Revision: 6835

Added:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStore.java
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStoreFactory.java
Log:


Added: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStore.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStore.java	2006-10-16 21:14:38 UTC (rev 6834)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStore.java	2006-10-16 21:14:40 UTC (rev 6835)
@@ -0,0 +1,35 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and others contributors as indicated 
+ * by the @authors tag. All rights reserved. 
+ * See the copyright.txt in the distribution for a
+ * full listing of individual contributors. 
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU Lesser General Public License, v. 2.1.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A 
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A 
+ * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License,
+ * v.2.1 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 
+ * MA  02110-1301, USA.
+ * 
+ * (C) 2005-2006,
+ * @author daniel.brum at jboss.com
+ */
+
+package org.jboss.soa.esb.persistence;
+
+import org.jboss.soa.esb.message.Message;
+
+
+
+public interface MessageStore {
+	
+	public String addMessage(Message message);
+	public Message getMessage(String uid) throws Exception;
+//	public void replaceMessage(Message message);
+//	public void removeMessage(long uid);
+
+}

Added: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStoreFactory.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStoreFactory.java	2006-10-16 21:14:38 UTC (rev 6834)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/persistence/MessageStoreFactory.java	2006-10-16 21:14:40 UTC (rev 6835)
@@ -0,0 +1,67 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and others contributors as indicated 
+ * by the @authors tag. All rights reserved. 
+ * See the copyright.txt in the distribution for a
+ * full listing of individual contributors. 
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU Lesser General Public License, v. 2.1.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A 
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A 
+ * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License,
+ * v.2.1 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 
+ * MA  02110-1301, USA.
+ * 
+ * (C) 2005-2006,
+ * @author daniel.brum at jboss.com
+ */
+
+
+/**
+ * You get a MessageStore of a specific type when you need it. 
+  */
+
+
+package org.jboss.soa.esb.persistence;
+
+import java.net.URI;
+
+import org.jboss.internal.soa.esb.persistence.format.MessageStoreFactoryImpl;
+
+
+public abstract class MessageStoreFactory {
+	
+	private static final MessageStoreFactory theFactory = new MessageStoreFactoryImpl();
+	
+	/**
+	 * @return a default implementation.
+	 */
+	
+	public abstract MessageStore getMessageStore ();
+	
+	/**
+	 * @param type the unique identifier representing the type of this MessageStore.
+	 * @return the MessageStore, or <code>null</code> if no suitable store is available.
+	 */
+	
+	public abstract MessageStore getMessageStore (URI type);
+	
+	
+	public static MessageStoreFactory getInstance ()
+	{
+		return theFactory;
+	}
+	
+	/**
+	 * Reload the plugins.
+	 */
+	
+	public abstract void reset ();
+	
+	
+	
+
+}