com.thomsonreuters.upa.codec.Qos.dynamic()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(13.1k)|赞(0)|评价(0)|浏览(100)

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

Qos.dynamic介绍

[英]If true, Qos is dynamic. Used to describe the changeability of the quality of service, typically over the life of a data stream.
[中]如果为true，则Qos是动态的。用于描述服务质量的可变性，通常在数据流的生命周期内。

代码示例

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

/**
 * Instantiates a new directory provider.
 */
public DirectoryProvider()
{
  _directoryRefresh = (DirectoryRefresh)DirectoryMsgFactory.createMsg();
  _directoryRefresh.rdmMsgType(DirectoryMsgType.REFRESH);
  _service = DirectoryMsgFactory.createService();
  _qos = CodecFactory.createQos();
  _directoryRefresh.rdmMsgType(DirectoryMsgType.REFRESH);
  
  _qos.dynamic(false);
  _qos.rate(QosRates.TICK_BY_TICK);
  _qos.timeliness(QosTimeliness.REALTIME);
  
  _encodeIter = CodecFactory.createEncodeIterator();
}

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

chnlInfo.symbolListHandler.qos().dynamic(qos.isDynamic());
chnlInfo.symbolListHandler.qos().rate(qos.rate());
chnlInfo.symbolListHandler.qos().timeliness(qos.timeliness());
chnlInfo.symbolListHandler.qos().dynamic(false);
chnlInfo.symbolListHandler.qos().rate(QosRates.TICK_BY_TICK);
chnlInfo.symbolListHandler.qos().timeliness(QosTimeliness.REALTIME);

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

void decode(com.thomsonreuters.upa.codec.Qos rsslQos)
{
  if (rsslQos != null)
  {
    _dataCode = DataCode.NO_CODE;
    
    _rsslQos.rate(rsslQos.rate());
    _rsslQos.timeliness(rsslQos.timeliness());
    _rsslQos.dynamic(rsslQos.isDynamic());
    _rsslQos.timeInfo(rsslQos.timeInfo());
    _rsslQos.rateInfo(rsslQos.rateInfo());
  }
  else
  {
    _dataCode = DataCode.BLANK;
    
    _rsslQos.clear();
  }
}

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

symbolListHandler.qos().dynamic(qos.isDynamic());
symbolListHandler.qos().rate(qos.rate());
symbolListHandler.qos().timeliness(qos.timeliness());
symbolListHandler.qos().dynamic(false);
symbolListHandler.qos().rate(QosRates.TICK_BY_TICK);
symbolListHandler.qos().timeliness(QosTimeliness.REALTIME);

代码示例来源：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 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

static void toRsslQos(int rate, int timeliness, Qos rsslQos)
{
  rsslQos.dynamic(false);
  if (rate == OmmQos.Rate.TICK_BY_TICK)
    rsslQos.rate(com.thomsonreuters.upa.codec.QosRates.TICK_BY_TICK);
  else if (rate == OmmQos.Rate.JUST_IN_TIME_CONFLATED)
    rsslQos.rate(com.thomsonreuters.upa.codec.QosRates.JIT_CONFLATED);
  else
  {
    if (rate <= 65535)
    {
      rsslQos.rate(com.thomsonreuters.upa.codec.QosRates.TIME_CONFLATED);
      rsslQos.rateInfo(rate);
    } else
      rsslQos.rate(com.thomsonreuters.upa.codec.QosRates.JIT_CONFLATED);
  }
  if (timeliness == OmmQos.Timeliness.REALTIME)
    rsslQos.timeliness(com.thomsonreuters.upa.codec.QosTimeliness.REALTIME);
  else if (timeliness == OmmQos.Timeliness.INEXACT_DELAYED)
    rsslQos.timeliness(com.thomsonreuters.upa.codec.QosTimeliness.DELAYED_UNKNOWN);
  else
  {
    if (timeliness <= 65535)
    {
      rsslQos.timeliness(com.thomsonreuters.upa.codec.QosTimeliness.DELAYED);
      rsslQos.timeInfo(timeliness);
    } else
      rsslQos.timeliness(com.thomsonreuters.upa.codec.QosTimeliness.DELAYED_UNKNOWN);
  }
}

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

private void generateRequest(MarketPriceRequest marketPriceRequest, boolean isPrivateStream, Service srcDirInfo, LoginRefresh loginInfo)
{
  marketPriceRequest.clear();
  if (!snapshotRequested)
    marketPriceRequest.applyStreaming();
  marketPriceRequest.applyHasServiceId();
  marketPriceRequest.serviceId(srcDirInfo.serviceId());
  marketPriceRequest.applyHasPriority();
  marketPriceRequest.priority(1, 1);
  if (srcDirInfo.info().qosList().size() > 0)
  {
    marketPriceRequest.applyHasQos();
    marketPriceRequest.qos().dynamic(false);
    marketPriceRequest.qos().timeInfo(srcDirInfo.info().qosList().get(0).timeInfo());
    marketPriceRequest.qos().timeliness(srcDirInfo.info().qosList().get(0)
        .timeliness());
    marketPriceRequest.qos().rateInfo(srcDirInfo.info().qosList().get(0).rateInfo());
    marketPriceRequest.qos().rate(srcDirInfo.info().qosList().get(0).rate());
  }
  if (isPrivateStream)
    marketPriceRequest.applyPrivateStream();
  if (loginInfo.checkHasFeatures() && 
    loginInfo.features().checkHasSupportViewRequests() && 
    loginInfo.features().supportViewRequests() == 1 &&
    viewRequested)
  {
    marketPriceRequest.applyHasView();
    marketPriceRequest.viewFields().addAll(viewFieldList);
  }
}

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

