1 files changed, 22 insertions, 15 deletions
diff --git a/sca-java-2.x/trunk/testing/itest/policy/interceptors/src/main/java/testpolicy/TestPolicyInterceptor.java b/sca-java-2.x/trunk/testing/itest/policy/interceptors/src/main/java/testpolicy/TestPolicyInterceptor.java
index 6600f34b66..73b4ce2825 100644
--- a/sca-java-2.x/trunk/testing/itest/policy/interceptors/src/main/java/testpolicy/TestPolicyInterceptor.java
+++ b/sca-java-2.x/trunk/testing/itest/policy/interceptors/src/main/java/testpolicy/TestPolicyInterceptor.java
@@ -18,6 +18,8 @@
  */
 package testpolicy;
 
+import helloworld.StatusImpl;
+
 import java.util.List;
 import java.util.logging.ConsoleHandler;
 import java.util.logging.Handler;
@@ -29,6 +31,7 @@ import javax.xml.namespace.QName;
 import org.apache.tuscany.sca.assembly.Component;
 import org.apache.tuscany.sca.assembly.Endpoint;
 import org.apache.tuscany.sca.assembly.EndpointReference;
+import org.apache.tuscany.sca.core.invocation.InterceptorAsyncImpl;
 import org.apache.tuscany.sca.interfacedef.Operation;
 import org.apache.tuscany.sca.invocation.Invoker;
 import org.apache.tuscany.sca.invocation.Message;
@@ -36,12 +39,8 @@ import org.apache.tuscany.sca.invocation.PhasedInterceptor;
 import org.apache.tuscany.sca.policy.PolicySubject;
 
 
-public class TestPolicyInterceptor implements PhasedInterceptor {
-    public static final String loggingPolicy = "JDKLoggingPolicy";
-    public static final QName policySetQName = new QName(TestPolicy.SCA11_TUSCANY_NS, loggingPolicy);
-    private Logger logger = null;
-
-    private Invoker next;
+public class TestPolicyInterceptor extends InterceptorAsyncImpl implements PhasedInterceptor {
+    
     private Operation operation;
     private List<TestPolicy> policies;
     private PolicySubject subject;
@@ -75,18 +74,26 @@ public class TestPolicyInterceptor implements PhasedInterceptor {
         return null;
     }
 
-    public Message invoke(Message msg) {
-        System.out.println("In interceptor at " + subject.toString());
-        return getNext().invoke(msg);
+    public Message processRequest(Message msg) {
+        StatusImpl.appendStatus("TestPolicyInterceptor.processRequest()", context + " @ " + phase);
+        return msg;
     }
-
-    public Invoker getNext() {
-        return next;
+    
+    public Message postProcessRequest(Message msg, Throwable e) throws Throwable {
+        StatusImpl.appendStatus("TestPolicyInterceptor.postProcessRequest()", context + " @ " + phase);
+        return msg;
+    } 
+    
+    public Message processResponse(Message msg) {
+        StatusImpl.appendStatus("TestPolicyInterceptor.processResponse()", context + " @ " + phase);
+        return msg;
     }
-
-    public void setNext(Invoker next) {
-        this.next = next;
+/* not in interface - should we add it?   
+    public Message postProcessResponse(Message msg) {
+        System.out.println("TestPolicyInterceptor.postProcessResponse() " + context + " @ " + phase);
+        return msg;
     }
+*/
 
     public String getPhase() {
         return phase;