Author: lresende
Date: Tue Feb 23 07:03:26 2010
New Revision: 915211
URL: http://svn.apache.org/viewvc?rev=915211&view=rev
Log:
Providing phase value for the interceptor
Modified:
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionImplementationPolicyProvider.java
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionInterceptor.java
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionReferencePolicyProvider.java
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionServicePolicyProvider.java
Modified:
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionImplementationPolicyProvider.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionImplementationPolicyProvider.java?rev=915211&r1=915210&r2=915211&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionImplementationPolicyProvider.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionImplementationPolicyProvider.java
Tue Feb 23 07:03:26 2010
@@ -49,7 +49,7 @@
for (Object p : policySet.getPolicies()) {
if (p instanceof TransactionPolicy) {
TransactionInterceptor interceptor =
- new TransactionInterceptor(helper, false,
(TransactionPolicy)p, null);
+ new TransactionInterceptor(helper, false,
(TransactionPolicy)p, null, getPhase());
return interceptor;
}
}
Modified:
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionInterceptor.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionInterceptor.java?rev=915211&r1=915210&r2=915211&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionInterceptor.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionInterceptor.java
Tue Feb 23 07:03:26 2010
@@ -19,7 +19,8 @@
package org.apache.tuscany.sca.policy.transaction.runtime;
-import org.apache.tuscany.sca.invocation.Interceptor;
+import java.util.logging.Logger;
+
import org.apache.tuscany.sca.invocation.Invoker;
import org.apache.tuscany.sca.invocation.Message;
import org.apache.tuscany.sca.invocation.PhasedInterceptor;
@@ -29,16 +30,20 @@
* @version $Rev$ $Date$
*/
public class TransactionInterceptor implements PhasedInterceptor {
+ private static final Logger logger =
Logger.getLogger(TransactionInterceptor.class.getName());
+
private Invoker next;
private TransactionManagerHelper helper;
private boolean outbound;
private TransactionPolicy interactionPolicy;
private TransactionPolicy implementationPolicy;
+ private String phase;
public TransactionInterceptor(TransactionManagerHelper helper,
boolean outbound,
TransactionPolicy interactionPolicy,
- TransactionPolicy implementationPolicy) {
+ TransactionPolicy implementationPolicy,
+ String phase) {
super();
this.helper = helper;
this.outbound = outbound;
@@ -64,6 +69,7 @@
* @see
org.apache.tuscany.sca.invocation.Invoker#invoke(org.apache.tuscany.sca.invocation.Message)
*/
public Message invoke(Message msg) {
+ //logger.info("Executing TransactionInterceptor.invoke");
TransactionalInvocation invocation = new TransactionalInvocation(next,
msg);
Message result = null;
@@ -122,8 +128,7 @@
}
public String getPhase() {
- // TODO Auto-generated method stub
- return null;
+ return phase;
}
}
Modified:
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionReferencePolicyProvider.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionReferencePolicyProvider.java?rev=915211&r1=915210&r2=915211&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionReferencePolicyProvider.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionReferencePolicyProvider.java
Tue Feb 23 07:03:26 2010
@@ -48,7 +48,7 @@
for (Object p : policySet.getPolicies()) {
if (p instanceof TransactionPolicy) {
TransactionInterceptor interceptor =
- new TransactionInterceptor(helper, true,
(TransactionPolicy)p, null);
+ new TransactionInterceptor(helper, true,
(TransactionPolicy)p, null,getPhase());
return interceptor;
}
}
Modified:
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionServicePolicyProvider.java
URL:
http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionServicePolicyProvider.java?rev=915211&r1=915210&r2=915211&view=diff
==============================================================================
---
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionServicePolicyProvider.java
(original)
+++
tuscany/sca-java-2.x/trunk/modules/policy-transaction/src/main/java/org/apache/tuscany/sca/policy/transaction/runtime/TransactionServicePolicyProvider.java
Tue Feb 23 07:03:26 2010
@@ -47,7 +47,7 @@
for (Object p : policySet.getPolicies()) {
if (p instanceof TransactionPolicy) {
TransactionInterceptor interceptor =
- new TransactionInterceptor(helper, true,
(TransactionPolicy)p, null);
+ new TransactionInterceptor(helper, true,
(TransactionPolicy)p, null, getPhase());
return interceptor;
}
}
