You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2011/08/31 00:00:32 UTC
svn commit: r1163427 -
/incubator/airavata/trunk/modules/ws-messenger/messagebox/src/main/org/apache/airavata/wsmg/msgbox/Storage/dbpool/MessageBoxDB.java
Author: lahiru
Date: Tue Aug 30 22:00:32 2011
New Revision: 1163427
URL: http://svn.apache.org/viewvc?rev=1163427&view=rev
Log:
Fixing message delivery order to queue mode. Messages will be delivered like a queue.
Modified:
incubator/airavata/trunk/modules/ws-messenger/messagebox/src/main/org/apache/airavata/wsmg/msgbox/Storage/dbpool/MessageBoxDB.java
Modified: incubator/airavata/trunk/modules/ws-messenger/messagebox/src/main/org/apache/airavata/wsmg/msgbox/Storage/dbpool/MessageBoxDB.java
URL: http://svn.apache.org/viewvc/incubator/airavata/trunk/modules/ws-messenger/messagebox/src/main/org/apache/airavata/wsmg/msgbox/Storage/dbpool/MessageBoxDB.java?rev=1163427&r1=1163426&r2=1163427&view=diff
==============================================================================
--- incubator/airavata/trunk/modules/ws-messenger/messagebox/src/main/org/apache/airavata/wsmg/msgbox/Storage/dbpool/MessageBoxDB.java (original)
+++ incubator/airavata/trunk/modules/ws-messenger/messagebox/src/main/org/apache/airavata/wsmg/msgbox/Storage/dbpool/MessageBoxDB.java Tue Aug 30 22:00:32 2011
@@ -64,7 +64,7 @@ public class MessageBoxDB {
public static String SQL_DELETE_ALL_STATEMENT = "DELETE FROM %s WHERE msgboxid='%s'";
- public static String SQL_SELECT_STATEMENT1 = "SELECT * FROM %s WHERE msgboxid='%s' ORDER BY '%s' DESC";
+ public static String SQL_SELECT_STATEMENT1 = "SELECT * FROM %s WHERE msgboxid='%s' ORDER BY time ";
public static String SQL_DELETE_ANCIENT_STATEMENT = "DELETE FROM %s WHERE time <'%s'";
@@ -128,7 +128,7 @@ public class MessageBoxDB {
Connection connection = db.connect();
PreparedStatement stmt = connection.prepareStatement(String.format(SQL_SELECT_STATEMENT1, "msgbox",
- msgBoxId, String.format("%s.%s", "msgbox", "id")));
+ msgBoxId));
ResultSet resultSet = stmt.executeQuery();
// resultSet.beforeFirst();