Page Comparison

import quickfix.*;
import java.io.FileInputStream;
 
public class QFJApp {
 
    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();
        // start acceptor
        Acceptor acceptor =
                new SocketAcceptor(application, storeFactory, settings, messageFactory);
        acceptor.start();
 
        // preventing application from exiting
        System.out.println("Press enter to exit");

        System.in.read();

        acceptor.stop();

    }
}
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
	
 	

 
        // create server that will listen for TCP/IP

 connections
        FIXServer server = new FIXServer();

        server.setPort(9880);

        // setting listener for new

 connections
        server.setListener(new

 SimpleAcceptorServer());

        // setting path to properties file with sessions
        server.setConfigPath(fileName);

 
        // starting new thread and listen for incoming

 connections
        server.start();

 
        // preventing application from

 exiting
        System.out.println("Press enter to exit");

        System.in.read();

        // stop the thread that listens for new

 connections
        server.stop();

    }
 
    // this method is called for every new connection
    public void newFIXSession(FIXSession session) {
        try {
            activeSessions.add(session);

 
            // setting listener for incoming messages;

            // MyFIXSessionListener is is your class that

 implements
            // the FIXSessionListener

 interface
            session.setFIXSessionListener(new

 MyFIXSessionListener(session));

 
            // accept incoming

 session
            session.connect();

        } catch (IOException e) {
        }
    }
}

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();

    }
}
	
	
	
	
	
	
	
	
	
	
	
	
	
	

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 configFile = args[0];

 
        //load initiator

 configuration
        SessionParameters details =
            SessionParametersBuilder.buildSessionParameters(configFile,

 "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");

    }
}

Message message = new Message();

  // BeginString

  message.getHeader().setField(new

 StringField(8,

 "FIX.4.2"));

  // SenderCompID

  message.getHeader().setField(new

 StringField(49,

 "TW"));

  // TargetCompID

  message.getHeader().setField(new

 StringField(56,

 "TARGET"));

  // MsgType

  message.getHeader().setField(new

 CharField(35,

 'F'));

  // ClOrdID

  message.setField(new

 StringField(11,

 "321"));

  // Side, with value enumeration

  message.setField(new

 CharField(54, Side.BUY)));

  // ... and other fields as necessary ...

FIXFieldList messageContent = new FIXFieldList();

 // BeginString

  messageContent.addTag(8,

 "FIX.4.2");

  // SenderCompID

  messageContent.addTag(49,

 "TW");

  // TargetCompID

  messageContent.addTag(56,

 "TARGET");

  // MsgType

  messageContent.addTag(35,

 "F");

  // ClOrdID

  message.addTag(11,

 "321");

  // Side

  message.addTag(54, Side.BUY.getValue());

  // ... and other fields as necessary ...

quickfix.fix42.ExecutionReport message

 =
    new quickfix.fix42.ExecutionReport

 (
        new ClOrdID("321"),

        new ExecType("1"),

        new OrdStatus("2"),

        new LeavesQty(0.0));

// Create an "Execution Report" message for FIX 4.2

ExecutionReport exec =

 new

 ExecutionReport();

exec.setClOrdID("321");

exec.setExecType('1');

exec.setOrdStatus('2');

exec.setLeavesQty(0.0);

public void createRG(){
    quickfix.fix42.MarketDataSnapshotFullRefresh message

 =
            new quickfix.fix42.MarketDataSnapshotFullRefresh(new

 Symbol("QF"));

 
    quickfix.fix42.MarketDataSnapshotFullRefresh.NoMDEntries group

 =
            new quickfix.fix42.MarketDataSnapshotFullRefresh.NoMDEntries();

 
    group.set(new

 MDEntryType('0'));

    group.set(new

 MDEntryPx(12.32));

    group.set(new

 MDEntrySize(100));

    group.set(new

 OrderID("ORDERID"));

    message.addGroup(group);

 
    group.set(new

 MDEntryType('1'));

    group.set(new

 MDEntryPx(12.32));

    group.set(new

 MDEntrySize(100));

    group.set(new

 OrderID("ORDERID"));

    message.addGroup(group);

}
	
	
	
	

 "QF");

 
     
RepeatingGroup group = message.addRepeatingGroup(NoMDEntries);

    RepeatingGroup.Entry entry1 = group.addEntry();

    entry1.addTag(MDEntryType,

 '0');

    entry1.addTag(MDEntryPx,

 12.32,

 2);

    entry1.addTag(MDEntrySize,

 100);

    entry1.addTag(OrderID,

 "ORDERID");

 
    RepeatingGroup.Entry entry2 = group.addEntry();

    entry2.addTag(MDEntryType,

 '1');

    entry2.addTag(MDEntryPx,

 12.32,

 2);

    entry2.addTag(MDEntrySize,

 100);

    entry2.addTag(OrderID,

 "ORDERID");

 
    //return objects to

 pool
    entry1.release();

    entry2.release();

    group.release();

}