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

KeyValue.put介绍

[英]Inserts or replaces double value for the specified key.
[中]插入或替换指定键的双精度值。

代码示例

代码示例来源：origin: apache/rocketmq

@Override
public Message putUserHeaders(String key, String value) {
  userHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putSysHeaders(String key, long value) {
  sysHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putSysHeaders(String key, String value) {
  sysHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putSysHeaders(String key, double value) {
  sysHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putUserHeaders(String key, int value) {
  userHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putSysHeaders(String key, int value) {
  sysHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putUserHeaders(String key, long value) {
  userHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
public Message putUserHeaders(String key, double value) {
  userHeaders.put(key, value);
  return this;
}

代码示例来源：origin: apache/rocketmq

@Override
  public void ack() {
    sync.countDown();
    contextProperties.put(NonStandardKeys.MESSAGE_CONSUME_STATUS,
      ConsumeConcurrentlyStatus.CONSUME_SUCCESS.name());
  }
};

代码示例来源：origin: apache/rocketmq

public static KeyValue buildKeyValue(KeyValue... keyValues) {
  KeyValue keyValue = OMS.newKeyValue();
  for (KeyValue properties : keyValues) {
    for (String key : properties.keySet()) {
      keyValue.put(key, properties.getString(key));
    }
  }
  return keyValue;
}

代码示例来源：origin: apache/rocketmq

@Override
  public BytesMessage createBytesMessage(String queue, byte[] body) {
    BytesMessage message = new BytesMessageImpl();
    message.setBody(body);
    message.sysHeaders().put(Message.BuiltinKeys.DESTINATION, queue);
    return message;
  }
}

代码示例来源：origin: apache/rocketmq

public static void main(String[] args) {
    final MessagingAccessPoint messagingAccessPoint = OMS
      .getMessagingAccessPoint("oms:rocketmq://localhost:9876/default:default");

    final PushConsumer consumer = messagingAccessPoint.
      createPushConsumer(OMS.newKeyValue().put(OMSBuiltinKeys.CONSUMER_ID, "OMS_CONSUMER"));

    messagingAccessPoint.startup();
    System.out.printf("MessagingAccessPoint startup OK%n");

    Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
      @Override
      public void run() {
        consumer.shutdown();
        messagingAccessPoint.shutdown();
      }
    }));

    consumer.attachQueue("OMS_HELLO_TOPIC", new MessageListener() {
      @Override
      public void onReceived(Message message, Context context) {
        System.out.printf("Received one message: %s%n", message.sysHeaders().getString(Message.BuiltinKeys.MESSAGE_ID));
        context.ack();
      }
    });

    consumer.startup();
    System.out.printf("Consumer startup OK%n");
  }
}

代码示例来源：origin: apache/rocketmq

@Override
public void onSuccess(final org.apache.rocketmq.client.producer.SendResult rmqResult) {
  message.sysHeaders().put(Message.BuiltinKeys.MESSAGE_ID, rmqResult.getMsgId());
  promise.set(OMSUtil.sendResultConvert(rmqResult));
}

代码示例来源：origin: apache/rocketmq

final CountDownLatch sync = new CountDownLatch(1);
contextProperties.put(NonStandardKeys.MESSAGE_CONSUME_STATUS, ConsumeConcurrentlyStatus.RECONSUME_LATER.name());

代码示例来源：origin: apache/rocketmq

public static BytesMessage msgConvert(org.apache.rocketmq.common.message.MessageExt rmqMsg) {
  BytesMessage omsMsg = new BytesMessageImpl();
  omsMsg.setBody(rmqMsg.getBody());
  KeyValue headers = omsMsg.sysHeaders();
  KeyValue properties = omsMsg.userHeaders();
  final Set<Map.Entry<String, String>> entries = rmqMsg.getProperties().entrySet();
  for (final Map.Entry<String, String> entry : entries) {
    if (isOMSHeader(entry.getKey())) {
      headers.put(entry.getKey(), entry.getValue());
    } else {
      properties.put(entry.getKey(), entry.getValue());
    }
  }
  omsMsg.putSysHeaders(BuiltinKeys.MESSAGE_ID, rmqMsg.getMsgId());
  omsMsg.putSysHeaders(BuiltinKeys.DESTINATION, rmqMsg.getTopic());
  omsMsg.putSysHeaders(BuiltinKeys.SEARCH_KEYS, rmqMsg.getKeys());
  omsMsg.putSysHeaders(BuiltinKeys.BORN_HOST, String.valueOf(rmqMsg.getBornHost()));
  omsMsg.putSysHeaders(BuiltinKeys.BORN_TIMESTAMP, rmqMsg.getBornTimestamp());
  omsMsg.putSysHeaders(BuiltinKeys.STORE_HOST, String.valueOf(rmqMsg.getStoreHost()));
  omsMsg.putSysHeaders(BuiltinKeys.STORE_TIMESTAMP, rmqMsg.getStoreTimestamp());
  return omsMsg;
}

代码示例来源：origin: apache/rocketmq

AbstractOMSProducer(final KeyValue properties) {
  this.properties = properties;
  this.rocketmqProducer = new DefaultMQProducer();
  this.clientConfig = BeanUtils.populate(properties, ClientConfig.class);
  if ("true".equalsIgnoreCase(System.getenv("OMS_RMQ_DIRECT_NAME_SRV"))) {
    String accessPoints = clientConfig.getAccessPoints();
    if (accessPoints == null || accessPoints.isEmpty()) {
      throw new OMSRuntimeException("-1", "OMS AccessPoints is null or empty.");
    }
    this.rocketmqProducer.setNamesrvAddr(accessPoints.replace(',', ';'));
  }
  this.rocketmqProducer.setProducerGroup(clientConfig.getRmqProducerGroup());
  String producerId = buildInstanceName();
  this.rocketmqProducer.setSendMsgTimeout(clientConfig.getOperationTimeout());
  this.rocketmqProducer.setInstanceName(producerId);
  this.rocketmqProducer.setMaxMessageSize(1024 * 1024 * 4);
  this.rocketmqProducer.setLanguage(LanguageCode.OMS);
  properties.put(OMSBuiltinKeys.PRODUCER_ID, producerId);
}

代码示例来源：origin: apache/rocketmq

public PullConsumerImpl(final KeyValue properties) {
  this.properties = properties;
  this.clientConfig = BeanUtils.populate(properties, ClientConfig.class);
  String consumerGroup = clientConfig.getConsumerId();
  if (null == consumerGroup || consumerGroup.isEmpty()) {
    throw new OMSRuntimeException("-1", "Consumer Group is necessary for RocketMQ, please set it.");
  }
  pullConsumerScheduleService = new MQPullConsumerScheduleService(consumerGroup);
  this.rocketmqPullConsumer = pullConsumerScheduleService.getDefaultMQPullConsumer();
  if ("true".equalsIgnoreCase(System.getenv("OMS_RMQ_DIRECT_NAME_SRV"))) {
    String accessPoints = clientConfig.getAccessPoints();
    if (accessPoints == null || accessPoints.isEmpty()) {
      throw new OMSRuntimeException("-1", "OMS AccessPoints is null or empty.");
    }
    this.rocketmqPullConsumer.setNamesrvAddr(accessPoints.replace(',', ';'));
  }
  this.rocketmqPullConsumer.setConsumerGroup(consumerGroup);
  int maxReDeliveryTimes = clientConfig.getRmqMaxRedeliveryTimes();
  this.rocketmqPullConsumer.setMaxReconsumeTimes(maxReDeliveryTimes);
  String consumerId = OMSUtil.buildInstanceName();
  this.rocketmqPullConsumer.setInstanceName(consumerId);
  properties.put(OMSBuiltinKeys.CONSUMER_ID, consumerId);
  this.rocketmqPullConsumer.setLanguage(LanguageCode.OMS);
  this.localMessageCache = new LocalMessageCache(this.rocketmqPullConsumer, clientConfig);
}

代码示例来源：origin: apache/rocketmq

OMS.newKeyValue().put(OMSBuiltinKeys.CONSUMER_ID, "OMS_CONSUMER"));

