Better way to build a database of Snapshot values for a list of RICs using EMA api

Mani.A
Mani.A
in EMA

Hi,

I have a requirement that I need to create a database of snapshot values for a list of RICs in a given interval say 15 minutes.

I have the below code that runs for every 15 minutes and it did the job. 

OmmConsumer consumer = EmaFactory.createOmmConsumer(config);
ElementList ricBatch = EmaFactory.createElementList();
ricBatch.add(EmaFactory.createElementEntry().array(EmaRdm.ENAME_BATCH_ITEM_LIST, ommArray));

//Specify Dynamic view of fields
ricBatch.add(EmaFactory.createElementEntry().uintValue(EmaRdm.ENAME_VIEW_TYPE, 1));
ricBatch.add(EmaFactory.createElementEntry().array(EmaRdm.ENAME_VIEW_DATA, fields));

ReqMsg ricReqMsg = EmaFactory.createReqMsg().serviceName(adsService).payload(ricBatch) .interestAfterRefresh(false);
consumer.registerClient(ricReqMsg, this);
//wait for snapshot request to be fulfilled
consumer.uninitialize();


Obviously I see that EMA API creates a new consumer thread with new ads connection for each of the snapshot call.

Is there a better do this , that optimized the resources and reuses the connection to ADS server ?

Thanks in advance

Mani

Tagged:

Best Answer

  • Jirapongse
    Jirapongse
    Answer ✓

    @Mani.A

    Instead of creating a new OMMConsumer every 15 minutes, you can reuse it.

    You can create an OMMConsumer when the program starts. 

    OmmConsumer consumer = EmaFactory.createOmmConsumer(config);

    Then, call the consumer.uninitialize() method when the program exits.

    consumer.uninitialize();

    Next, call the consumer.registerClient(ricReqMsg, this) method every interval to get snapshots.

Answers

  • umer.nalla
    umer.nalla

    Hi @Mani.A

    Also, just to be clear - you don't need to create a separate OmmConsume for each ReqMsg that you register - same OMMConsumer instance can be used to make multiple batch requests if required.

    I only mentioned this because I have come across a few developers who did not realise this and were creating an OmmConsumer for each batch request.

  • Mani.A
    Mani.A

    Thanks @Jirapongse and @umer.nalla

    It worked. Earlier I tried reusing the OmmConsumer but made a mistake calling the OmmConsumer.uninitialize() at the end of each iteration instead of at the end of the program.

Categories