Package com.opengamma.bbg.model

Examples of com.opengamma.bbg.model.SecurityMasterRequestMessage.toFudgeMsg()

102
103
104
105
106
107
108
109
110
111
112
    RemoteSecurityMasterReceiver receiver = new RemoteSecurityMasterReceiver();
    s_logger.debug("sending getSecurities for {} to remote securityMaster", secKey);
    SecurityMasterRequestMessage requestMessage = new SecurityMasterRequestMessage();
    requestMessage.setMessageType(MessageType.GET_SECURITIES_BY_KEY);
    requestMessage.setSecKey(secKey);
    FudgeMsg fudgeMsg = requestMessage.toFudgeMsg(new FudgeSerializer(_fudgeContext));
    _byteArrayRequestSender.sendRequest(_fudgeContext.toByteArray(fudgeMsg), receiver);
    try {
      receiver.getLatch().await();
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
    RemoteSecurityMasterReceiver receiver = new RemoteSecurityMasterReceiver();
    s_logger.debug("sending getSecurity for {} to remote securityMaster", secKey);
    SecurityMasterRequestMessage requestMessage = new SecurityMasterRequestMessage();
    requestMessage.setMessageType(MessageType.GET_SECURITY_BY_KEY);
    requestMessage.setSecKey(secKey);
    FudgeMsg fudgeMsg = requestMessage.toFudgeMsg(new FudgeSerializer(_fudgeContext));
    _byteArrayRequestSender.sendRequest(_fudgeContext.toByteArray(fudgeMsg), receiver);
    try {
      receiver.getLatch().await();
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
    RemoteSecurityMasterReceiver receiver = new RemoteSecurityMasterReceiver();
    s_logger.debug("sending getSecurity for {} to remote securityMaster", uid);
    SecurityMasterRequestMessage requestMessage = new SecurityMasterRequestMessage();
    requestMessage.setMessageType(MessageType.GET_SECURITY_BY_IDENTITY);
    requestMessage.setUniqueId(uid);
    FudgeMsg fudgeMsg = requestMessage.toFudgeMsg(new FudgeSerializer(_fudgeContext));
    _byteArrayRequestSender.sendRequest(_fudgeContext.toByteArray(fudgeMsg), receiver);
    try {
      receiver.getLatch().await();
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
    RemoteSecurityMasterReceiver receiver = new RemoteSecurityMasterReceiver();
    s_logger.debug("sending getSecurity for {} to remote securityMaster", identifier);
    SecurityMasterRequestMessage requestMessage = new SecurityMasterRequestMessage();
    requestMessage.setMessageType(MessageType.GET_OPTION_CHAIN);
    requestMessage.setSecKey(ExternalIdBundle.of(identifier));
    FudgeMsg fudgeMsg = requestMessage.toFudgeMsg(new FudgeSerializer(_fudgeContext));
    _byteArrayRequestSender.sendRequest(_fudgeContext.toByteArray(fudgeMsg), receiver);
    try {
      receiver.getLatch().await();
    } catch (InterruptedException e) {
      Thread.currentThread().interrupt();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.