代码示例来源：origin: apache/rocketmq

private SendResult send(final Message message, long timeout) {
  checkMessageType(message);
  org.apache.rocketmq.common.message.Message rmqMessage = msgConvert((BytesMessage) message);
  try {
    org.apache.rocketmq.client.producer.SendResult rmqResult = this.rocketmqProducer.send(rmqMessage, timeout);
    if (!rmqResult.getSendStatus().equals(SendStatus.SEND_OK)) {
      log.error(String.format("Send message to RocketMQ failed, %s", message));
      throw new OMSRuntimeException("-1", "Send message to RocketMQ broker failed.");
    }
    message.sysHeaders().put(Message.BuiltinKeys.MESSAGE_ID, rmqResult.getMsgId());
    return OMSUtil.sendResultConvert(rmqResult);
  } catch (Exception e) {
    log.error(String.format("Send message to RocketMQ failed, %s", message), e);
    throw checkProducerException(rmqMessage.getTopic(), message.sysHeaders().getString(Message.BuiltinKeys.MESSAGE_ID), e);
  }
}

代码示例来源：origin: apache/rocketmq

public PushConsumerImpl(final KeyValue properties) {
  this.rocketmqPushConsumer = new DefaultMQPushConsumer();
  this.properties = properties;
  this.clientConfig = BeanUtils.populate(properties, ClientConfig.class);
  if ("true".equalsIgnoreCase(System.getenv("OMS_RMQ_DIRECT_NAME_SRV"))) {
    String accessPoints = clientConfig.getAccessPoints();
    if (accessPoints == null || accessPoints.isEmpty()) {
      throw new OMSRuntimeException("-1", "OMS AccessPoints is null or empty.");
    }
    this.rocketmqPushConsumer.setNamesrvAddr(accessPoints.replace(',', ';'));
  }
  String consumerGroup = clientConfig.getConsumerId();
  if (null == consumerGroup || consumerGroup.isEmpty()) {
    throw new OMSRuntimeException("-1", "Consumer Group is necessary for RocketMQ, please set it.");
  }
  this.rocketmqPushConsumer.setConsumerGroup(consumerGroup);
  this.rocketmqPushConsumer.setMaxReconsumeTimes(clientConfig.getRmqMaxRedeliveryTimes());
  this.rocketmqPushConsumer.setConsumeTimeout(clientConfig.getRmqMessageConsumeTimeout());
  this.rocketmqPushConsumer.setConsumeThreadMax(clientConfig.getRmqMaxConsumeThreadNums());
  this.rocketmqPushConsumer.setConsumeThreadMin(clientConfig.getRmqMinConsumeThreadNums());
  String consumerId = OMSUtil.buildInstanceName();
  this.rocketmqPushConsumer.setInstanceName(consumerId);
  properties.put(OMSBuiltinKeys.CONSUMER_ID, consumerId);
  this.rocketmqPushConsumer.setLanguage(LanguageCode.OMS);
  this.rocketmqPushConsumer.registerMessageListener(new MessageListenerImpl());
}