You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2008/02/18 14:42:28 UTC
svn commit: r628736 -
/incubator/qpid/branches/thegreatmerge/qpid/java/broker/src/main/java/org/apache/qpid/server/messageStore/JDBCStore.java
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;
}
};
}