diff options
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java index ae4f6f3796..62f2d14e09 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java +++ b/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(); |