private void generateRequest(MarketPriceRequest marketPriceRequest, boolean isPrivateStream,
    Service srcDirInfo, LoginRefresh loginInfo)
{
  marketPriceRequest.clear();
  if (!snapshotRequested)
    marketPriceRequest.applyStreaming();
  marketPriceRequest.applyHasServiceId();
  marketPriceRequest.serviceId(srcDirInfo.serviceId());
  marketPriceRequest.applyHasPriority();
  marketPriceRequest.priority(1, 1);
  if (srcDirInfo.info().qosList().size() > 0)
  {
    marketPriceRequest.applyHasQos();
    marketPriceRequest.qos().dynamic(false);
    marketPriceRequest.qos().timeInfo(srcDirInfo.info().qosList().get(0).timeInfo());
    marketPriceRequest.qos().timeliness(srcDirInfo.info().qosList().get(0).timeliness());
    marketPriceRequest.qos().rateInfo(srcDirInfo.info().qosList().get(0).rateInfo());
    marketPriceRequest.qos().rate(srcDirInfo.info().qosList().get(0).rate());
  }
  if (isPrivateStream)
    marketPriceRequest.applyPrivateStream();
  if (loginInfo.checkHasFeatures() && loginInfo.features().checkHasSupportViewRequests()
      && loginInfo.features().supportViewRequests() == 1 && viewRequested)
  {
    marketPriceRequest.applyHasView();
    marketPriceRequest.viewFields().addAll(viewFieldList);
  }
}

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

private void generateRequest(MarketPriceRequest marketPriceRequest, boolean isPrivateStream, Service srcDirInfo, LoginRefresh loginInfo)
{
  marketPriceRequest.clear();
  if (!snapshotRequested)
    marketPriceRequest.applyStreaming();
  marketPriceRequest.applyHasServiceId();
  marketPriceRequest.serviceId(srcDirInfo.serviceId());
  marketPriceRequest.applyHasPriority();
  marketPriceRequest.priority(1, 1);
  if (srcDirInfo.info().qosList().size() > 0)
  {
    marketPriceRequest.applyHasQos();
    marketPriceRequest.qos().dynamic(false);
    marketPriceRequest.qos().timeInfo(srcDirInfo.info().qosList().get(0).timeInfo());
    marketPriceRequest.qos().timeliness(srcDirInfo.info().qosList().get(0)
        .timeliness());
    marketPriceRequest.qos().rateInfo(srcDirInfo.info().qosList().get(0).rateInfo());
    marketPriceRequest.qos().rate(srcDirInfo.info().qosList().get(0).rate());
  }
  if (isPrivateStream)
    marketPriceRequest.applyPrivateStream();
  if (loginInfo.checkHasFeatures() && 
    loginInfo.features().checkHasSupportViewRequests() && 
    loginInfo.features().supportViewRequests() == 1 &&
    viewRequested)
  {
    marketPriceRequest.applyHasView();
    marketPriceRequest.viewFields().addAll(viewFieldList);
  }
}

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

ItemHandler(DictionaryHandler dictionaryHandler, LoginHandler loginHandler)
{
  _marketByOrderItemWatchList = new MarketByOrderCacheItems();
  _marketByPriceItemWatchList = new MarketByPriceCacheItems();
  _marketPriceItemWatchList = new MarketPriceCacheItems();
  _marketPriceStatus = new MarketPriceStatus();
  _symbolListItemWatchList = new SymbolListItems();
  _itemInfoWatchList = new ItemInfoList();
  _itemRequestWatchList = new ItemRequestInfoList();
  _dictionaryHandler = dictionaryHandler;
  _loginHandler = loginHandler;
  _updateMsg.msgClass(MsgClasses.UPDATE);
  _ackMsg.msgClass(MsgClasses.ACK);
  _statusMsg.msgClass(MsgClasses.STATUS);
  _triItemName.data("TRI");
  _privateStreamItemName.data("RES-DS");
  _slNameBuf.data("_UPA_ITEM_LIST");
  _batchReqName.data(":ItemList");
  
  //set Qos for provider
  _providerQos.dynamic(false);
  _providerQos.rate(QosRates.TICK_BY_TICK);
  _providerQos.timeliness(QosTimeliness.REALTIME);
}

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

