qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ai...@apache.org
Subject svn commit: r628736 - /incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
Date Mon, 18 Feb 2008 13:42:28 GMT
Author: aidan
Date: Mon Feb 18 05:42:26 2008
New Revision: 628736

URL: http://svn.apache.org/viewvc?rev=628736&view=rev
Log:
add setExchange method

Modified:
    incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java

Modified: incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java?rev=628736&r1=628735&r2=628736&view=diff
==============================================================================
--- incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
(original)
+++ incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
Mon Feb 18 05:42:26 2008
@@ -1259,15 +1259,16 @@
                 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()
                     {
@@ -1287,6 +1288,11 @@
                     public AMQShortString getRoutingKey()
                     {
                         return routingKey;
+                    }
+
+                    public void setExchange(AMQShortString ex) 
+                    {
+                        exchange = ex;
                     }
                 };
             }



Mime
View raw message