Reentrant Decode OMMexception

Hello @robert_hau,

This com.reuters.rfa.omm.OMMException: Reentrant decode can happen in the situation that multi-threads try to decode the same OMM object.

The snippet code below shows how to replicate this exception:

    public void processEvent(Event event)
    {
        if (event.getType() == Event.COMPLETION_EVENT)
        {
            System.out.println(_className + ": Receive a COMPLETION_EVENT, " + event.getHandle());
            return;
        }
        System.out.println(_className + ".processEvent: Received Item Event...");
        if (event.getType() != Event.OMM_ITEM_EVENT)
        {
            System.out.println("ERROR: " + _className + " Received an unsupported Event type.");
            _mainApp.cleanup(-1);
            return;
        }
        OMMItemEvent ie = (OMMItemEvent)event;
        OMMMsg respMsg = ie.getMsg();
       
        for (int i=0; i<2; i++) {
        	new DecoderThread(respMsg).start();
        }
    }


class DecoderThread extends Thread {
	final OMMMsg msg;
	public DecoderThread(OMMMsg msg) {
		this.msg = msg;
	}
	
	public void run() {
		OMMData payload = msg.getPayload();
        for (Iterator iter = ((OMMIterable)payload).iterator(); iter.hasNext();)
        {        	
        	OMMFieldEntry entry = (OMMFieldEntry)iter.next();
        	System.out.println(entry.getData());
        }
	}
}

In that case, please check and review the application source code to ensure whether it has a possibility that an OMMMsg object is decoded by multiple-threads or not.

Hope this helps.