1 files changed, 11 insertions, 1 deletions
diff --git a/sandbox/event/modules/implementation-java/src/main/java/org/apache/tuscany/sca/implementation/java/impl/JavaImplementationImpl.java b/sandbox/event/modules/implementation-java/src/main/java/org/apache/tuscany/sca/implementation/java/impl/JavaImplementationImpl.java
index 375896cf26..bb95fd78ac 100644
--- a/sandbox/event/modules/implementation-java/src/main/java/org/apache/tuscany/sca/implementation/java/impl/JavaImplementationImpl.java
+++ b/sandbox/event/modules/implementation-java/src/main/java/org/apache/tuscany/sca/implementation/java/impl/JavaImplementationImpl.java
@@ -44,6 +44,8 @@ public class JavaImplementationImpl extends BaseJavaImplementationImpl implement
     private final Map<String, JavaElementImpl> propertyMembers = new HashMap<String, JavaElementImpl>();
     private final Map<String, JavaElementImpl> referenceMembers = new HashMap<String, JavaElementImpl>();
     private final Map<String, Collection<JavaElementImpl>> callbackMembers = new HashMap<String, Collection<JavaElementImpl>>();
+    private final Map<String, Collection<JavaElementImpl>> consumerMembers = new HashMap<String, Collection<JavaElementImpl>>();
+    private final Map<String, JavaElementImpl> producerMembers = new HashMap<String, JavaElementImpl>();
     private List<Member> conversationIDMember = new ArrayList<Member>();
     private boolean eagerInit;
     private boolean allowsPassByReference;
@@ -133,7 +135,15 @@ public class JavaImplementationImpl extends BaseJavaImplementationImpl implement
         return referenceMembers;
     }
 
-    public JavaScopeImpl getJavaScope() {
+    public Map<String, Collection<JavaElementImpl>> getConsumerMembers() {
+    	return consumerMembers;
+	}
+
+	public Map<String, JavaElementImpl> getProducerMembers() {
+		return producerMembers;
+	}
+
+	public JavaScopeImpl getJavaScope() {
         return scope;
     }