Author: keith Date: Wed Dec 10 23:01:11 2008 New Revision: 26743 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=26743
Log: adding a check to take care of servicename.endpoint Modified: branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/udp/UDPListener.java Modified: branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java?rev=26743&r1=26742&r2=26743&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java (original) +++ branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java Wed Dec 10 23:01:11 2008 @@ -104,6 +104,11 @@ * @throws AxisFault */ public EndpointReference[] getEPRsForService(String serviceName, String ip) throws AxisFault { + + // strip out the endpoint name if present + if (serviceName.indexOf('.') != -1) { + serviceName = serviceName.substring(0, serviceName.indexOf('.')); + } //Try to get the list of EPRs from the FIXSessionFactory String[] serviceEPRStrings = fixSessionFactory.getServiceEPRs(serviceName, ip); if (serviceEPRStrings != null) { Modified: branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/udp/UDPListener.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/udp/UDPListener.java?rev=26743&r1=26742&r2=26743&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/udp/UDPListener.java (original) +++ branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/udp/UDPListener.java Wed Dec 10 23:01:11 2008 @@ -142,6 +142,12 @@ } public EndpointReference[] getEPRsForService(String serviceName, String ip) throws AxisFault { + + // strip out the endpoint name if present + if (serviceName.indexOf('.') != -1) { + serviceName = serviceName.substring(0, serviceName.indexOf('.')); + } + Endpoint endpoint = endpoints.get(serviceName); if (endpoint == null) { return null; _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
