Hello @dimple.shah

Basically, the OmmConsumer.registerClient() method returns a handle which is a reference to the subscription RIC.

Once you get a handle, you can use OmmConsumer.unregister(handle) method to unsubscribe that RIC stream.

Example Code:

long handle = consumer.registerClient(EmaFactory.createReqMsg().serviceName("ELEKTRON_DD").name("JPY="), appClient, 0)


Thread.sleep(6000);      // API calls onRefreshMsg(), onUpdateMsg() and onStatusMsg()
System.out.println("Close Item request");
consumer.unregister(handle);
Thread.sleep(60000);     // API calls onRefreshMsg(), onUpdateMsg() and onStatusMsg()

If you are using Batch, the batch request message is always closed by the backend, and then the backend creates individual streams for each of the RICs and allocate a unique handle to each stream. You can get the item subscription handler from the OmmConsumerEvent.handler() method in the OmmConsumerClient class too.

Please see the full example code from the EMA Java ex300_MP_Close example.

Example Code:

class AppClient implements OmmConsumerClient{
    long numOfUpdates = 0;
    OmmConsumer _ommConsumer = null;
    
    void setOmmConsumer(OmmConsumer consumer){
        _ommConsumer = consumer;
    }


    public void onRefreshMsg(RefreshMsg refreshMsg, OmmConsumerEvent event){
        ....
    }
    
    public void onUpdateMsg(UpdateMsg updateMsg, OmmConsumerEvent event) {
        System.out.println("Item Name: " + (updateMsg.hasName() ? updateMsg.name() : "<not set>"));
        System.out.println("Service Name: " + (updateMsg.hasServiceName() ? updateMsg.serviceName() : "<not set>"));
        
        if (DataType.DataTypes.FIELD_LIST == updateMsg.payload().dataType())
            decode(updateMsg.payload().fieldList());
        
        System.out.println();
        
        // Close streaming request after receiving 3 update messages
        if (++numOfUpdates == 3){
            System.out.println("Close Item request");
            _ommConsumer.unregister(event.handle());


        }
    }

    public void onStatusMsg(StatusMsg statusMsg, OmmConsumerEvent event) {
        ...
    }
    
    ....

    void decode(FieldList fieldList){
        ....
    }


}
public class Consumer {
   public static void main(String[] args) {
      OmmConsumer consumer = null;
      try{
         AppClient appClient = new AppClient();
         consumer = EmaFactory.createOmmConsumer(EmaFactory.createOmmConsumerConfig().host("localhost:14002").username("user"));

        appClient.setOmmConsumer(consumer);

         ....
      }
   }
}

Hi @wasin.w ,

Thanks for your prompt reply.

We also want to know that do we get any acknowledgement message or event when we call the method consumer.unregister(handle) to unsubscribe any streaming RIC. If we yes, then what is the type of java object and how do we process it?

Hi @wasin.w,
Thanks again for your response.

We also want to know if it is guaranteed that once we call consumer.unregister(handle), then we will stop receiving updates for that item.

Hello @dimple.shah

Once the application calls OmmConsumer.unregister(handle) method with a valid handle, the API sends the close request message for that item to the server, and the server will stop send that item's data to the API.

By default, the application will stop receiving updates for that item immediately.

• Unless there are some updates in the API queue that not dispatched to the application yet. The API will dispatch those updates to the application until no more updates of that item. However, this is rarely happened.

If you encounter the issue that the application still receiving updates after the OmmConsumer.unregister(handle) method called, I suggest you contact the API support team to verify the API issue.

You can submit the GitHub - Issue to the RTSDK team directly via the https://github.com/Refinitiv/Real-Time-SDK/issues page.

Alternatively, you can contact your colleagues who are the RDC named user to submit a support ticket to the Real-Time APIs support team via the "contact premium support" button on the https://developers.lseg.com/en/api-catalog/refinitiv-real-time-opnsrc/rt-sdk-java page.