svn commit: r728193 - in /ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test: InsertObjectTest.java SelectObjectTest.java

[karthick]

Author: karthick
Date: Fri Dec 19 16:27:55 2008
New Revision: 728193

URL: http://svn.apache.org/viewvc?rev=728193&view=rev
Log:
Rename the correlation keys class.

Modified:
    
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/InsertObjectTest.java
    
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java

Modified: 
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/InsertObjectTest.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/InsertObjectTest.java?rev=728193&r1=728192&r2=728193&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/InsertObjectTest.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/InsertObjectTest.java
 Fri Dec 19 16:27:55 2008
@@ -21,7 +21,7 @@
 
 import junit.framework.TestCase;
 import org.apache.ode.bpel.common.CorrelationKey;
-import org.apache.ode.bpel.common.CorrelationKeySet;
+import org.apache.ode.bpel.common.CorrelationKeys;
 import org.apache.ode.bpel.dao.BpelDAOConnection;
 import org.apache.ode.bpel.dao.CorrelationSetDAO;
 import org.apache.ode.bpel.dao.CorrelatorDAO;
@@ -184,8 +184,8 @@
                
                MessageExchangeDAO mex = createMessageExchange(process,pi,pl1);
                
-               corr.addRoute("testRoute", pi, 1, new 
CorrelationKeySet().add(key1), "one");
-               corr.enqueueMessage(mex, new 
CorrelationKeySet().add(corrkeys[0]).add(corrkeys[1]));
+               corr.addRoute("testRoute", pi, 1, new 
CorrelationKeys().add(key1), "one");
+               corr.enqueueMessage(mex, new 
CorrelationKeys().add(corrkeys[0]).add(corrkeys[1]));
                
                return pi;
        }

Modified: 
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java?rev=728193&r1=728192&r2=728193&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/dao-jpa-ojpa-derby/src/test/java/org/apache/ode/dao/jpa/test/SelectObjectTest.java
 Fri Dec 19 16:27:55 2008
@@ -21,7 +21,7 @@
 
 import junit.framework.TestCase;
 import org.apache.ode.bpel.common.CorrelationKey;
-import org.apache.ode.bpel.common.CorrelationKeySet;
+import org.apache.ode.bpel.common.CorrelationKeys;
 import org.apache.ode.bpel.dao.ActivityRecoveryDAO;
 import org.apache.ode.bpel.dao.BpelDAOConnection;
 import org.apache.ode.bpel.dao.CorrelationSetDAO;
@@ -107,7 +107,7 @@
                assertEquals(corr.getCorrelatorId(),CORRELATOR_ID1);
                
                // Assert the MessageRouteDAO
-               List<MessageRouteDAO> routes = corr.findRoute(new 
CorrelationKeySet().add(key1));
+               List<MessageRouteDAO> routes = corr.findRoute(new 
CorrelationKeys().add(key1));
         MessageRouteDAO route = null;
         if (routes != null && routes.size() > 0) {
             route = routes.get(0);
@@ -203,7 +203,7 @@
                        assertNotNull(ic);
                        assertEquals(ic.getCorrelatorId(),CORRELATOR_ID1);
                        // The message is dequeued but not persisted
-                       MessageExchangeDAO me = ic.dequeueMessage(new 
CorrelationKeySet().add(key1));
+                       MessageExchangeDAO me = ic.dequeueMessage(new 
CorrelationKeys().add(key1));
                        assertNotNull(me);
                        assertEquals(me.getCallee(),new 
QName(TEST_NS,"testCallee"));
                        assertEquals(me.getPropagateTransactionFlag(),false);