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

ZooKeeperUpdatingPersistentDirectory.put介绍

暂无

代码示例

代码示例来源：origin: spotify/helios

/**
 * Set the {@link TaskStatus} for the job identified by {@code jobId}.
 */
@Override
public void setTaskStatus(final JobId jobId, final TaskStatus status)
  throws InterruptedException {
 log.debug("setting task status: {}", status);
 taskStatuses.put(jobId.toString(), status.toJsonBytes());
 if (historyWriter != null) {
  try {
   historyWriter.saveHistoryItem(status);
  } catch (Exception e) {
   // Log error here and keep going as saving task history is not critical.
   // This is to prevent bad data in the queue from screwing up the actually important Helios
   // agent operations.
   log.error("Error saving task status {} to ZooKeeper: {}", status, e);
  }
 }
 final TaskStatusEvent event = new TaskStatusEvent(status, System.currentTimeMillis(), agent);
 final byte[] message = event.toJsonBytes();
 for (final EventSender sender : eventSenders) {
  sender.send(taskStatusEventTopic, message);
 }
}

代码示例来源：origin: at.molindo/helios-services

/**
 * Set the {@link TaskStatus} for the job identified by {@code jobId}.
 */
@Override
public void setTaskStatus(final JobId jobId, final TaskStatus status)
  throws InterruptedException {
 log.debug("setting task status: {}", status);
 taskStatuses.put(jobId.toString(), status.toJsonBytes());
 try {
  historyWriter.saveHistoryItem(status);
 } catch (Exception e) {
  // Log error here and keep going as saving task history is not critical.
  // This is to prevent bad data in the queue from screwing up the actually important Helios
  // agent operations.
  log.error("Error saving task status {} to ZooKeeper: {}", status, e);
 }
 final TaskStatusEvent event = new TaskStatusEvent(status, System.currentTimeMillis(), agent);
 kafkaSender.send(KafkaRecord.of(TaskStatusEvent.KAFKA_TOPIC, event.toJsonBytes()));
}