diff options
Diffstat (limited to '')
10 files changed, 37 insertions, 35 deletions
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingInvoker.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingInvoker.java index f9bb195b29..1d9e28a899 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingInvoker.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingInvoker.java @@ -28,6 +28,7 @@ import echo.server.EchoServer; */ class EchoBindingInvoker implements Invoker { private String uri; + EchoBindingInvoker(String uri) { this.uri = uri; } diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingPoliciedInvoker.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingPoliciedInvoker.java index 4877bade7f..342fd6e0e7 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingPoliciedInvoker.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingPoliciedInvoker.java @@ -28,8 +28,8 @@ import org.apache.tuscany.sca.invocation.Invoker; import org.apache.tuscany.sca.invocation.Message;
import org.apache.tuscany.sca.policy.PolicySet;
-import echo.provider.policy.PolicyHandler;
import echo.provider.policy.EncryptionPolicyHandler;
+import echo.provider.policy.PolicyHandler;
/**
* Invoker that applies policies before invocation for the sample echo binding.
@@ -37,32 +37,31 @@ import echo.provider.policy.EncryptionPolicyHandler; public class EchoBindingPoliciedInvoker implements Invoker {
List<PolicySet> policies = null;
Map<QName, PolicyHandler> policyHandlers = new HashMap<QName, PolicyHandler>();
-
+
public EchoBindingPoliciedInvoker(List<PolicySet> policies) {
this.policies = policies;
- policyHandlers.put(new QName("http://test","EncryptionPolicy"),
- new EncryptionPolicyHandler());
+ policyHandlers.put(new QName("http://test", "EncryptionPolicy"), new EncryptionPolicyHandler());
}
public Message invoke(Message msg) {
try {
Object[] args = msg.getBody();
-
+
applyPolicies(args);
// echo back the first parameter, a real binding would invoke some API for flowing the request
Object result = args[0];
-
+
msg.setBody(result);
-
+
} catch (Exception e) {
msg.setFaultBody(e);
}
return msg;
- }
-
+ }
+
private void applyPolicies(Object[] args) throws Exception {
- for ( PolicySet policySet : policies ) {
+ for (PolicySet policySet : policies) {
PolicyHandler policyHandler = policyHandlers.get(policySet.getName());
policyHandler.applyPolicy(args, policySet);
}
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingProviderFactory.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingProviderFactory.java index ba74d8f99a..adbc436950 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingProviderFactory.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoBindingProviderFactory.java @@ -31,27 +31,30 @@ import org.apache.tuscany.sca.runtime.RuntimeComponentService; import echo.EchoBinding; - /** * Implementation of the Echo binding model. */ public class EchoBindingProviderFactory implements BindingProviderFactory<EchoBinding> { - + private MessageFactory messageFactory; - + public EchoBindingProviderFactory(ExtensionPointRegistry extensionPoints) { ModelFactoryExtensionPoint factories = extensionPoints.getExtensionPoint(ModelFactoryExtensionPoint.class); this.messageFactory = factories.getFactory(MessageFactory.class); } - public ReferenceBindingProvider createReferenceBindingProvider(RuntimeComponent component, RuntimeComponentReference reference, EchoBinding binding) { + public ReferenceBindingProvider createReferenceBindingProvider(RuntimeComponent component, + RuntimeComponentReference reference, + EchoBinding binding) { return new EchoReferenceBindingProvider(component, reference, binding); } - public ServiceBindingProvider createServiceBindingProvider(RuntimeComponent component, RuntimeComponentService service, EchoBinding binding) { + public ServiceBindingProvider createServiceBindingProvider(RuntimeComponent component, + RuntimeComponentService service, + EchoBinding binding) { return new EchoServiceBindingProvider(component, service, binding, messageFactory); } - + public Class<EchoBinding> getModelType() { return EchoBinding.class; } diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoReferenceBindingProvider.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoReferenceBindingProvider.java index dbd0c535f4..3178c50a2a 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoReferenceBindingProvider.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/EchoReferenceBindingProvider.java @@ -37,9 +37,7 @@ class EchoReferenceBindingProvider implements ReferenceBindingProvider { private RuntimeComponentReference reference; private EchoBinding binding; - EchoReferenceBindingProvider(RuntimeComponent component, - RuntimeComponentReference reference, - EchoBinding binding) { + EchoReferenceBindingProvider(RuntimeComponent component, RuntimeComponentReference reference, EchoBinding binding) { this.reference = reference; this.binding = binding; } @@ -47,7 +45,7 @@ class EchoReferenceBindingProvider implements ReferenceBindingProvider { public Invoker createInvoker(Operation operation) { if (binding instanceof PolicySetAttachPoint) { PolicySetAttachPoint policySetAttachPoint = (PolicySetAttachPoint)binding; - if ( !policySetAttachPoint.getPolicySets().isEmpty() ){ + if (!policySetAttachPoint.getPolicySets().isEmpty()) { return new EchoBindingPoliciedInvoker(policySetAttachPoint.getPolicySets()); } } diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicy.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicy.java index 33dc761aa4..c1f1269db6 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicy.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicy.java @@ -24,16 +24,19 @@ public class EchoBindingEncryptionPolicy extends EchoBindingPolicy { private String encryptionStrategyClassName;
private Class<? extends EncryptionStrategy> strategyClass;
-
+
public String getEncryptionStrategyClassName() {
return encryptionStrategyClassName;
}
+
public void setEncryptionStrategyClassName(String encryptionStrategyClassName) {
this.encryptionStrategyClassName = encryptionStrategyClassName;
}
+
public Class<? extends EncryptionStrategy> getStrategyClass() {
return strategyClass;
}
+
public void setStrategyClass(Class<? extends EncryptionStrategy> strategy) {
this.strategyClass = strategy;
}
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicyProcessor.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicyProcessor.java index c847d088a6..da47bbfac3 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicyProcessor.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingEncryptionPolicyProcessor.java @@ -21,7 +21,6 @@ package echo.provider.policy; import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
import org.apache.tuscany.sca.monitor.Monitor;
-
/**
*
*/
@@ -29,9 +28,9 @@ public class EchoBindingEncryptionPolicyProcessor extends EchoBindingPolicyProce public EchoBindingEncryptionPolicyProcessor(ModelFactoryExtensionPoint modelFactories, Monitor monitor) {
}
-
+
public Class<EchoBindingEncryptionPolicy> getModelType() {
return EchoBindingEncryptionPolicy.class;
}
-
+
}
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingPolicy.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingPolicy.java index 7d38e3b7a8..0dab68075d 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingPolicy.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EchoBindingPolicy.java @@ -27,9 +27,9 @@ import org.apache.tuscany.sca.policy.Policy; */
public class EchoBindingPolicy implements Policy {
private boolean unresolved = true;
-
+
public QName getSchemaName() {
- return new QName("http://sample/policy","echoBindingPolicy");
+ return new QName("http://sample/policy", "echoBindingPolicy");
}
public boolean isUnresolved() {
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EncryptionPolicyHandler.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EncryptionPolicyHandler.java index deda8d9744..cf98b3830f 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EncryptionPolicyHandler.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/EncryptionPolicyHandler.java @@ -18,7 +18,6 @@ */
package echo.provider.policy;
-import org.apache.tuscany.sca.policy.Policy;
import org.apache.tuscany.sca.policy.PolicySet;
/**
@@ -27,18 +26,18 @@ import org.apache.tuscany.sca.policy.PolicySet; public class EncryptionPolicyHandler implements PolicyHandler {
public void applyPolicy(Object msg, PolicySet policySet) throws Exception {
- for ( Object aPolicy : policySet.getPolicies() ) {
- if ( aPolicy instanceof EchoBindingEncryptionPolicy ) {
- encrypt(msg, (EchoBindingEncryptionPolicy)aPolicy);
+ for (Object aPolicy : policySet.getPolicies()) {
+ if (aPolicy instanceof EchoBindingEncryptionPolicy) {
+ encrypt(msg, (EchoBindingEncryptionPolicy)aPolicy);
}
}
}
-
+
private void encrypt(Object msg, EchoBindingEncryptionPolicy policy) throws Exception {
- if ( !policy.isUnresolved() && msg instanceof Object[] ) {
+ if (!policy.isUnresolved() && msg instanceof Object[]) {
EncryptionStrategy strategy = policy.getStrategyClass().newInstance();
Object[] msgArgs = (Object[])msg;
- for ( int count = 0 ; count < msgArgs.length ; ++count ) {
+ for (int count = 0; count < msgArgs.length; ++count) {
msgArgs[count] = strategy.encryptMessage(msgArgs[count]);
}
}
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/ReverseEncryptionStrategy.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/ReverseEncryptionStrategy.java index cf55b36fc2..3220102926 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/ReverseEncryptionStrategy.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/ReverseEncryptionStrategy.java @@ -23,7 +23,7 @@ package echo.provider.policy; public class ReverseEncryptionStrategy implements EncryptionStrategy {
public Object encryptMessage(Object msg) {
- if ( msg instanceof String ) {
+ if (msg instanceof String) {
StringBuffer sb = new StringBuffer((String)msg);
msg = sb.reverse().toString();
}
diff --git a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/WSPolicy.java b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/WSPolicy.java index ac610cfb51..598683c251 100644 --- a/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/WSPolicy.java +++ b/branches/sca-java-1.x/samples/binding-echo-extension/src/main/java/echo/provider/policy/WSPolicy.java @@ -27,7 +27,7 @@ import org.apache.tuscany.sca.policy.Policy; */
public class WSPolicy implements Policy {
private boolean unresolved = true;
-
+
public QName getSchemaName() {
return new QName("http://schemas.xmlsoap.org/ws/2004/09/policy", "PolicyAttachment");
}
|