svn commit: r684710 - in /incubator/qpid/trunk/qpid/java: broker/src/main/java/org/apache/qpid/server/store/ systests/src/main/java/org/apache/qpid/server/store/

[ritchiem]

Author: ritchiem
Date: Mon Aug 11 04:01:28 2008
New Revision: 684710

URL: http://svn.apache.org/viewvc?rev=684710&view=rev
Log:
QPID-1193 : re-added createQueue(AMQQueue queue) method, after code review call.

Modified:
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
    
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java
    
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java?rev=684710&r1=684709&r2=684710&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
 Mon Aug 11 04:01:28 2008
@@ -728,6 +728,11 @@
 
     }
 
+    public void createQueue(AMQQueue queue) throws AMQException
+    {
+        createQueue(queue, null);
+    }
+
     public void createQueue(AMQQueue queue, FieldTable arguments) throws 
AMQException
     {
         _logger.debug("public void createQueue(AMQQueue queue = " + queue + 
"): called");

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java?rev=684710&r1=684709&r2=684710&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
 Mon Aug 11 04:01:28 2008
@@ -121,6 +121,12 @@
 
     }
 
+
+    public void createQueue(AMQQueue queue) throws AMQException
+    {
+        // Not requred to do anything
+    }
+
     public void createQueue(AMQQueue queue, FieldTable arguments) throws 
AMQException
     {
         // Not required to do anything

Modified: 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java?rev=684710&r1=684709&r2=684710&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java
 Mon Aug 11 04:01:28 2008
@@ -131,6 +131,15 @@
      *
      * @param queue The queue to store.
      *
+     * @throws AMQException If the operation fails for any reason.
+     */
+    void createQueue(AMQQueue queue) throws AMQException;
+
+    /**
+     * Makes the specified queue persistent.
+     *
+     * @param queue The queue to store.
+     *
      * @param arguments The additional arguments to the binding
      * @throws AMQException If the operation fails for any reason.
      */

Modified: 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java?rev=684710&r1=684709&r2=684710&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java
 Mon Aug 11 04:01:28 2008
@@ -78,6 +78,10 @@
         //To change body of implemented methods use File | Settings | File 
Templates.
     }
 
+    public void createQueue(AMQQueue queue) throws AMQException
+    {
+    }
+
     public void createQueue(AMQQueue queue, FieldTable arguments) throws 
AMQException
     {
     }