Make sure callback endpoints are created

When a component is invoked from a non bidirectional interface, inject null to the fields/setters with @Callback

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

1 files changed, 12 insertions, 0 deletions

diff --git a/sca-java-2.x/trunk/modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/EndpointReferenceBuilderImpl.java b/sca-java-2.x/trunk/modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/EndpointReferenceBuilderImpl.java
index 2dd21fe3e6..d7c345b9f1 100644
--- a/sca-java-2.x/trunk/modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/EndpointReferenceBuilderImpl.java
+++ b/sca-java-2.x/trunk/modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/EndpointReferenceBuilderImpl.java
@@ -314,6 +314,13 @@ public class EndpointReferenceBuilderImpl {
                             endpointRef.setTargetEndpoint(createEndpoint(false));
                             endpointRef.setStatus(EndpointReference.Status.RESOLVED_BINDING);
                         }
+                        
+                        if (reference.getCallbackService() != null) {
+                            Endpoint callbackEndpoint =
+                                createEndpoint(component, reference.getCallbackService(), false);
+                            endpointRef.setCallbackEndpoint(callbackEndpoint);
+                        }
+                        
                         reference.getEndpointReferences().add(endpointRef);
                         continue;
                     } // end if
@@ -345,6 +352,11 @@ public class EndpointReferenceBuilderImpl {
                     }
                     
                     endpointRef.setTargetEndpoint(endpoint);   
+                    if (reference.getCallbackService() != null) {
+                        Endpoint callbackEndpoint =
+                            createEndpoint(component, reference.getCallbackService(), false);
+                        endpointRef.setCallbackEndpoint(callbackEndpoint);
+                    }
                     reference.getEndpointReferences().add(endpointRef);
                 }
             }