private void startFixServer()

in src/main/java/com/amazonaws/fixengineonaws/FixEngine.java [540:564]

24 lines of code
4 McCabe index (conditional complexity)


    private void startFixServer(FixEngineConfig config) throws ConfigError {
	    LOGGER.info(MY_IP+"****STARTING FIX SERVER APPLICATION");           
	    if(FIX_SERVER!=null) {
		    LOGGER.info(MY_IP+"START FIX SERVER: FIX_SERVER object already exists!");
	    } else {
	        MessageStoreFactory messageStoreFactory = null;
	        if("true".equals(config.getSessionSetting("UseJdbcMessageStore"))) {
	        	messageStoreFactory = new JdbcStoreFactory(config.getSessionSettings());
	        } else {
	        	messageStoreFactory = new FileStoreFactory(config.getSessionSettings());
	        }
	        LogFactory logFactory = new ScreenLogFactory(true, true, true);
	        MessageFactory messageFactory = new DefaultMessageFactory();
	    	FIX_SERVER = new SocketAcceptor(this, messageStoreFactory, config.getSessionSettings(), logFactory, messageFactory);
		    LOGGER.info(MY_IP+"START FIX SERVER: FIX_SERVER object created: " + FIX_SERVER);	    	
	    }

	    if(FIX_SESSION!=null) {
		    LOGGER.info(MY_IP+"START FIX SERVER: FIX_INBOUND_SESSION object already exists!");
	    } else {
	    	FIX_SERVER.start();
	    	FIX_SESSION = Session.lookupSession(FIX_SERVER.getSessions().get(0));
		    LOGGER.info(MY_IP+"START FIX SERVER: FIX_INBOUND_SESSION object created: " + FIX_SESSION);
	    }
    }