Author: keith Date: Mon Dec 22 08:55:26 2008 New Revision: 27662 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=27662
Log: Disabling FIX for the service if no FIX configuration was found Modified: branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/base/AbstractTransportListener.java branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXTransportListener.java Modified: branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/base/AbstractTransportListener.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/base/AbstractTransportListener.java?rev=27662&r1=27661&r2=27662&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/base/AbstractTransportListener.java (original) +++ branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/base/AbstractTransportListener.java Mon Dec 22 08:55:26 2008 @@ -170,6 +170,7 @@ exposedTransports.add(transportName); } } + service.setEnableAllTransports(false); service.setExposedTransports(exposedTransports); } else { service.removeExposedTransport(getTransportName()); Modified: branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java?rev=27662&r1=27661&r2=27662&view=diff ============================================================================== --- branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java (original) +++ branches/synapse/1.2.wso2v1/modules/transports/src/main/java/org/apache/synapse/transport/fix/FIXSessionFactory.java Mon Dec 22 08:55:26 2008 @@ -83,7 +83,7 @@ * * @param service the AxisService */ - public void createFIXAcceptor(AxisService service) { + public void createFIXAcceptor(AxisService service) throws AxisFault{ //Try to get an InputStream to the FIX configuration file InputStream fixConfigStream = getFIXConfigAsStream(service, true); @@ -114,9 +114,12 @@ } catch (ConfigError e) { log.error("Error in the specified FIX configuration. Unable to initialize a " + "FIX session for the service " + service.getName(), e); + throw new AxisFault("Error in the specified FIX configuration. Unable to initialize a " + + "FIX session for the service " + service.getName(), e); } } log.error("Unable to initialize a FIX session for the service " + service.getName()); + throw new AxisFault("Unable to initialize a FIX session for the service " + service.getName()); } /** 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=27662&r1=27661&r2=27662&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 Mon Dec 22 08:55:26 2008 @@ -81,8 +81,12 @@ if (service.getName().startsWith("__")) { return; } - - fixSessionFactory.createFIXAcceptor(service); + + try { + fixSessionFactory.createFIXAcceptor(service); + } catch (AxisFault axisFault) { + disableTransportForService(service); + } } /** _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
