Maybe you can outline the changes that you want to introduce into the IoSessionInitiator? IMHO it would be good to introduce some kind of strategy that can easily be changed without changing QFJ itself.

Hi @chrjohn,
Thanks a lot for the Response. I've tried the change and tested. It is working as expected. As you mentioned Main change is in the class IoSessionInitiator. But couple of classes also need to be modified in order to introduce the New Configuration.
I've Add those classes here. I would be grateful if you could able overview my changes. I've done this change on top of Version 2.0.0.
If this change is acceptable please be kind enough to guide me to add this change to the Latest Code.
ChangedClasses.zip
Configuration&TestEvidence.zip

To submit a change so we can modify/merge it:

• Go to: https://github.com/quickfix-j/quickfixj
• Click "Fork"
• Go to your new repository - i.e. https://github.com/MuhammadhAadhil/quickfixj
• Clone the repository
• Checkout a new branch
• Make the changes to the classes (tests and source code)
• Commit the change
• Push the branch
• Go to https://github.com/quickfix-j/quickfixj
• Click New pull request
• Click 'compare across forks'
• Select your repository and branch
• Make sure the changes look like what you did
• Click 'Create pull request'

Hi, was this ever added as a PR / merged into a release version by any chance? I tried to look but I couldn't find anything that suggested it had.
Thanks!

Hi @PetteriPertola , no this has not been merged since there was no PR submitted.

Hi @PetteriPertola , no this has not been merged since there was no PR submitted.

Thanks. We're seeing a similar issue: If primary host is down when starting up, then the failover mechanism of SocketConnectHost1, SocketConnectPort1 does not work, it just keeps retrying the SocketConnectHost over and over again.

@PetteriPertola Maybe you can take a stab at a PR?

Hi guys,

I found a funny thing: the failover feature works sometimes, but not always.

For the failover test I created a working acceptor at port 9998; and I also created a TCP server at port 9999 to send a reset back to the initiator as soon as it connects:

final ServerSocket serverSocket = new ServerSocket(9999);

while (true) {
    try (final Socket socket = serverSocket.accept()) {
        socket.setSoLinger(true, 0);
        System.out.println("accepted " + socket);
    } finally {
        System.out.println("done");
    }
}

The TCP server above makes the initiator to try the next host:port. However, if we add a Thread.sleep(20) before closing the connection, the failover stops working.

This divergence happens when calling Net.pollConnectNow(fd) at .finishConnect() method from sun.nio.ch.SocketChannelImpl happens sooner or later depending on the response from the server.

A workaround to this problem case is to add a Thread.sleep(MILLIS) (with a reasonable MILLIS value) at the beginnig of .finishConnect(handle) method from org.apache.mina.transport.socket.nio.NioSocketConnector of the org.apache.mina:mina-core:2.1.4 dependency.

@suguiura
Thanks for the comment but if you are suggesting a change for MINA then your best bet is to open an issue in their issue tracker. http://issues.apache.org/jira/browse/DIRMINA

Hi All,
I'm really apologizing for my late response. I've added the change. Please be kind enough to review.
#624