Messtone LLC Manages(FIX API):

FIX API/ public static boolean startDataFix( ){if(!devEnv){if(startDataFixProd(resetSeqData)){return true;}else{logger.error(“Failed to start data service.”);return false;}}else{if(startDataFixDev(resetSeqData)){return true;}else{logger.error(“Failed to start data service.”)); return false;}}} private static boolean startDataFixProd(boolean resetReq){if(dataInitiator !=null){dataInitiator.stop(true);try{dataInitiator.start( );return true;}catch(Exception e){dataInitiator=null;e.printStackTrace( );logger.error(e.getMessage( ));return false;}}boolean result=false;FileInputStream fileInputStream=null;try{fileInputStream=Thread.currentThread( ).getContextClassLoader( ).getResourceAsSfream(dataCfgFileNameMesstone);SessionSettings settings=new SessionSettings(fileInputStream); fileInputStream.close( );fileInputStream=null;dataFIX=new Data(settings,resetReq);Message store factory storeFactory=new FileStoreFactory(settings);LogFactory logFactory=null; logFactory=new FileLogFactory(settings);MessageFactory messageFactory=new DefaultMessageFactory( ); dataInitiator=new SocketInitiator(dataFIX,storeFactory,settings,logFactory,messageFactory);dataInitiator.start( );result=true;}catch(Exception e){dataInitiator=null;e.printStackTrace( ); logger.error(e.getMessage);}finally{if(fileInputStream !=null){try{fileInputStream.close( );}catch(Exception e){e.printStackTrace( );logger.error(e.getMessage( ));}}}return result;} private static boolean startOrderFixDev(boolean resetReq){if(orderInitiator !=null){orderInitiator.stop(true);try{orderInitiator.start( );return true;}catch(Exception e){orderInitiator=null;e.printStackTrace( );logger.error(e.getMessage( )); return false;}}boolean result=false;InputStream fileInputStream=null;try{fileInputStream=Thread.currentThread( ).getContextClassLoader( ). getResourceAsSfream(dataCfgFileNameMesstone);SessionSettings settings=new SessionSettings(fileInputStream);fileInputStream.close( );fileInputStream=null;dataFIX=new Data(settings,resetReq);MessageStoreFactory storeFactory=new FileStoreFactory(settings); LogFactory logFactory=null; logFactory=new FileLogFactory(settings);MessageFactory messageFactory=new DefaultMessageFactory( ); dataInitiator=new SocketInitiator(dataFIX, storeFactory,settings,logFactory,messageFactory); dataInitiator.start( ); result=true


Leave a comment