io.openmessaging.KeyValue.getString()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(73)

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

KeyValue.getString介绍

[英]Searches for the String property with the specified key in this KeyValue object. If the key is not found in this property list, null is returned.
[中]在此KeyValue对象中搜索具有指定键的字符串属性。如果在此属性列表中找不到密钥，则返回null。

代码示例

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

@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();
  }
});

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

public static <T> T populate(final KeyValue properties, final T obj) {
    Class<?> clazz = obj.getClass();
    try {

      final Set<String> keySet = properties.keySet();
      for (String key : keySet) {
        String[] keyGroup = key.split("[\\._]");
        for (int i = 0; i < keyGroup.length; i++) {
          keyGroup[i] = keyGroup[i].toLowerCase();
          keyGroup[i] = StringUtils.capitalize(keyGroup[i]);
        }
        String beanFieldNameWithCapitalization = StringUtils.join(keyGroup);
        try {
          setProperties(clazz, obj, "set" + beanFieldNameWithCapitalization, properties.getString(key));
        } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) {
          //ignored...
        }
      }
    } catch (RuntimeException e) {
      log.warn("Error occurs !", e);
    }
    return obj;
  }
}

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

return ConsumeConcurrentlyStatus.valueOf(contextProperties.getString(NonStandardKeys.MESSAGE_CONSUME_STATUS));

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

public static org.apache.rocketmq.common.message.Message msgConvert(BytesMessage omsMessage) {
  org.apache.rocketmq.common.message.Message rmqMessage = new org.apache.rocketmq.common.message.Message();
  rmqMessage.setBody(omsMessage.getBody(byte[].class));
  KeyValue sysHeaders = omsMessage.sysHeaders();
  KeyValue userHeaders = omsMessage.userHeaders();
  //All destinations in RocketMQ use Topic
  rmqMessage.setTopic(sysHeaders.getString(BuiltinKeys.DESTINATION));
  if (sysHeaders.containsKey(BuiltinKeys.START_TIME)) {
    long deliverTime = sysHeaders.getLong(BuiltinKeys.START_TIME, 0);
    if (deliverTime > 0) {
      rmqMessage.putUserProperty(RocketMQConstants.START_DELIVER_TIME, String.valueOf(deliverTime));
    }
  }
  for (String key : userHeaders.keySet()) {
    MessageAccessor.putProperty(rmqMessage, key, userHeaders.getString(key));
  }
  //System headers has a high priority
  for (String key : sysHeaders.keySet()) {
    MessageAccessor.putProperty(rmqMessage, key, sysHeaders.getString(key));
  }
  return rmqMessage;
}

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

Message message = consumer.receive();
if (message != null) {
  String msgId = message.sysHeaders().getString(Message.BuiltinKeys.MESSAGE_ID);
  System.out.printf("Received one message: %s%n", msgId);
  consumer.ack(msgId);

代码示例来源：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: didi/DDMQ

@Override
  public void ack(final KeyValue properties) {
    sync.countDown();
    contextProperties.put(NonStandardKeys.MESSAGE_CONSUME_STATUS,
      properties.getString(NonStandardKeys.MESSAGE_CONSUME_STATUS));
  }
};

代码示例来源：origin: openmessaging/openmessaging-java

private static String parseDriverImpl(String driverType, KeyValue attributes) {
  if (attributes.containsKey(OMSBuiltinKeys.DRIVER_IMPL)) {
    return attributes.getString(OMSBuiltinKeys.DRIVER_IMPL);
  }
  return "io.openmessaging." + driverType + ".MessagingAccessPointImpl";
}

代码示例来源：origin: didi/DDMQ

@Override
  public void onMessage(final Message message, final ReceivedMessageContext context) {
    System.out.printf("Received one message: %s%n", message.headers().getString(MessageHeader.MESSAGE_ID));
    context.ack();
  }
});

代码示例来源：origin: didi/DDMQ

