git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@711918 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 1 deletions

diff --git a/sandbox/event/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/JavaImplementationProvider.java b/sandbox/event/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/JavaImplementationProvider.java
index e9eea607c9..e7eb2545f3 100644
--- a/sandbox/event/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/JavaImplementationProvider.java
+++ b/sandbox/event/modules/implementation-java-runtime/src/main/java/org/apache/tuscany/sca/implementation/java/invocation/JavaImplementationProvider.java
@@ -146,7 +146,12 @@ public class JavaImplementationProvider implements ScopedImplementationProvider
 
     public Invoker createInvoker(RuntimeComponentService service, Operation operation) {
         try {
-            return componentContextProvider.createInvoker(operation);
+        	// Added separate processing for Consumers...     Mike Edwards, 06/11/2008
+        	if( service.isConsumer() ){
+        		return componentContextProvider.createInvoker(operation, service.getConsumer() );
+        	} else {
+        		return componentContextProvider.createInvoker(operation);
+        	} // end if      
         } catch (NoSuchMethodException e) {
             // It's possible that the instance being invoked is a user-specified
             // callback object that isn't an instance of the component implementation