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

WriteArgs.clear介绍

[英]Clears UPA Write Arguments.
[中]清除UPA写入参数。

代码示例

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

/**
   * Clears this object for reuse.
   */
  public void clear()
  {
    _writeArgs.clear();
    _serviceName = null;
    _requestMsgOptions.clear();
  }
}

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

void write(TransportBuffer writeBuffer)
{
  _writeArgs.clear();
  _writeArgs.flags(WriteFlags.DIRECT_SOCKET_WRITE);
  assertEquals(TransportReturnCodes.SUCCESS, _channel.write(writeBuffer, _writeArgs, _error));
}

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

private void write(TransportBuffer msgBuf)
{
  // write data to the channel
  _writeArgs.clear();
  _writeArgs.priority(WritePriorities.HIGH);
  _writeArgs.flags(WriteFlags.DIRECT_SOCKET_WRITE);
  int ret = _channel.write(msgBuf, _writeArgs, _error);
  while (ret > TransportReturnCodes.SUCCESS)
  {
    // Need to flush
    ret = _channel.flush(_error);
  }
  
  if(ret < TransportReturnCodes.SUCCESS)
  {
    switch(ret)
    {
      case TransportReturnCodes.NO_BUFFERS:
        _channel.flush(_error);
        break;
      default:
        if (!Thread.interrupted())
        {
          closeChannelAndShutDown("Failure while writing message bursts: " + _error.text());
        }
        break;
    }
  }
}

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

_writeArgs.clear();
_writeArgs.priority(WritePriorities.HIGH);
_writeArgs.flags(writeFlags);

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

_writeArgs.clear();
ret = channel.write(tBuffer, _writeArgs, error);

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

System.out.println("[Packing] availableRemaining at end of packing:" + availableRemaining);
_writeArgs.clear();

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

_writeArgs.clear();
_writeArgs.priority(_priority);

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

_writeArgs.clear();
_writeArgs.priority(_priority);

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

writeArgs.clear();
writeArgs.priority(WritePriorities.HIGH);
writeArgs.flags(WriteFlags.DIRECT_SOCKET_WRITE);

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

_writeArgs.clear();
_writeArgs.priority(_priority);
retVal = _channel.write(msgBuf, _writeArgs, _error);

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

_writeArgs.clear();
_writeArgs.priority(WritePriorities.HIGH);
_writeArgs.flags(WriteFlags.DIRECT_SOCKET_WRITE);
_submitOptions.writeArgs().clear();
_submitOptions.writeArgs().priority(WritePriorities.HIGH);
_submitOptions.writeArgs().flags(WriteFlags.DIRECT_SOCKET_WRITE);

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

_writeArgs.clear();
_writeArgs.priority(WritePriorities.HIGH);
_writeArgs.flags(WriteFlags.DIRECT_SOCKET_WRITE);

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

/**
 * Instantiates a new provider thread.
 *
 * @param xmlMsgData the xml msg data
 */
public ProviderThread(XmlMsgData xmlMsgData)
{
  super("ProviderThread");
  _refreshMsgCount = new CountStat();
  _updateMsgCount = new CountStat();
  _itemRequestCount = new CountStat();
  _closeMsgCount = new CountStat();
  _postMsgCount = new CountStat();
  _outOfBuffersCount = new CountStat();
  _msgSentCount = new CountStat();
  _bufferSentCount = new CountStat();
  _writeArgs = TransportFactory.createWriteArgs();
  _xmlMsgData  = xmlMsgData;
  _itemEncoder = new ItemEncoder(xmlMsgData);
  _updateLatencyRandomArray = new LatencyRandomArray();
  _genMsgLatencyRandomArray = new LatencyRandomArray();
  _randomArrayOpts = new LatencyRandomArrayOptions();
  _error = TransportFactory.createError();
  _provThreadInfo = new ProviderThreadInfo(); 
  _submitOptions = ReactorFactory.createReactorSubmitOptions();
  _submitOptions.writeArgs().clear();
  _submitOptions.writeArgs().priority(WritePriorities.HIGH);
  _submitOptions.writeArgs().flags(ProviderPerfConfig.directWrite() ? WriteFlags.DIRECT_SOCKET_WRITE : 0);
  _errorInfo = ReactorFactory.createReactorErrorInfo();
}

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

_writeArgs.clear();
_writeArgs.priority(WritePriorities.HIGH);
_writeArgs.flags(ProviderPerfConfig.directWrite() ? WriteFlags.DIRECT_SOCKET_WRITE : 0);