add setExchange method

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/thegreatmerge@628736 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 11 insertions, 5 deletions

diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
index 6fcdf8de3a..c2d17e51fb 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
@@ -1259,15 +1259,16 @@ public class JDBCStore implements MessageStore
                 connection.getStatements()[GET_MESSAGE_INFO] = pstmt;
             }
             pstmt.setLong(1, m.getMessageId());
-            ResultSet rs = pstmt.executeQuery();
+            final ResultSet rs = pstmt.executeQuery();
             if (rs.next())
             {
-                final AMQShortString exchange = new AMQShortString(rs.getString(1));
-                final AMQShortString routingKey = new AMQShortString(rs.getString(2));
-                final boolean mandatory = rs.getBoolean(3);
-                final boolean immediate = rs.getBoolean(4);
+                
                 result = new MessagePublishInfo()
                 {
+                    AMQShortString exchange = new AMQShortString(rs.getString(1));
+                    final AMQShortString routingKey = new AMQShortString(rs.getString(2));
+                    final boolean mandatory = rs.getBoolean(3);
+                    final boolean immediate = rs.getBoolean(4);
 
                     public AMQShortString getExchange()
                     {
@@ -1288,6 +1289,11 @@ public class JDBCStore implements MessageStore
                     {
                         return routingKey;
                     }
+
+                    public void setExchange(AMQShortString ex) 
+                    {
+                        exchange = ex;
+                    }
                 };
             }
             else