Event order
1. Configure the OMM NON-INTERACTIVE PROVIDER session
com.apama.rfa.SessionConfiguration("ReutersRFATransport",
{"applicationType":"OMMNIProvider",
"RFASessionName":"ApamaNameSpace::nonInteractiveProviderSession",
"heartBeatInterval":"30"})
2. Send Login request
com.apama.rfa.Login("ReutersRFATransport","reuters",{})
3. Publishing Directory
com.apama.rfa.DIRECTORY_RESP("ReutersRFATransport","REFRESH_RESP",1,
"REFRESH_COMPLETE",[1,2,4,8,16,32],
{
"DIRECT_FEED":
com.apama.rfa.Service(
com.apama.rfa.SDInfoFilterEntry("DIRECT_FEED",[5,6],
[],["RWFFld","RWFEnum"],{"IsSource":"0",
"SupportsOutOfBandSnapshots":"1","SupportsQoSRange":"0",
"Vendor":"Reuters"}),
com.apama.rfa.SDStateFilterEntry(1,1,""),
com.apama.rfa.SDGroupFilterEntry("","",""),
com.apama.rfa.SDLoadFilterEntry(0,0,0),
com.apama.rfa.SDDataFilterEntry(0,""),
com.apama.rfa.SDLinkFilterEntry(1,0,0,"")
)
},
{
"DataState":"OK",
"StatusCode":"NONE",
"StreamState":"OPEN"
})
4. Publish Data MARKET_PRICE/MARKET_BY_PRICE/MARKET_BY_ORDER/ MARKET_MAKER/SYMBOL_LIST
com.apama.rfa.MARKET_PRICE_RESP("ReutersRFATransport","REFRESH_RESP",1,
"DO_NOT_CONFLATE","DIRECT_FEED","ABC","RIC",12.0000,2100,
{
"DataState":"OK",
"StreamState":"OPEN",
"StatusCode":"NONE",
"BID":"11.8000",
"ASK":"12.2000"
})
com.apama.rfa.MARKET_BY_PRICE_RESP("ReutersRFATransport","REFRESH_RESP",
1,"REFRESH_COMPLETE","DIRECT_FEED","ABC","RIC",
[com.apama.rfa.MKT_BY_PRICE_Entry(
"DELETE","123","ASK",10.09,100,200,{})
],
{})