Not able to get updates when submitting post messages through the ommConsumer,

harsh_tripathi

We are migrating from RFA to RTDSK EMA. The migration for consumer is done, and we are able to market data from trep server through ommConsumer.

Now that we are moving to the contributor part, we are facing some issues. When we try to submit post messages through the ommConsumer, we are not able to get updates when subscribing to that instrument. We don't get any exception in the try block for submitting the post message.

What are the possible things which could be going wrong here?

The ommConsumer →

m_ommConsumer = std::make_shared<OmmConsumer>(OmmConsumerConfig()

                                                .host(rmds_host.c_str())

                                                .operationModel(OmmConsumerConfig::UserDispatchEnum)

                                                .username(app_user.c_str()));


The submit try catch block →

void AppClient_NameSpace::onRefreshMsg(const RefreshMsg &refreshMsg, const OmmConsumerEvent & e)
{
try{
m_ommConsumer->submit(PostMsg()
.streamId(refreshMsg.getStreamId())
.postId(1)
.serviceId(refreshMsg.getServiceId())
.solicitAck(true).complete()
.payload(UpdateMsg().streamId(refreshMsg.getStreamId())
.name(refreshMsg.getName())
.payload(FieldList()
.addReal(22, 1000, OmmReal::ExponentNeg2Enum)
.addReal(25, 2000, OmmReal::ExponentNeg2Enum)
.complete()))
.complete(),
e.getHandle());
}
catch (const std::exception &exp)
{
std::cout << "Not able to post for RIC" << refreshMsg.getName() << "Exception: " << exp.what() << std::endl;
}
}
 

Jirapongse

@harsh_tripathi

Thank you for reaching out to us.

You can enable the XML trace log (XmlTraceToStdout or XmlTraceToFile) in the EMA configuration file to verify the incoming and outgoing messages.

For example:

		<Consumer>
		
			<Name value="Consumer_1"/>
			<Channel value="Channel_1"/>
			<Logger value="Logger_1"/>
			<Dictionary value="Dictionary_2"/>
			<XmlTraceToStdout value="1"/>
		</Consumer>

What is the source of the posting service?