本文整理了Java中com.thomsonreuters.upa.codec.Qos.decode
方法的一些代码示例,展示了Qos.decode
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Qos.decode
方法的具体详情如下:
包路径:com.thomsonreuters.upa.codec.Qos
类名称:Qos
方法名:decode
[英]Decode Qos.
[中]解码Qos。
代码示例来源:origin: Refinitiv/Elektron-SDK
@Override
void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
{
_rsslBuffer = rsslBuffer;
if (com.thomsonreuters.upa.codec.CodecReturnCodes.SUCCESS == _rsslQos.decode(dIter))
_dataCode = DataCode.NO_CODE;
else
{
_dataCode = DataCode.BLANK;
_rsslQos.clear();
}
}
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = fidQosValue.decode(dIter);
if (ret == CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
if ((retVal = qos.decode(decIter)) < CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
retval = qoS.decode(dIter);
if (retval != CodecReturnCodes.SUCCESS && retval != CodecReturnCodes.BLANK_DATA)
代码示例来源:origin: Refinitiv/Elektron-SDK
retval = qoS.decode(dIter);
if (retval != CodecReturnCodes.SUCCESS && retval != CodecReturnCodes.BLANK_DATA)
代码示例来源:origin: Refinitiv/Elektron-SDK
retval =qoS.decode(dIter);
if (retval != CodecReturnCodes.SUCCESS && retval != CodecReturnCodes.BLANK_DATA)
代码示例来源:origin: Refinitiv/Elektron-SDK
break;
case DataTypes.QOS:
if ((ret = _fidQosValue.decode(iter)) < CodecReturnCodes.SUCCESS)
return ret;
break;
代码示例来源:origin: Refinitiv/Elektron-SDK
break;
case DataTypes.QOS:
if ((ret = _fidQosValue.decode(iter)) < CodecReturnCodes.SUCCESS)
return ret;
break;
代码示例来源:origin: Refinitiv/Elektron-SDK
private void qosED(QosImpl qos)
{
_encIter.clear();
_buffer.data(ByteBuffer.allocate(15));
_encIter.setBufferAndRWFVersion(_buffer, Codec.majorVersion(), Codec.minorVersion());
qos.encode(_encIter);
_decIter.clear();
_decIter.setBufferAndRWFVersion(_buffer, Codec.majorVersion(), Codec.minorVersion());
Qos qos1 = CodecFactory.createQos();
qos1.decode(_decIter);
assertEquals(qos.rate(), qos1.rate());
assertEquals(qos.rateInfo(), qos1.rateInfo());
assertEquals(qos.timeInfo(), qos1.timeInfo());
assertEquals(qos.timeliness(), qos1.timeliness());
assertEquals(qos.isDynamic(), qos1.isDynamic());
}
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = qos.decode(dIter);
qosList().add(qos);
if (ret != CodecReturnCodes.SUCCESS
代码示例来源:origin: Refinitiv/Elektron-SDK
ret = tmpQos.decode(_decIter);
if (ret == CodecReturnCodes.SUCCESS)
代码示例来源:origin: Refinitiv/Elektron-SDK
assertEquals(28, fieldEntry.fieldId());
assertEquals(DataTypes.QOS, fieldEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
assertEquals(28, fieldEntry.fieldId());
assertEquals(DataTypes.UNKNOWN, fieldEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
assertTrue(elementEntry.name().toString().equals("28"));
assertEquals(DataTypes.QOS, elementEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
assertTrue(elementEntry.name().toString().equals("28"));
assertEquals(DataTypes.QOS, elementEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, qosVal.decode(dIter));
assertEquals(QosTimeliness.DELAYED, qosVal.timeliness());
assertEquals(3000, qosVal.timeInfo());
内容来源于网络,如有侵权,请联系作者删除!