Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

QuickFIX/J

FIX Antenna Java

Code Block
languagejava
linenumberstrue
import quickfix.*;
import java.io.FileInputStream;
 
public class QFJInitiator {
    public static void main(String args[]) throws Exception {
        if (args.length != 1) return;
        // path to file with session's configuration
        String fileName = args[0];
 
        // FooApplication is your class that implements the Application interface
        Application application = new FooApplication();
 
        SessionSettings settings = new SessionSettings(new FileInputStream(fileName));
        MessageStoreFactory storeFactory = new FileStoreFactory(settings);
        MessageFactory messageFactory = new DefaultMessageFactory();
        Initiator initiator =
                new SocketInitiator(application, storeFactory, settings, messageFactory);
        initiator.start();
        // preventing application from exiting
        System.out.println("Press enter to exit");
        System.in.read();
 
        initiator.stop();
    }
}
	
	
	
	
	
	
	
	
	
	
	
	
	
	
Code Block
languagejava
linenumberstrue
import com.epam.fix.message.FIXFieldList;
import com.epam.fix.message.constants.FIXT11;
import com.epam.fixengine.*;
import com.epam.fixengine.session.util.SessionParametersBuilder;
 
import java.io.IOException;
 
public class SimpleInitiator {
    public static void main(String[] args) throws IOException {
        if (args.length != 1) {
            return;
        }
        String configFilefileName = args[0];
 
        //load initiator configuration
        SessionParameters details =
            SessionParametersBuilder.buildSessionParameters(configFilefileName, "initiatorS");
 
        // create session we intend to work with
        final FIXSession session = details.createNewFIXSession();
 
        // setting listener for incoming messages;
        // MyFIXSessionListener is is your class that implements
        // the FIXSessionListener interface
        session.setFIXSessionListener(new MyFIXSessionListener(session));
 
        // initiate connection
        try {
            session.connect();
        } catch (IOException e) {
        }
 
        // preventing application from exiting
        System.out.println("Press enter to exit");
        System.in.read();
        // stop the thread that listens for new connections
        session.disconnect("user request");
    }
}

...