Author: chirino
Date: Fri Feb 10 13:11:33 2006
New Revision: 376856
URL: http://svn.apache.org/viewcvs?rev=376856&view=rev
Log:
Fixing broker DurableConsumerCloseAndReconnectTest, subscriptions were not
being added to the result array.
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java?rev=376856&r1=376855&r2=376856&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java
Fri Feb 10 13:11:33 2006
@@ -499,6 +499,7 @@
subscription.setSelector(rs.getString(1));
subscription.setSubcriptionName(rs.getString(2));
subscription.setClientId(rs.getString(3));
+ rc.add(subscription);
}
return (SubscriptionInfo[]) rc.toArray(new
SubscriptionInfo[rc.size()]);
@@ -616,6 +617,11 @@
s.setString(2,clientId);
s.setString(3,subscriptionName);
printQuery(s,System.out);
+ }
+
+ public void dumpTables(Connection c) throws SQLException {
+ printQuery(c, "Select * from ACTIVEMQ_MSGS", System.out);
+ printQuery(c, "Select * from ACTIVEMQ_ACKS", System.out);
}
private void printQuery(Connection c, String query, PrintStream out)
throws SQLException {
