Hi @ashwathguru.s,

You can follow the decode example as shown in the samples packaged with SDK like - series200\example200__MarketPrice__Streaming\Consumer.java, or follow the step by step EMA Java decoding tutorial.

If there is still an issue, please post you complete code and we can take a peek at it. Thanks.

Hi,

We are using Scala. The code we are referring is mentioned here

https://developers.refinitiv.com/article/get-real-time-market-data-using-ema-java-scala-language

As mentioned, decode(fieldList: FieldList) is failing with given error.

We are running this in scala interpreter and trying to run forEach loop to extract each single field and use it for further purpose.

class AppClient extends OmmConsumerClient {

def onRefreshMsg(refreshMsg: RefreshMsg,event: OmmConsumerEvent) {

println("Refresh Message of: " +

(if (refreshMsg.hasName()) refreshMsg.name()

else "<not set>"))

println("Service Name: " +

(if (refreshMsg.hasServiceName()) refreshMsg.serviceName()

else "<not set>"))

println("Item State: " + refreshMsg.state());

//println(refreshMsg)

val a = refreshMsg.payload().fieldList().size

println(a)

decode(refreshMsg.payload().fieldList())

}

def decode(fieldList: FieldList){

fieldList.forEach((fieldEntry:FieldEntry) => {

print("\tFid: " + fieldEntry.fieldId() + " Name: " + fieldEntry.name() + " DataType: " + DataType.asString(fieldEntry.load().dataType()) + " Value: ")

})

}

def onUpdateMsg(updateMsg: UpdateMsg,event: OmmConsumerEvent) {

println("Update Message of: " +

(if (updateMsg.hasName()) updateMsg.name()

else "<not set>"))

println("Service Name: " +

(if (updateMsg.hasServiceName()) updateMsg.serviceName()

else "<not set>"))

println(updateMsg)

}

def onStatusMsg(statusMsg: StatusMsg,event: OmmConsumerEvent) {

println("Status Message of:" +

(if (statusMsg.hasName()) statusMsg.name()

else "<not set>"))

println("Service Name: " +

(if (statusMsg.hasServiceName()) statusMsg.serviceName()

else "<not set>"))

if (statusMsg.hasState())

println("Item State: " + statusMsg.state())

println()

}

def onGenericMsg(genericMsg: GenericMsg,event: OmmConsumerEvent) { }

def onAckMsg(ackMsg: AckMsg,event: OmmConsumerEvent) { }

def onAllMsg(msg: Msg,event: OmmConsumerEvent) { }

}

var myapp = new AppClient

var consumer: OmmConsumer = null

val appClient: AppClient = new AppClient()

val config: OmmConsumerConfig = EmaFactory.createOmmConsumerConfig()

consumer = EmaFactory.createOmmConsumer(config.host("test").username("test"));

val reqMsg = EmaFactory.createReqMsg();

var itemNames: scala.collection.mutable.Set[String] = Set("INR=")

var domainType: Int = EmaRdm.MMT_MARKET_PRICE

consumer.registerClient(reqMsg.serviceName("test").domainType(domainType).name(itemNames.head), appClient)

Are you using Consumer.scala sample without any modifications?

@Pimchaya.Wongrukun can you please help with this code snippet.

Hello @ashwathguru.s

You can see an example of EMA Consumer in the Scala language from this article.

Hello @ashwathguru.s

Based on your given source code, I have tested it with Elektron SDK 1.5.0.L1 and it worked properly without any problem. The complete source code is ConsumerClient.txt, please try it with Elektron SDK 1.5.0.L1

If the problem still occurs with my given source code and Elektron SDK 1.5.0.L1, please share the following info:

1. EMA xml trace log when the problem occurs. EMA will trace sent and received message between EMA and the server when set XmlTraceToStdout in Consumer node to be 1. For example:

<Consumer>

<Name value="Consumer_1"/>

…

<XmlTraceToStdout value="1"/>

</Consumer>

2. EMA configuration file (EmaConfig.xml)