Not able to successfully post using example341MarketPriceOffStreamPost

To submit an OffStream PostMsg you need an OmmConsumer instance and the Login Handle.

So, you can can post from wherever you want in you application as long you have access to the above two.

The above example uses event.handle() because the OnRefresh event is for the MMT_LOGIN. However, you can instead store the return value from when you can registerClient for MMT_LOGIN and use that when calling submit from somewhere other than the onRefresh.

All comments

A few of things to note

The line of code below is registering interesting in consuming the item - not posting

long handle = consumer.registerClient(reqMsg.clear().serviceName("UAT_MLIP").name(".WFCBTST1"), appClient, consumer);

2.The actual post is done using the submit() call in the onRefreshMsg() method e.g.

((OmmConsumer)event.closure()).submit( postMsg.postId( 1 ).serviceId( 1501 )
	.name( ".WFCBTST1" ).solicitAck( true ).complete(true)
	.payload(nestedRefreshMsg), event.handle() );

3. There is an outstanding issue with EMA Java in that the serviceName() method is not working. You need to use serviceId() call instead - after obtaining the correct service ID for the service from your Market Data team.

The development team are aware of the above issue and it should be fixed in a future build.

Hi Umer,

Thanks for the response. We got the service id pertained to our
service UAT_MLIP ie 4300 and retried. It did not work, came back with similar
error, pasted below. We are not sure if this is successful or not and it is not
reflecting in the frontend.

On the other note, We are also trying to enable the logging
using logback and even if I set root logger level to debug, we are not getting
much logging out of API.

Also is there a any better example which I can use for post.

Received AckMsg. Item Handle: 1 Closure: com.thomsonreuters.ema.access.OmmConsumerImpl@35bfa910

Item Name: .WFCBTST1

Service Name: not set

Ack Id: 1

Nack Code: DeniedBySource

Text: .WFCBTST1

Received Status. Item Handle: 2 Closure: com.thomsonreuters.ema.access.OmmConsumerImpl@35bfa910

Item Name: .WFCBTST1

Service Name: UAT_MLIP

Item State: Open / Suspect / None / 'Request timeout'

Thanks & regards

--Thiru

A few things.

Has your Market Data team confirmed that the MLIP_UAT source is able to receive Posts/ contributions for that particular RIC? Have they confirmed this works with some other existing application which posts successfully? Because it could be possible that the source has not been configured correctly. In which case they could raise a ticket with TREP support and get some assistance with the config
With regards logging please see this post
It is also possible to enable low level EMA message tracing using the XmlTraceToStdout=1 setting in your EMAConfig.xml file as described here

If your Market Data team are sure that MLIP_UAT is configured correctly, then you can upload some logging and the XmlTrace here for further analysis.

emajlog0.txt output.zip

Pls find the full trace and the log information and let us know if you see any obvious things to be fixed.

Jirapongse

veerapath.rungruengrayubkul

I have tested it with my contribution server (ATS). I don't have MarketLink. The ATS can accept the post message properly.

<POST domainType="MARKET_PRICE" streamId="1" containerType="MSG" flags="0x66 (HAS_POST_ID|HAS_MSG_KEY|POST_COMPLETE|ACK)" postId="1" postUserId="0" postUserAddr="0.0.0.0" dataSize="24">
    <key flags="0x03 (HAS_SERVICE_ID|HAS_NAME)" serviceId="267" name="TEST.BK"/>
    <dataBody>
        <REFRESH domainType="MARKET_PRICE" streamId="0" containerType="FIELD_LIST" flags="0x40 (REFRESH_COMPLETE)" groupId="0" State: Open/Ok/None - text: "" dataSize="8">
            <dataBody>
                <fieldList flags="0x08 (HAS_STANDARD_DATA)">
                    <fieldEntry fieldId="22" data="0F22"/>
                </fieldList>
            </dataBody>
        </REFRESH>
    </dataBody>
</POST>

<ACK domainType="MARKET_PRICE" streamId="1" containerType="NO_DATA" flags="0x12 (HAS_TEXT|HAS_MSG_KEY)" ackId="1" text="[1]: Contribution Accepted" dataSize="0">
    <key flags="0x03 (HAS_SERVICE_ID|HAS_NAME)" serviceId="267" name="TEST.BK"/>
    <dataBody>
    </dataBody>
</ACK>

In your case, the below AckMsg could be sent from the MarketLink server. You should contact the MarketLink team to verify the MarketLink's log to find the reason of NAK DeniedBySource.

Received AckMsg. Item Handle: 1 Closure: com.thomsonreuters.ema.access.OmmConsumerImpl@35bfa910
Item Name: .WFCBTST1
Service Name: not set
Ack Id: 1
Nack Code: DeniedBySource
Text: .WFCBTST1

As far as I know, the MarketLink IP can accept only the Post message which contains Update message as payload. Could you try modifying the example to use nested Update instead of Refresh?

zoya faberov

Veerapath is absolutely correct. Please see the tested update to EMA OffStreamPost example

...
PostMsg postMsg = EmaFactory.createPostMsg();
RefreshMsg nestedRefreshMsg = EmaFactory.createRefreshMsg();
UpdateMsg nestedUpdateMsg = EmaFactory.createUpdateMsg();
FieldList nestedFieldList = EmaFactory.createFieldList();
//FieldList is a collection in java
nestedFieldList.add(EmaFactory.createFieldEntry().real(22, 34, OmmReal.MagnitudeType.EXPONENT_POS_1));
nestedFieldList.add(EmaFactory.createFieldEntry().real(25, 35, OmmReal.MagnitudeType.EXPONENT_POS_1));

nestedUpdateMsg.payload(nestedFieldList );

((OmmConsumer)event.closure()).submit( postMsg.postId( 1 ).serviceId( 338)//1501 )
.name( "YOUR_INSTRUMENT_HERE" ).solicitAck( true ).complete(true)
.payload(nestedUpdateMsg), event.handle() );
...

Thanks for the suggestion. I have changed it to nested update, after that I am not getting ACK, is this mean, it's throwing exception now.

Exception in thread "pool-2-thread-1" Exception Type='OmmInvalidHandleException', Text='loggerMsg

ClientName: ItemCallbackClient

Severity: Error

Text: Attempt to use invalid Handle on submit(PostMsg). Instance name='Consumer_1_1'.

loggerMsgEnd

', Handle='0'

com.thomsonreuters.ema.examples.training.consumer.series300.example341__MarketPrice__OffStreamPost.AppClient.onRefreshMsg(Consumer.java:102)

consumer.zipPls find the consumer.java.

thanks for help

--Thiru

Jirapongse

Thank you for the code.

From my test, the issue happens randomly. Sometimes, event.handle() returns zero which causes the exception. I will investigate the issue.

To submit an OffStream PostMsg you need an OmmConsumer instance and the Login Handle.

So, you can can post from wherever you want in you application as long you have access to the above two.

Hi @Umer Nalla

Thanks for the details and it worked out well. We were able to submit using login handle successfully but the submission happens for every individual updates. Is there a way we can batch it and submit?

Nipat Kunvutipongsak