qos.rateInfo(rateInfo);
qos.timeInfo(timeInfo);
qos.dynamic(false);
qosED((QosImpl)qos);
qos.rateInfo(rateInfo);
qos.timeInfo(timeInfo);
qos.dynamic(true);
qosED((QosImpl)qos);

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

qos.dynamic(true);
qos.rate(QosRates.JIT_CONFLATED);
qos.timeliness(QosTimeliness.DELAYED);

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

_providerQos.dynamic(false);
_providerQos.rate(QosRates.TICK_BY_TICK);
_providerQos.timeliness(QosTimeliness.REALTIME);

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

private void generateRefreshAndUpdate(int serviceId)
{
  //refresh complete
  marketPriceRefresh.applyRefreshComplete();
  //service Id
  marketPriceRefresh.serviceId(serviceId);
  marketPriceRefresh.applyHasServiceId();
  marketPriceUpdate.serviceId(serviceId);
  marketPriceUpdate.applyHasServiceId();
  //QoS
  marketPriceRefresh.qos().dynamic(false);
  marketPriceRefresh.qos().timeliness(QosTimeliness.REALTIME);
  marketPriceRefresh.qos().rate(QosRates.TICK_BY_TICK);
  marketPriceRefresh.applyHasQos();
  //state
  marketPriceRefresh.state().streamState(StreamStates.OPEN);
  marketPriceRefresh.state().dataState(DataStates.OK);
  marketPriceRefresh.state().code(StateCodes.NONE);
  marketPriceRefresh.state().text().data("Item Refresh Completed");
}

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

private void generateRefreshAndUpdate(int serviceId)
{
  //refresh complete
  marketByOrderRefresh.applyRefreshComplete();
  //service Id
  marketByOrderRefresh.serviceId(serviceId);
  marketByOrderRefresh.applyHasServiceId();
  marketByOrderUpdate.serviceId(serviceId);
  marketByOrderUpdate.applyHasServiceId();
  //QoS
  marketByOrderRefresh.qos().dynamic(false);
  marketByOrderRefresh.qos().timeliness(QosTimeliness.REALTIME);
  marketByOrderRefresh.qos().rate(QosRates.TICK_BY_TICK);
  marketByOrderRefresh.applyHasQos();
  //state
  marketByOrderRefresh.state().streamState(StreamStates.OPEN);
  marketByOrderRefresh.state().dataState(DataStates.OK);
  marketByOrderRefresh.state().code(StateCodes.NONE);
  marketByOrderRefresh.state().text().data("Item Refresh Completed");
}

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

private void generateRefreshAndUpdate(Service serviceInfo)
{
  //refresh complete
  marketByOrderRefresh.applyRefreshComplete();
  //service Id
  marketByOrderRefresh.serviceId(serviceInfo.serviceId());
  marketByOrderRefresh.applyHasServiceId();
  marketByOrderUpdate.serviceId(serviceInfo.serviceId());
  marketByOrderUpdate.applyHasServiceId();
  //QoS
  marketByOrderRefresh.qos().dynamic(false);
  marketByOrderRefresh.qos().timeliness(QosTimeliness.REALTIME);
  marketByOrderRefresh.qos().rate(QosRates.TICK_BY_TICK);
  marketByOrderRefresh.applyHasQos();
  //state
  marketByOrderRefresh.state().streamState(StreamStates.OPEN);
  marketByOrderRefresh.state().dataState(DataStates.OK);
  marketByOrderRefresh.state().code(StateCodes.NONE);
  marketByOrderRefresh.state().text().data("Item Refresh Completed");
}

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

private void generateRefreshAndUpdate(Service serviceInfo)
{
  //refresh complete
  marketPriceRefresh.applyRefreshComplete();
  //service Id
  marketPriceRefresh.serviceId(serviceInfo.serviceId());
  marketPriceRefresh.applyHasServiceId();
  marketPriceUpdate.serviceId(serviceInfo.serviceId());
  marketPriceUpdate.applyHasServiceId();
  //QoS
  marketPriceRefresh.qos().dynamic(false);
  marketPriceRefresh.qos().timeliness(QosTimeliness.REALTIME);
  marketPriceRefresh.qos().rate(QosRates.TICK_BY_TICK);
  marketPriceRefresh.applyHasQos();
  //state
  marketPriceRefresh.state().streamState(StreamStates.OPEN);
  marketPriceRefresh.state().dataState(DataStates.OK);
  marketPriceRefresh.state().code(StateCodes.NONE);
  marketPriceRefresh.state().text().data("Item Refresh Completed");
}

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

symbolListRequest.serviceId(serviceId());
symbolListRequest.applyHasServiceId();
symbolListRequest.qos().dynamic(qos.isDynamic());
symbolListRequest.qos().rate(qos.rate());
symbolListRequest.qos().timeliness(qos.timeliness());

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

refreshMsg.qos().dynamic(qos().isDynamic());
refreshMsg.qos().rate(qos().rate());
refreshMsg.qos().timeliness(qos().timeliness());

内容来源于网络，如有侵权，请联系作者删除！

qos

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com