how to resolve the below issue

nsharma · April 2

When I am trying to publish Data using the postMsg method getting below error

Failed to submit PostMsg on item stream. Reason: ReactorReturnCodes.INVALID_USAGE. Error text: Cannot submit PostMsg when stream not in open state.

Code snippet using as below

OmmConsumer consumer = null;

AppClient appClient = new AppClient();

OmmConsumerConfig config = EmaFactory.createOmmConsumerConfig();

consumer = EmaFactory.createOmmConsumer(

config.host("localhost:14002").username("user") );

ReqMsg reqMsg = EmaFactory.createReqMsg();

long closure = 1;

long itemHandle = consumer.registerClient( reqMsg.serviceName( "servicename" ).name(

"name" ), appClient, closure );

reqMsg.clear();

PostMsg postMsg = EmaFactory.createPostMsg();

FieldList nestedFieldList = EmaFactory.createFieldList();

nestedFieldList.add( EmaFactory.createFieldEntry().uintValue(1, 100) );

consumer.submit( postMsg.payload(nestedFieldList), itemHandle );

Thread.sleep(60000);

}

Jirapongse · April 2

Thank you for reaching out to us.

According to the code, you are using the on-stream posting to post a message on an item stream.

You need to wait for the item stream to open before sending post messages.

You can refer to the on-stream posting example on GitHub.

nsharma · April 2

Thank you for the quick reply

Can you please let me know how and when the item stream opens?
and also what to do if I need to use the off-stream instead of on-stream

Jirapongse · April 2

Please check the example on GitHub.

The example demonstrates how to check if the item stream is opened.

Yes, you can use the off-stream posting instead.

If you would like to post items to ATS, you can refer to this Implementing Real-Time API application to work with ATS - Part 1 article.

nsharma · April 2

What need to be done to publish data using the EMA OMMConsumer?

Does the onPostMsg method is used for publishing the data

Jirapongse · April 2

There are three ways to publish data to consumers.

Consumers typically consume data from providers and posting allows consumers to contribute data to providers.

It is better to read the API Concept Guide so you will understand the functionalities of each component.

Welcome!