You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2008/08/11 13:01:33 UTC
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/
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
{
}