Author: heiko.braun(a)jboss.com Date: 2009-10-12 06:20:43 -0400 (Mon, 12 Oct 2009) New Revision: 168 Modified: branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionImpl.java branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java Log: Rollback changes wrt MEXID Modified: branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionImpl.java =================================================================== --- branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionImpl.java 2009-10-12 10:01:51 UTC (rev 167) +++ branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/BpelDAOConnectionImpl.java 2009-10-12 10:20:43 UTC (rev 168) @@ -97,10 +97,8 @@ } public MessageExchangeDAO getMessageExchange(String mexid) { - org.hibernate.Query query = getSession().createQuery("from HMessageExchange x where x.mexId = ?"); - query.setString(0, mexid); - HMessageExchange mex = (HMessageExchange) query.uniqueResult(); - return mex == null ? null : new MessageExchangeDaoImpl(_sm, mex); + HMessageExchange mex = (HMessageExchange) getSession().get(HMessageExchange.class, new Long(mexid)); + return mex == null ? null : new MessageExchangeDaoImpl(_sm, mex); } public ProcessDAO createProcess(QName pid, QName type, String guid, long version) { Modified: branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java =================================================================== --- branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java 2009-10-12 10:01:51 UTC (rev 167) +++ branches/ODE/ODE-1.x-fixes/dao-hibernate/src/main/java/org/apache/ode/daohib/bpel/MessageExchangeDaoImpl.java 2009-10-12 10:20:43 UTC (rev 168) @@ -60,7 +60,7 @@ } public String getMessageExchangeId() { - return _hself.getMexId(); + return _hself.getId().toString(); } public MessageDAO getResponse() {