svn commit: r743875 - /ode/trunk/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/EXTENSIONACTIVITY.java

[vanto]

Author: vanto
Date: Thu Feb 12 20:43:32 2009
New Revision: 743875

URL: http://svn.apache.org/viewvc?rev=743875&view=rev
Log:
small fix (I could swear that I fixed it already...)

Modified:
    
ode/trunk/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/EXTENSIONACTIVITY.java

Modified: 
ode/trunk/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/EXTENSIONACTIVITY.java
URL: 
http://svn.apache.org/viewvc/ode/trunk/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/EXTENSIONACTIVITY.java?rev=743875&r1=743874&r2=743875&view=diff
==============================================================================
--- 
ode/trunk/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/EXTENSIONACTIVITY.java
 (original)
+++ 
ode/trunk/runtimes/src/main/java/org/apache/ode/bpel/rtrep/v2/EXTENSIONACTIVITY.java
 Thu Feb 12 20:43:32 2009
@@ -35,39 +35,40 @@
  * @author Tammo van Lessen (University of Stuttgart)
  */
 public class EXTENSIONACTIVITY extends ACTIVITY {
-       private static final long serialVersionUID = 1L;
-       private static final Log __log = 
LogFactory.getLog(EXTENSIONACTIVITY.class);
+    private static final long serialVersionUID = 1L;
+    private static final Log __log = 
LogFactory.getLog(EXTENSIONACTIVITY.class);
 
     private OExtensionActivity _oext;
     
-       public EXTENSIONACTIVITY(ActivityInfo self, ScopeFrame scopeFrame,
-                       LinkFrame linkFrame) {
+    public EXTENSIONACTIVITY(ActivityInfo self, ScopeFrame scopeFrame,
+            LinkFrame linkFrame) {
         super(self, scopeFrame, linkFrame);
         _oext = (OExtensionActivity) _self.o;
-       }
+    }
 
     public final void run() {
-       final ExtensionContext context = new ExtensionContextImpl(_self, 
_scopeFrame, getBpelRuntime());
-       final QName extensionId = 
DOMUtils.getElementQName(_oext.nestedElement.getElement());
-       try {
-               ExtensionOperation ea = 
getBpelRuntime().createExtensionActivityImplementation(extensionId);
-               if (ea == null) {
-                       if 
(_oext.getOwner().mustUnderstandExtensions.contains(extensionId.getNamespaceURI()))
 {
-                               __log.warn("Lookup of extension activity " + 
extensionId + " failed.");
-                               throw new 
FaultException(ExtensibilityQNames.UNKNOWN_EA_FAULT_NAME,
-                            "Lookup of extension activity " + extensionId + " 
failed. No implementation found.");
-                       } else {
-                               // act like <empty> - do nothing
-                               context.complete();
-                               return;
-                       }
-               }
+        final ExtensionContext context = new ExtensionContextImpl(_self, 
_scopeFrame, getBpelRuntime());
+        final QName extensionId = 
DOMUtils.getElementQName(_oext.nestedElement.getElement());
+        try {
+            ExtensionOperation ea = 
getBpelRuntime().createExtensionActivityImplementation(extensionId);
+            if (ea == null) {
+                for (OProcess.OExtension oe : 
_oext.getOwner().mustUnderstandExtensions) {
+                    if (extensionId.getNamespaceURI().equals(oe.namespaceURI)) 
{
+                        __log.warn("Lookup of extension activity " + 
extensionId + " failed.");
+                        throw new 
FaultException(ExtensibilityQNames.UNKNOWN_EA_FAULT_NAME, "Lookup of extension 
activity " 
+                                + extensionId + " failed. No implementation 
found.");
+                    }
+                }
+                // act like <empty> - do nothing
+                context.complete();
+                return;
+            }
 
-               ea.run(context, _oext.nestedElement.getElement());
-               } catch (FaultException fault) {
+            ea.run(context, _oext.nestedElement.getElement());
+        } catch (FaultException fault) {
             __log.error(fault);
             context.completeWithFault(fault);
-               }
+        }
 
     }