Attempt to use invalid Handle on submit(PostMsg)

Hi,

I am trying to post a message on RTMDS connectivity (no tunnel stream), but the response to the post request is this error message

2023-05-23 10:44:52.704 ERROR 37860 --- [pool-2-thread-1] c.refinitiv.ema.access.OmmConsumerImpl : loggerMsg

ClientName: ItemCallbackClient

Severity: Error

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

loggerMsgEnd

Sample code:

...

try {

System.out.println("Contributing to Refinitiv Contributions Channel");

//Parsing Program arguments.

OmmConsumerConfig config = EmaFactory.createOmmConsumerConfig();

Common.readCommandlineArgs(args,config);

if (Common.userName != null) config.username(Common.userName);

_ommConsumer = EmaFactory.createOmmConsumer(config.host(Common.host));

//Register to get the login and source directory message

_ommConsumer.registerClient(loginReq.message(), this);

_ommConsumer.registerClient(EmaFactory.createReqMsg().domainType(EmaRdm.MMT_DIRECTORY).serviceName(trceServiceName), this);

Thread.sleep(60000);

} catch (InterruptedException | OmmException excp) {

System.out.println(excp.getMessage());

}

...

@Override

public void onRefreshMsg(RefreshMsg refreshMsg, OmmConsumerEvent event) {

try {

System.out.println("----- Refresh message ----");

System.out.println(refreshMsg);

if (refreshMsg.domainType() == EmaRdm.MMT_LOGIN && refreshMsg.state().streamState() == OmmState.StreamState.OPEN && refreshMsg.state().dataState() == OmmState.DataState.OK) {

// 3. Login accepted, app can post data now

System.out.println("Login accepted, starting posting...");

_postStreamID = refreshMsg.streamId();

postMessage();

} else {

System.out.println("Stream not open");

}

} catch (OmmException excp) {

System.out.println(excp.getMessage());

}

...

private void postMessage() {

try {

Thread.sleep(300);

} catch (Exception e) {

}

// populate the contributed FIDs and values

FieldList nestedFieldList = EmaFactory.createFieldList();

nestedFieldList.add(EmaFactory.createFieldEntry().real(22, _bid++, OmmReal.MagnitudeType.EXPONENT_NEG_1));

nestedFieldList.add(EmaFactory.createFieldEntry().real(25, _ask++, OmmReal.MagnitudeType.EXPONENT_NEG_1));

// create an update message for our item

UpdateMsg nestedUpdateMsg = EmaFactory.createUpdateMsg()

.streamId(_postStreamID)

.name(trceItem)

.payload(nestedFieldList);

// post this market price message

_ommConsumer.submit(EmaFactory.createPostMsg()

.streamId(_postStreamID)

.postId(_postID++)

.domainType(EmaRdm.MMT_MARKET_PRICE)

.solicitAck(true)

.complete(true)

.payload(nestedUpdateMsg), _subStreamHandle);

}

....

Any idea?

Find more posts tagged with

posting

ema-api

#technology

Accepted answers

Jirapongse

@jasequeirosa

What values would you like to post?

For example, if I would like to send 123.50 and 456.50, the code looks like this:

        nestedFieldList.add(EmaFactory.createFieldEntry().real(22, 12350, OmmReal.MagnitudeType.EXPONENT_NEG_2));
        nestedFieldList.add(EmaFactory.createFieldEntry().real(25, 45650, OmmReal.MagnitudeType.EXPONENT_NEG_2));

The output is:

All comments

Gurpreet

Hi @jasequeirosa,

Please try to run the Example 341 - offstream posting from EMA SDK, and let us know if you still have issues. Your example is incomplete and I don't know what _subStreamHandle is pointing to.

Jirapongse

@jasequeirosa

I assume that you are contributing data to RCC. You can refer to the sample code in the EMA Consumer - Posting data to Contribution Channel tutorial.

According to the error message, it looks like the handle or stream used by the application to contribute the data has been closed.

You may need to enable tracing in the API to verify what the problem is. You can set the XmlTraceToStdout to 1 in the consumer used by the application. For example:

        <Consumer>            
            <Name value="Consumer_1"/>            
            <Channel value="Channel_1"/>
            <Dictionary value="Dictionary_1"/>
            <XmlTraceToStdout value="1"/>
        </Consumer>

jasequeirosa

Hi,

I found the problem. On the one hand, I was using the wrong service, since I was using the contributing service incorrectly, and on the other hand, I was not using the correct type of message to publish prices.

On the other hand, now I have a problem posting decimals for the bid/ask, how do I send decimals?

    public void postMessage(BidAsk bidAsk) {
        PostMsg postMsg = EmaFactory.createPostMsg();
        UpdateMsg nestedRefreshMsg = EmaFactory.createUpdateMsg();
        FieldList nestedFieldList = EmaFactory.createFieldList();

        //FieldList is a collection in java
        nestedFieldList.add(EmaFactory.createFieldEntry().real(22, bidAsk.getBid().longValue(), OmmReal.MagnitudeType.EXPONENT_POS_1));
        nestedFieldList.add(EmaFactory.createFieldEntry().real(25, bidAsk.getAsk().longValue(), OmmReal.MagnitudeType.EXPONENT_POS_1));

        nestedRefreshMsg.payload(nestedFieldList);

        consumer.submit(postMsg.postId(postId++).serviceName("Service")
                .name((bidAsk.getItemName().substring(0, 3))+ Constants.LH_CAIX).solicitAck(true).complete(true)
                .payload(nestedRefreshMsg), eventHandle);
    }

Thanks

Jirapongse

@jasequeirosa

What values would you like to post?

For example, if I would like to send 123.50 and 456.50, the code looks like this:

        nestedFieldList.add(EmaFactory.createFieldEntry().real(22, 12350, OmmReal.MagnitudeType.EXPONENT_NEG_2));
        nestedFieldList.add(EmaFactory.createFieldEntry().real(25, 45650, OmmReal.MagnitudeType.EXPONENT_NEG_2));

The output is:

jasequeirosa

Hi,

Ok, thanks, it`s works!

Best regards

EXPLORE OUR SITES