public static <T> T populate(final KeyValue properties, final T obj) {
    Class<?> clazz = obj.getClass();
    try {

      final Set<String> keySet = properties.keySet();
      for (String key : keySet) {
        String[] keyGroup = key.split("\\.");
        for (int i = 0; i < keyGroup.length; i++) {
          keyGroup[i] = keyGroup[i].toLowerCase();
          keyGroup[i] = StringUtils.capitalize(keyGroup[i]);
        }
        String beanFieldNameWithCapitalization = StringUtils.join(keyGroup);
        try {
          setProperties(clazz, obj, "set" + beanFieldNameWithCapitalization, properties.getString(key));
        } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException ignored) {
          //ignored...
        }
      }
    } catch (RuntimeException e) {
      log.warn("Error occurs !", e);
    }
    return obj;
  }
}

代码示例来源：origin: didi/DDMQ

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: didi/DDMQ

Message message = consumer.poll();
if (message != null) {
  String msgId = message.headers().getString(MessageHeader.MESSAGE_ID);
  System.out.printf("Received one message: %s%n", msgId);
  consumer.ack(msgId);

代码示例来源：origin: didi/DDMQ

@Override
public void send(final Message message) {
  checkMessageType(message);
  org.apache.rocketmq.common.message.Message rmqMessage = OMSUtil.msgConvert((BytesMessage) message);
  try {
    Validators.checkMessage(rmqMessage, this.rocketmqProducer);
  } catch (MQClientException e) {
    throw checkProducerException(rmqMessage.getTopic(), message.headers().getString(MessageHeader.MESSAGE_ID), e);
  }
  msgCacheQueue.add(message);
}

代码示例来源：origin: didi/DDMQ

public static org.apache.rocketmq.common.message.Message msgConvert(BytesMessage omsMessage) {
  org.apache.rocketmq.common.message.Message rmqMessage = new org.apache.rocketmq.common.message.Message();
  rmqMessage.setBody(omsMessage.getBody());
  KeyValue headers = omsMessage.headers();
  KeyValue properties = omsMessage.properties();
  //All destinations in RocketMQ use Topic
  if (headers.containsKey(MessageHeader.TOPIC)) {
    rmqMessage.setTopic(headers.getString(MessageHeader.TOPIC));
    rmqMessage.putUserProperty(NonStandardKeys.MESSAGE_DESTINATION, "TOPIC");
  } else {
    rmqMessage.setTopic(headers.getString(MessageHeader.QUEUE));
    rmqMessage.putUserProperty(NonStandardKeys.MESSAGE_DESTINATION, "QUEUE");
  }
  for (String key : properties.keySet()) {
    MessageAccessor.putProperty(rmqMessage, key, properties.getString(key));
  }
  //Headers has a high priority
  for (String key : headers.keySet()) {
    MessageAccessor.putProperty(rmqMessage, key, headers.getString(key));
  }
  return rmqMessage;
}

代码示例来源：origin: didi/DDMQ

return ConsumeConcurrentlyStatus.valueOf(contextProperties.getString(NonStandardKeys.MESSAGE_CONSUME_STATUS));

代码示例来源：origin: didi/DDMQ

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.headers().put(MessageHeader.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.headers().getString(MessageHeader.MESSAGE_ID), e);
  }
}

代码示例来源：origin: com.aliyun.relay/relay-sdk

@Override
public void publish(final Object service, final KeyValue keyValue) {
  Properties properties = new Properties();
  for (String key : keyValue.keySet()) {
    properties.setProperty(key, keyValue.getString(key));
  }
  serviceProvider.publish(service, properties);
}

代码示例来源：origin: com.aliyun.relay/relay-sdk

@Override
public <T> T bind(final Class<T> type, final KeyValue keyValue, final ServiceLoadBalance serviceLoadBalance) {
  Properties properties = new Properties();
  for (String key : keyValue.keySet()) {
    properties.setProperty(key, keyValue.getString(key));
  }
  return serviceConsumer.bind(type, properties, serviceLoadBalance);
}

代码示例来源：origin: jiangxinlingdu/rocketmq-all-4.1.0-incubating

@Override
public void send(final Message message) {
  checkMessageType(message);
  org.apache.rocketmq.common.message.Message rmqMessage = OMSUtil.msgConvert((BytesMessage) message);
  try {
    Validators.checkMessage(rmqMessage, this.rocketmqProducer);
  } catch (MQClientException e) {
    throw checkProducerException(rmqMessage.getTopic(), message.headers().getString(MessageHeader.MESSAGE_ID), e);
  }
  msgCacheQueue.add(message);
}

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

KeyValue

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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