svn commit: r1097753 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java

[su...@apache.org]

Author: supun
Date: Fri Apr 29 10:07:15 2011
New Revision: 1097753

URL: http://svn.apache.org/viewvc?rev=1097753&view=rev
Log:
fixing an issues with endpoint init in event sources

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java?rev=1097753&r1=1097752&r2=1097753&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/eventing/SynapseEventSource.java Fri Apr 29 10:07:15 2011
@@ -217,7 +217,7 @@ public class SynapseEventSource extends 
                 synCtx.setProperty(SynapseConstants.OUT_ONLY,
                         "true");    // Set one way message for events
                 try {
-                    getEndpointFromURL(subscription.getEndpointUrl())
+                    getEndpointFromURL(subscription.getEndpointUrl(), synCtx.getEnvironment())
                             .send(MessageHelper.cloneMessageContext(synCtx));
                 } catch (AxisFault axisFault) {
                     log.error("Event sending failure " + axisFault.toString());
@@ -413,13 +413,17 @@ public class SynapseEventSource extends 
      * Create a Endpoint for a given URL
      *
      * @param endpointUrl      URL
+     * @param se    synapse environment
      * @return AddressEndpoint address endpoint
      */
-    private Endpoint getEndpointFromURL(String endpointUrl) {
+    private Endpoint getEndpointFromURL(String endpointUrl, SynapseEnvironment se) {
         AddressEndpoint endpoint = new AddressEndpoint();
         EndpointDefinition def = new EndpointDefinition();
         def.setAddress(endpointUrl.trim());
         endpoint.setDefinition(def);
+
+        endpoint.init(se);
+
         return endpoint;
     }