how to resolve the below issue

nsharma · 2025-04-02T05:05:32+00:00

There was an error rendering this rich post.

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);

}

Find more posts tagged with

java

posting

#technology

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.

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

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.

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

Does the onPostMsg method is used for publishing the data