QPID-2742: Gather exchange type name properly, and remove the extraneous statement execution and move its closure after use use the output ResultSet.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@964829 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 3 deletions

diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
index ae4f6f3796..62f2d14e09 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
@@ -618,17 +618,17 @@ public class DerbyMessageStore implements MessageStore
 
                     PreparedStatement stmt = conn.prepareStatement(FIND_EXCHANGE);
                     stmt.setString(1, exchange.getNameShortString().toString());
-                    stmt.execute();
-                    stmt.close();
 
                     ResultSet rs = stmt.executeQuery();
 
                     // If we don't have any data in the result set then we can add this exchange
                     if (!rs.next())
                     {
+                        stmt.close();
+                        
                         stmt = conn.prepareStatement(INSERT_INTO_EXCHANGE);
                         stmt.setString(1, exchange.getName().toString());
-                        stmt.setString(2, exchange.getType().toString());
+                        stmt.setString(2, exchange.getTypeShortString().asString());
                         stmt.setShort(3, exchange.isAutoDelete() ? (short) 1 : (short) 0);
                         stmt.execute();
                         stmt.close();