-
Notifications
You must be signed in to change notification settings - Fork 132
/
Copy pathIProvider.java
129 lines (111 loc) · 4.68 KB
/
IProvider.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
///*|-----------------------------------------------------------------------------
// *| This source code is provided under the Apache 2.0 license
// *| and is provided AS IS with no warranty or guarantee of fit for purpose.
// *| See the project's LICENSE.md for details.
// *| Copyright (C) 2019 LSEG. All rights reserved.
///*|-----------------------------------------------------------------------------
package com.refinitiv.ema.examples.training.iprovider.series100.ex100_MP_Streaming;
import com.refinitiv.ema.access.EmaFactory;
import com.refinitiv.ema.access.FieldList;
import com.refinitiv.ema.access.GenericMsg;
import com.refinitiv.ema.access.Msg;
import com.refinitiv.ema.access.OmmException;
import com.refinitiv.ema.access.OmmIProviderConfig;
import com.refinitiv.ema.access.OmmProvider;
import com.refinitiv.ema.access.OmmProviderClient;
import com.refinitiv.ema.access.OmmProviderEvent;
import com.refinitiv.ema.access.OmmReal;
import com.refinitiv.ema.access.OmmState;
import com.refinitiv.ema.access.PostMsg;
import com.refinitiv.ema.access.RefreshMsg;
import com.refinitiv.ema.access.ReqMsg;
import com.refinitiv.ema.access.StatusMsg;
import com.refinitiv.ema.rdm.EmaRdm;
class AppClient implements OmmProviderClient
{
public long itemHandle = 0;
public void onReqMsg(ReqMsg reqMsg, OmmProviderEvent event)
{
switch (reqMsg.domainType())
{
case EmaRdm.MMT_LOGIN :
processLoginRequest(reqMsg, event);
break;
case EmaRdm.MMT_MARKET_PRICE :
processMarketPriceRequest(reqMsg, event);
break;
default :
processInvalidItemRequest(reqMsg, event);
break;
}
}
public void onRefreshMsg(RefreshMsg refreshMsg, OmmProviderEvent event){}
public void onStatusMsg(StatusMsg statusMsg, OmmProviderEvent event){}
public void onGenericMsg(GenericMsg genericMsg, OmmProviderEvent event){}
public void onPostMsg(PostMsg postMsg, OmmProviderEvent event){}
public void onReissue(ReqMsg reqMsg, OmmProviderEvent event){}
public void onClose(ReqMsg reqMsg, OmmProviderEvent event){}
public void onAllMsg(Msg msg, OmmProviderEvent event){}
void processLoginRequest(ReqMsg reqMsg, OmmProviderEvent event)
{
event.provider().submit( EmaFactory.createRefreshMsg().domainType(EmaRdm.MMT_LOGIN).name(reqMsg.name()).
nameType(EmaRdm.USER_NAME).complete(true).solicited(true).
state(OmmState.StreamState.OPEN, OmmState.DataState.OK, OmmState.StatusCode.NONE, "Login accepted"),
event.handle() );
}
void processMarketPriceRequest(ReqMsg reqMsg, OmmProviderEvent event)
{
if( itemHandle != 0 )
{
processInvalidItemRequest(reqMsg, event);
return;
}
FieldList fieldList = EmaFactory.createFieldList();
fieldList.add( EmaFactory.createFieldEntry().real(22, 3990, OmmReal.MagnitudeType.EXPONENT_NEG_2));
fieldList.add( EmaFactory.createFieldEntry().real(25, 3994, OmmReal.MagnitudeType.EXPONENT_NEG_2));
fieldList.add( EmaFactory.createFieldEntry().real(30, 9, OmmReal.MagnitudeType.EXPONENT_0));
fieldList.add( EmaFactory.createFieldEntry().real(31, 19, OmmReal.MagnitudeType.EXPONENT_0));
event.provider().submit( EmaFactory.createRefreshMsg().name(reqMsg.name()).serviceId(reqMsg.serviceId()).solicited(true).
state(OmmState.StreamState.OPEN, OmmState.DataState.OK, OmmState.StatusCode.NONE, "Refresh Completed").
payload(fieldList).complete(true),
event.handle() );
itemHandle = event.handle();
}
void processInvalidItemRequest(ReqMsg reqMsg, OmmProviderEvent event)
{
event.provider().submit( EmaFactory.createStatusMsg().name(reqMsg.name()).serviceName(reqMsg.serviceName()).
state(OmmState.StreamState.CLOSED, OmmState.DataState.SUSPECT, OmmState.StatusCode.NOT_FOUND, "Item not found"),
event.handle() );
}
}
public class IProvider
{
public static void main(String[] args)
{
OmmProvider provider = null;
try
{
AppClient appClient = new AppClient();
FieldList fieldList = EmaFactory.createFieldList();
OmmIProviderConfig config = EmaFactory.createOmmIProviderConfig();
provider = EmaFactory.createOmmProvider(config.port("14002"), appClient);
while( appClient.itemHandle == 0 ) Thread.sleep(1000);
for( int i = 0; i < 60; i++ )
{
fieldList.clear();
fieldList.add(EmaFactory.createFieldEntry().real(22, 3991 + i, OmmReal.MagnitudeType.EXPONENT_NEG_2));
fieldList.add(EmaFactory.createFieldEntry().real(30, 10 + i, OmmReal.MagnitudeType.EXPONENT_0));
provider.submit( EmaFactory.createUpdateMsg().payload( fieldList ), appClient.itemHandle );
Thread.sleep(1000);
}
}
catch (InterruptedException | OmmException excp)
{
System.out.println(excp.getMessage());
}
finally
{
if (provider != null) provider.uninitialize();
}
}
}