[infinispan-commits] Infinispan SVN: r836 - branches/ISPN-32/query/src/main/java/org/infinispan/query/backend.

[infinispan-commits at lists.jboss.org]

Author: navssurtani
Date: 2009-09-18 08:41:14 -0400 (Fri, 18 Sep 2009)
New Revision: 836

Modified:
   branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/LocalQueryInterceptor.java
   branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/QueryInterceptor.java
Log:
[ISPN - 32] New API works. Scheduled for refactoring back into trunk for 21st Sept

Modified: branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/LocalQueryInterceptor.java
===================================================================
--- branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/LocalQueryInterceptor.java	2009-09-18 11:10:19 UTC (rev 835)
+++ branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/LocalQueryInterceptor.java	2009-09-18 12:41:14 UTC (rev 836)
@@ -29,14 +29,14 @@
    // TODO:  navssurtani --> check to make sure that these fields will be assigned properly on superclass method so that they can be used correctly when needed.
 
    
-   private SearchFactoryImplementor searchFactory;
-   private TransactionManager transactionManager;
 
    @Inject
    public void init(SearchFactoryImplementor searchFactory, TransactionManager transactionManager) {
 
       log.debug("Entered LocalQueryInterceptor.init()");
 
+      // Fields on superclass.
+
       this.searchFactory = searchFactory;
       this.transactionManager = transactionManager;
    }
@@ -56,6 +56,7 @@
       // context is local.
 
       if (ctx.isOriginLocal()) {
+         log.debug("Origin is local");
          addToIndexes(command.getValue(), command.getKey().toString());
       }
 
@@ -73,6 +74,7 @@
       // Check to make sure that the context is local as well as successful.
 
       if (command.isSuccessful() && ctx.isOriginLocal()) {
+         log.debug("Origin is local");
          removeFromIndexes(valueRemoved, command.getKey().toString());
       }
 
@@ -91,6 +93,7 @@
 
       if (valueReplaced != null && ctx.isOriginLocal()) {
 
+         log.debug("Origin is local");
          Object[] parameters = command.getParameters();
          String keyString = command.getKey().toString();
 
@@ -112,6 +115,7 @@
 
       if (ctx.isOriginLocal()) {
 
+         log.debug("Origin is local");
          Map<Object, Object> dataMap = command.getMap();
 
          // Loop through all the keys and put those key, value pairings into lucene.

Modified: branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/QueryInterceptor.java
===================================================================
--- branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/QueryInterceptor.java	2009-09-18 11:10:19 UTC (rev 835)
+++ branches/ISPN-32/query/src/main/java/org/infinispan/query/backend/QueryInterceptor.java	2009-09-18 12:41:14 UTC (rev 836)
@@ -24,8 +24,8 @@
 
 public class QueryInterceptor extends CommandInterceptor {
 
-   private SearchFactoryImplementor searchFactory;
-   private TransactionManager transactionManager;
+   protected SearchFactoryImplementor searchFactory;
+   protected TransactionManager transactionManager;
 
    @Inject
    public void init(SearchFactoryImplementor searchFactory, TransactionManager transactionManager) {