fixed usage of internal requester API

ddossot · Dec 28, 2009 · ed177ed · ed177ed
1 parent 96237b8
commit ed177ed
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/chapter13/mule-event-context/src/main/java/com/clood/component/Md5FileHasher.java b/chapter13/mule-event-context/src/main/java/com/clood/component/Md5FileHasher.java
@@ -3,6 +3,7 @@
 import org.apache.commons.codec.digest.DigestUtils;
 import org.mule.api.MuleEventContext;
 import org.mule.api.MuleMessage;
+import org.mule.api.endpoint.InboundEndpoint;
 import org.mule.api.lifecycle.Callable;
 import org.mule.transport.file.FileConnector;
 
@@ -27,10 +28,13 @@ public void setFileConnector(final FileConnector fileConnector) {
     public Object onCall(final MuleEventContext eventContext) throws Exception {
 
         final String fileName = eventContext.getMessageAsString();
-
-        final MuleMessage requestedFileMessage = eventContext.requestEvent(
-                "file://" + sourceFolder + "/" + fileName + "?connector="
-                        + fileConnectorName, 0);
+        final String endpointUri = "file://" + sourceFolder + "/"
+            + fileName + "?connector=" + fileConnectorName;
+
+        final InboundEndpoint endpoint = eventContext.getMuleContext()
+                .getRegistry().lookupEndpointFactory().getInboundEndpoint(endpointUri);
+
+        final MuleMessage requestedFileMessage = eventContext.requestEvent(endpoint, 0);
 
         eventContext.setStopFurtherProcessing(true);
 

diff --git a/chapter13/mule-event-context/src/test/resources/conf/md5fh-config.xml b/chapter13/mule-event-context/src/test/resources/conf/md5fh-config.xml
@@ -15,7 +15,7 @@
 
         <service name="Md5FileHasher">
             <inbound>
-                <vm:inbound-endpoint path="Md5FileHasher.In" />
+                <vm:inbound-endpoint path="Md5FileHasher.In" synchronous="true" />
             </inbound>
             <pooled-component>
                 <singleton-object class="com.clood.component.Md5FileHasher">