本文整理了Java中com.thomsonreuters.upa.shared.rdm.yieldcurve.YieldCurveRequest类的一些代码示例，展示了YieldCurveRequest类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YieldCurveRequest类的具体详情如下：
包路径：com.thomsonreuters.upa.shared.rdm.yieldcurve.YieldCurveRequest
类名称：YieldCurveRequest

YieldCurveRequest介绍

[英]The request message for yield curve domain.
[中]屈服曲线域的请求消息。

代码示例

代码示例来源：origin: Refinitiv/Elektron-SDK

private int sendRequest(ChannelSession chnl, List<String> itemNames, Error error)
{
  int ret = CodecReturnCodes.SUCCESS;
  for (String itemName : itemNames)
  {
    Integer streamId = watchList.add(domainType, itemName, yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().clear();
    yieldCurveRequest.itemNames().add(itemName);
    yieldCurveRequest.streamId(streamId);
    ret = encodeAndSendRequest(chnl, yieldCurveRequest, error);
    if (ret < CodecReturnCodes.SUCCESS)
      return ret;
  }
  return CodecReturnCodes.SUCCESS;
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private YieldCurveRequest createYieldCurveRequest()
{
  return new YieldCurveRequest();
}

代码示例来源：origin: Refinitiv/Elektron-SDK

stringBuf.append(tabChar);
stringBuf.append("streaming: ");
stringBuf.append(checkStreaming());
stringBuf.append(eolChar);
stringBuf.append(checkPrivateStream());
stringBuf.append(eolChar);
stringBuf.append(checkHasView());
stringBuf.append(eolChar);
stringBuf.append(itemNames());
stringBuf.append(eolChar);
if (checkHasServiceId())
  stringBuf.append(serviceId());
  stringBuf.append(eolChar);
if (checkHasPriority())
  stringBuf.append(priorityClass());
  stringBuf.append(", priority count: ");
  stringBuf.append(priorityCount());
  stringBuf.append(eolChar);
if (checkHasQos())

代码示例来源：origin: Refinitiv/Elektron-SDK

private void generateRequest(YieldCurveRequest yieldCurveRequest,
    boolean isPrivateStream, Service srcDirInfo, LoginRefresh loginInfo)
{
  yieldCurveRequest.clear();
  if (!snapshotRequested)
    yieldCurveRequest.applyStreaming();
  yieldCurveRequest.applyHasServiceId();
  yieldCurveRequest.serviceId(srcDirInfo.serviceId());
  yieldCurveRequest.applyHasPriority();
  yieldCurveRequest.priority(1, 1);
  yieldCurveRequest.applyHasQos();
  yieldCurveRequest.qos().dynamic(false);
  yieldCurveRequest.qos().timeInfo(srcDirInfo.info().qosList().get(0).timeInfo());
  yieldCurveRequest.qos().timeliness(srcDirInfo.info().qosList().get(0).timeliness());
  yieldCurveRequest.qos().rateInfo(srcDirInfo.info().qosList().get(0).rateInfo());
  yieldCurveRequest.qos().rate(srcDirInfo.info().qosList().get(0).rate());
  if (isPrivateStream)
    yieldCurveRequest.applyPrivateStream();
}

代码示例来源：origin: Refinitiv/Elektron-SDK

requestMsg.streamId(streamId());
requestMsg.domainType(domainType);
requestMsg.containerType(DataTypes.NO_DATA);
if (checkHasQos())
if (checkHasPriority())
  requestMsg.priority().priorityClass(priorityClass());
  requestMsg.priority().count(priorityCount());
if (checkStreaming())
applyFeatureFlags(isBatchRequest);
requestMsg.msgKey().serviceId(serviceId());
if (checkHasView() || isBatchRequest)
  ret = encodeRequestPayload(isBatchRequest, encodeIter);
  if (ret < CodecReturnCodes.SUCCESS)
    return ret;

代码示例来源：origin: Refinitiv/Elektron-SDK

private int redirectToPrivateStream(int streamId, ReactorErrorInfo errorInfo)
{
  WatchListEntry wle = watchList.get(streamId);
  /* remove non-private stream entry from list */
  removeYieldCurveItemEntry(streamId);
  /* add item name to private stream list */
  Integer psStreamId = watchList.add(domainType, wle.itemName, true);
  generateRequest(yieldCurveRequest, true, redirectSrcDirInfo, redirectLoginInfo);
  yieldCurveRequest.itemNames().add(wle.itemName);
  yieldCurveRequest.streamId(psStreamId);
  return encodeAndSendRequest(redirectChnl, yieldCurveRequest, errorInfo);
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private void applyFeatureFlags(boolean isBatchRequest)
{
  if (checkPrivateStream())
  {
    requestMsg.applyPrivateStream();
  }
  if (checkHasView() || isBatchRequest)
  {
    requestMsg.containerType(DataTypes.ELEMENT_LIST);
    if (checkHasView())
    {
      requestMsg.applyHasView();
    }
    if (isBatchRequest)
    {
      requestMsg.applyHasBatch();
    }
  }
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private void generateRequest(YieldCurveRequest yieldCurveRequest,
    boolean isPrivateStream, Service srcDirInfo, LoginRefresh loginInfo)
{
  yieldCurveRequest.clear();
  if (!snapshotRequested)
    yieldCurveRequest.applyStreaming();
  yieldCurveRequest.applyHasServiceId();
  yieldCurveRequest.serviceId(srcDirInfo.serviceId());
  yieldCurveRequest.applyHasPriority();
  yieldCurveRequest.priority(1, 1);
  yieldCurveRequest.applyHasQos();
  yieldCurveRequest.qos().dynamic(false);
  yieldCurveRequest.qos().timeInfo(srcDirInfo.info().qosList().get(0).timeInfo());
  yieldCurveRequest.qos().timeliness(srcDirInfo.info().qosList().get(0).timeliness());
  yieldCurveRequest.qos().rateInfo(srcDirInfo.info().qosList().get(0).rateInfo());
  yieldCurveRequest.qos().rate(srcDirInfo.info().qosList().get(0).rate());
  if (isPrivateStream)
    yieldCurveRequest.applyPrivateStream();
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private int redirectToPrivateStream(int streamId, com.thomsonreuters.upa.transport.Error error)
  {
    WatchListEntry wle = watchList.get(streamId);

    /* remove non-private stream entry from list */
    removeYieldCurveItemEntry(streamId);

    /* add item name to private stream list */
    Integer psStreamId = watchList.add(domainType, wle.itemName, true);

    generateRequest(yieldCurveRequest, true, redirectSrcDirInfo, redirectLoginInfo);
    yieldCurveRequest.itemNames().add(wle.itemName);
    yieldCurveRequest.streamId(psStreamId);
    return encodeAndSendRequest(redirectChnl, yieldCurveRequest, error);
  }
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private int sendRequest(ReactorChannel chnl, List<String> itemNames, ReactorErrorInfo errorInfo)
{
  int ret = CodecReturnCodes.SUCCESS;
  for (String itemName : itemNames)
  {
    Integer streamId = watchList.add(domainType, itemName, yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().clear();
    yieldCurveRequest.itemNames().add(itemName);
    yieldCurveRequest.streamId(streamId);
    ret = encodeAndSendRequest(chnl, yieldCurveRequest, errorInfo);
    if (ret < CodecReturnCodes.SUCCESS)
      return ret;
  }
  return CodecReturnCodes.SUCCESS;
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private YieldCurveRequest createYieldCurveRequest()
{
  return new YieldCurveRequest();
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private int sendBatchRequest(ReactorChannel chnl, List<String> itemNames, ReactorErrorInfo errorInfo)
{
  int batchStreamId = watchList.add(domainType, "BATCH_" + new Date(),
      yieldCurveRequest.checkPrivateStream());
  yieldCurveRequest.streamId(batchStreamId);
  for (String itemName : itemNames)
  {
    watchList.add(domainType, itemName,    yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().add(itemName);
  }
  return encodeAndSendRequest(chnl, yieldCurveRequest, errorInfo);
}

代码示例来源：origin: Refinitiv/Elektron-SDK

private int sendBatchRequest(ChannelSession chnl, List<String> itemNames, Error error)
{
  int batchStreamId = watchList.add(domainType, "BATCH_" + new Date(),
      yieldCurveRequest.checkPrivateStream());
  yieldCurveRequest.streamId(batchStreamId);
  for (String itemName : itemNames)
  {
    watchList.add(domainType, itemName,    yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().add(itemName);
  }
  return encodeAndSendRequest(chnl, yieldCurveRequest, error);
}