org.apache.synapse.transport.fix: class: FIXIncomingMessageHandler.FIXWorkerThread

org.apache.synapse.transport.fix
class: FIXIncomingMessageHandler.FIXWorkerThread [javadoc | source]

java.lang.Object
   org.apache.synapse.transport.fix.FIXIncomingMessageHandler$FIXWorkerThread

All Implemented Interfaces:
Runnable

This Runnable class can be used when it is required to process each incoming message using separate threads.

Constructor:
public FIXWorkerThread(Message message, SessionID sessionID, int counter) { this.message = message; this.sessionID = sessionID; this.counter = counter; }

Constructor:

 public FIXWorkerThread(Message message,
    SessionID sessionID,
    int counter) {
            this.message = message;
            this.sessionID = sessionID;
            this.counter = counter;
}

Method from org.apache.synapse.transport.fix.FIXIncomingMessageHandler$FIXWorkerThread Summary:
run

Methods from java.lang.Object:
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.apache.synapse.transport.fix.FIXIncomingMessageHandler$FIXWorkerThread Detail:
public void run() { if (allNewApproach) { //treat all messages (including responses) as new messages handleIncomingRequest(); } else { if (acceptor) { //treat messages coming from an acceptor as new request messages handleIncomingRequest(); } else { MessageContext outMsgCtx = outgoingMessages.poll(); if (outMsgCtx != null) { //handle as a response to an outgoing message handleIncomingResponse(outMsgCtx); } else { //handle as a new request message handleIncomingRequest(); } } } }

Method from org.apache.synapse.transport.fix.FIXIncomingMessageHandler$FIXWorkerThread Detail:

 public  void run() {
            if (allNewApproach) {
                //treat all messages (including responses) as new messages
                handleIncomingRequest();
            }
            else {
                if (acceptor) {
                    //treat messages coming from an acceptor as new request messages
                    handleIncomingRequest();
                }
                else {
                    MessageContext outMsgCtx = outgoingMessages.poll();
                    if (outMsgCtx != null) {
                        //handle as a response to an outgoing message
                        handleIncomingResponse(outMsgCtx);
                    }
                    else {
                        //handle as a new request message
                        handleIncomingRequest();
                    }
                }
            }
}