org.apache.qpid.proton.message.Message.getReplyTo()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(11.6k)|赞(0)|评价(0)|浏览(175)

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

Message.getReplyTo介绍

暂无

代码示例

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Adds a property for the address that responses to
  3.  * this (request) message should be sent.
  4.  * <p>
  5.  * The property will only be added if the AMQP message contains
  6.  * a non-{@code null} <em>reply-to</em> property.
  7.  * 
  8.  * @param msg The AMQP message to retrieve the value from.
  9.  * @return This message for chaining.
  10.  */
  11. public EventBusMessage setReplyToAddress(final Message msg) {
  12.   setReplyToAddress(msg.getReplyTo());
  13.   return this;
  14. }

代码示例来源：origin: Azure/azure-event-hubs-java

  1. if (amqpMessage.getSubject() != null)
  2.   receiveProperties.put(AmqpConstants.AMQP_PROPERTY_SUBJECT, amqpMessage.getSubject());
  3. if (amqpMessage.getReplyTo() != null)
  4.   receiveProperties.put(AmqpConstants.AMQP_PROPERTY_REPLY_TO, amqpMessage.getReplyTo());
  5. if (amqpMessage.getCorrelationId() != null)
  6.   receiveProperties.put(AmqpConstants.AMQP_PROPERTY_CORRELATION_ID, amqpMessage.getCorrelationId());

代码示例来源：origin: org.eclipse.hono/hono-core

  1. /**
  2.  * Adds a property for the address that responses to
  3.  * this (request) message should be sent.
  4.  * <p>
  5.  * The property will only be added if the AMQP message contains
  6.  * a non-{@code null} <em>reply-to</em> property.
  7.  * 
  8.  * @param msg The AMQP message to retrieve the value from.
  9.  * @return This message for chaining.
  10.  */
  11. public EventBusMessage setReplyToAddress(final Message msg) {
  12.   setReplyToAddress(msg.getReplyTo());
  13.   return this;
  14. }

代码示例来源：origin: org.apache.qpid/proton

  1. private void adjustReplyTo(Message m)
  2. {
  3.   String original = m.getReplyTo();
  4.   if (original == null || original.length() == 0)
  5.   {
  6.     m.setReplyTo("amqp://" + _name);
  7.   }
  8.   else if (original.startsWith("~/"))
  9.   {
  10.     m.setReplyTo("amqp://" + _name + "/" + original.substring(2));
  11.   }
  12. }

代码示例来源：origin: org.apache.qpid/proton-j-impl

  1. private void adjustReplyTo(Message m)
  2. {
  3.   String original = m.getReplyTo();
  4.   if (original != null) {
  5.     if (original.startsWith("~/"))
  6.     {
  7.       m.setReplyTo("amqp://" + _name + "/" + original.substring(2));
  8.     }
  9.     else if (original.equals("~"))
  10.     {
  11.       m.setReplyTo("amqp://" + _name);
  12.     }
  13.   }
  14. }

代码示例来源：origin: com.microsoft.azure.iot/proton-j-azure-iot

  1. private void adjustReplyTo(Message m)
  2. {
  3.   String original = m.getReplyTo();
  4.   if (original != null) {
  5.     if (original.startsWith("~/"))
  6.     {
  7.       m.setReplyTo("amqp://" + _name + "/" + original.substring(2));
  8.     }
  9.     else if (original.equals("~"))
  10.     {
  11.       m.setReplyTo("amqp://" + _name);
  12.     }
  13.   }
  14. }

代码示例来源：origin: EnMasseProject/enmasse

  1. public Message request(Message message, long timeout, TimeUnit timeUnit) {
  2.   Map<String, Object> properties = new HashMap<>();
  3.   if (message.getApplicationProperties() != null) {
  4.     properties.putAll(message.getApplicationProperties().getValue());
  5.   }
  6.   message.setApplicationProperties(new ApplicationProperties(properties));
  7.   if (message.getReplyTo() == null) {
  8.     message.setReplyTo(replyTo);
  9.   }
  10.   context.runOnContext(h -> sender.send(message));
  11.   try {
  12.     return replies.poll(timeout, timeUnit);
  13.   } catch (InterruptedException e) {
  14.     throw new RuntimeException(e);
  15.   }
  16. }

代码示例来源：origin: Azure/azure-event-hubs-java

  1. public void request(
  2.     final Message message,
  3.     final OperationResult<Message, Exception> onResponse) {
  4.   if (message == null)
  5.     throw new IllegalArgumentException("message cannot be null");
  6.   if (message.getMessageId() != null)
  7.     throw new IllegalArgumentException("message.getMessageId() should be null");
  8.   if (message.getReplyTo() != null)
  9.     throw new IllegalArgumentException("message.getReplyTo() should be null");
  10.   message.setMessageId("request" + UnsignedLong.valueOf(this.requestId.incrementAndGet()).toString());
  11.   message.setReplyTo(this.replyTo);
  12.   this.inflightRequests.put(message.getMessageId(), onResponse);
  13.   sendLink.delivery(UUID.randomUUID().toString().replace("-", StringUtil.EMPTY).getBytes());
  14.   final int payloadSize = AmqpUtil.getDataSerializedSize(message) + 512; // need buffer for headers
  15.   final byte[] bytes = new byte[payloadSize];
  16.   final int encodedSize = message.encode(bytes, 0, payloadSize);
  17.   receiveLink.flow(1);
  18.   sendLink.send(bytes, 0, encodedSize);
  19.   sendLink.advance();
  20. }

代码示例来源：origin: org.eclipse.hono/hono-client

  1. if (message.getReplyTo() != null) {
  2.   try {
  3.     final ResourceIdentifier replyTo = ResourceIdentifier.fromString(message.getReplyTo());
  4.     if (!CommandConstants.COMMAND_ENDPOINT.equals(replyTo.getEndpoint())) {

代码示例来源：origin: eclipse/hono

  1. /**
  2.    * Checks whether a given tenant message contains all required properties.
  3.    * 
  4.    * @param linkTarget The resource path to check the message's properties against for consistency.
  5.    * @param msg The AMQP 1.0 message to perform the checks on.
  6.    * @return {@code true} if the message passes all checks.
  7.    */
  8.   public static boolean verify(final ResourceIdentifier linkTarget, final Message msg) {
  10.     if (msg.getMessageId() == null && msg.getCorrelationId() == null) {
  11.       LOG.trace("message has neither a message-id nor correlation-id");
  12.       return false;
  13.     } else if (msg.getSubject() == null) {
  14.       LOG.trace("message [{}] does not contain subject", msg.getMessageId());
  15.       return false;
  16.     } else if (msg.getReplyTo() == null) {
  17.       LOG.trace("message [{}] contains no reply-to address", msg.getMessageId());
  18.       return false;
  19.     } else if (msg.getBody() != null && !MessageHelper.hasDataBody(msg)) {
  20.       LOG.trace("message [{}] contains no Data section payload", msg.getMessageId());
  21.       return false;
  22.     } else {
  23.       return true;
  24.     }
  25.   }
  26. }

代码示例来源：origin: strimzi/strimzi-kafka-bridge

  1. if (message.getSubject() != null)
  2.   jsonProperties.put(AmqpJsonMessageConverter.SUBJECT, message.getSubject());
  3. if (message.getReplyTo() != null)
  4.   jsonProperties.put(AmqpJsonMessageConverter.REPLY_TO, message.getReplyTo());
  5. if (message.getCorrelationId() != null)
  6.   jsonProperties.put(AmqpJsonMessageConverter.CORRELATION_ID, message.getCorrelationId());

代码示例来源：origin: eclipse/hono

  1. /**
  2.  * Checks whether a given credentials message contains all required properties.
  3.  *
  4.  * @param linkTarget The resource path to check the message's properties against for consistency.
  5.  * @param msg The AMQP 1.0 message to perform the checks on.
  6.  * @return {@code true} if the message passes all checks.
  7.  */
  8. public static boolean verify(final ResourceIdentifier linkTarget, final Message msg) {
  9.   if (msg.getMessageId() == null && msg.getCorrelationId() == null) {
  10.     LOG.trace("message has neither a message-id nor correlation-id");
  11.     return false;
  12.   } else if (!CredentialsConstants.CredentialsAction.isValid(msg.getSubject())) {
  13.     LOG.trace("message [{}] does not contain valid subject property", msg.getMessageId());
  14.     return false;
  15.   } else if (msg.getReplyTo() == null) {
  16.     LOG.trace("message [{}] has no reply-to address set", msg.getMessageId());
  17.     return false;
  18.   } else if (!MessageHelper.hasDataBody(msg)) {
  19.     LOG.trace("message [{}] contains no Data section payload", msg.getMessageId());
  20.     return false;
  21.   } else {
  22.     return true;
  23.   }
  24. }

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. /**
  2.  * Checks whether a given credentials message contains all required properties.
  3.  *
  4.  * @param linkTarget The resource path to check the message's properties against for consistency.
  5.  * @param msg The AMQP 1.0 message to perform the checks on.
  6.  * @return {@code true} if the message passes all checks.
  7.  */
  8. public static boolean verify(final ResourceIdentifier linkTarget, final Message msg) {
  9.   if (msg.getMessageId() == null && msg.getCorrelationId() == null) {
  10.     LOG.trace("message has neither a message-id nor correlation-id");
  11.     return false;
  12.   } else if (!CredentialsConstants.CredentialsAction.isValid(msg.getSubject())) {
  13.     LOG.trace("message [{}] does not contain valid subject property", msg.getMessageId());
  14.     return false;
  15.   } else if (msg.getReplyTo() == null) {
  16.     LOG.trace("message [{}] has no reply-to address set", msg.getMessageId());
  17.     return false;
  18.   } else if (!MessageHelper.hasDataBody(msg, true)) {
  19.     LOG.trace("message [{}] contains no AmqpValue or Data section payload", msg.getMessageId());
  20.     return false;
  21.   } else {
  22.     return true;
  23.   }
  24. }

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. /**
  2.    * Checks whether a given tenant message contains all required properties.
  3.    * 
  4.    * @param linkTarget The resource path to check the message's properties against for consistency.
  5.    * @param msg The AMQP 1.0 message to perform the checks on.
  6.    * @return {@code true} if the message passes all checks.
  7.    */
  8.   public static boolean verify(final ResourceIdentifier linkTarget, final Message msg) {
  10.     if (msg.getMessageId() == null && msg.getCorrelationId() == null) {
  11.       LOG.trace("message has neither a message-id nor correlation-id");
  12.       return false;
  13.     } else if (msg.getSubject() == null) {
  14.       LOG.trace("message [{}] does not contain subject", msg.getMessageId());
  15.       return false;
  16.     } else if (msg.getReplyTo() == null) {
  17.       LOG.trace("message [{}] contains no reply-to address", msg.getMessageId());
  18.       return false;
  19.     } else if (msg.getBody() != null && !MessageHelper.hasDataBody(msg, true)) {
  20.       LOG.trace("message [{}] contains no AmqpValue or Data section payload", msg.getMessageId());
  21.       return false;
  22.     } else {
  23.       return true;
  24.     }
  25.   }
  26. }

代码示例来源：origin: org.eclipse.hono/hono-server

  1. private void processRequest(final Message msg) {
  2.   final JsonObject registrationMsg = RegistrationConstants.getRegistrationMsg(msg);
  3.   vertx.eventBus().send(EVENT_BUS_ADDRESS_REGISTRATION_IN, registrationMsg,
  4.       result -> {
  5.         JsonObject response = null;
  6.         if (result.succeeded()) {
  7.           // TODO check for correct session here...?
  8.           response = (JsonObject) result.result().body();
  9.         } else {
  10.           logger.debug("failed to process request [msg ID: {}] due to {}", msg.getMessageId(), result.cause());
  11.           // we need to inform client about failure
  12.           response = RegistrationConstants.getReply(
  13.               HttpURLConnection.HTTP_INTERNAL_ERROR,
  14.               MessageHelper.getTenantIdAnnotation(msg),
  15.               MessageHelper.getDeviceIdAnnotation(msg),
  16.               null);
  17.         }
  18.         addHeadersToResponse(msg, response);
  19.         vertx.eventBus().send(msg.getReplyTo(), response);
  20.       });
  21. }

代码示例来源：origin: eclipse/hono

  1. /**
  2.    * Checks whether a given registration message contains all required properties.
  3.    * 
  4.    * @param linkTarget The resource path to check the message's properties against for consistency.
  5.    * @param msg The AMQP 1.0 message to perform the checks on.
  6.    * @return {@code true} if the message passes all checks.
  7.    */
  8.    public static boolean verify(final ResourceIdentifier linkTarget, final Message msg) {
  10.      if (!hasValidDeviceId(linkTarget, msg)) {
  11.        return false;
  12.      } else if (!hasCorrelationId(msg)) {
  13.        return false;
  14.      } else if (!RegistrationConstants.isValidAction(msg.getSubject())) {
  15.        LOG.trace("message [{}] does not contain valid action property", msg.getMessageId());
  16.        return false;
  17.      } else if (msg.getReplyTo() == null) {
  18.        LOG.trace("message [{}] contains no reply-to address", msg.getMessageId());
  19.        return false;
  20.     } else if (msg.getBody() != null && !MessageHelper.hasDataBody(msg)) {
  21.       LOG.trace("message [{}] contains no Data section payload", msg.getMessageId());
  22.       return false;
  23.      } else {
  24.        return true;
  25.      }
  26.   }
  27. }

代码示例来源：origin: org.eclipse.hono/hono-server

  1. LOG.trace("message [{}] does not contain valid action property", msg.getMessageId());
  2.   return false;
  3. } else if (msg.getReplyTo() == null) {
  4.   LOG.trace("message [{}] contains no reply-to address", msg.getMessageId());
  5.   return false;

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. /**
  2.    * Checks whether a given registration message contains all required properties.
  3.    * 
  4.    * @param linkTarget The resource path to check the message's properties against for consistency.
  5.    * @param msg The AMQP 1.0 message to perform the checks on.
  6.    * @return {@code true} if the message passes all checks.
  7.    */
  8.    public static boolean verify(final ResourceIdentifier linkTarget, final Message msg) {
  10.      if (!hasValidDeviceId(linkTarget, msg)) {
  11.        return false;
  12.      } else if (!hasCorrelationId(msg)) {
  13.        return false;
  14.      } else if (!RegistrationConstants.isValidAction(msg.getSubject())) {
  15.        LOG.trace("message [{}] does not contain valid action property", msg.getMessageId());
  16.        return false;
  17.      } else if (msg.getReplyTo() == null) {
  18.        LOG.trace("message [{}] contains no reply-to address", msg.getMessageId());
  19.        return false;
  20.     } else if (msg.getBody() != null && !MessageHelper.hasDataBody(msg, true)) {
  21.       LOG.trace("message [{}] contains no AmqpValue or Data section payload", msg.getMessageId());
  22.       return false;
  23.      } else {
  24.        return true;
  25.      }
  26.   }
  27. }

代码示例来源：origin: org.eclipse.hono/hono-service-base

  1. final String replyTo = message.getReplyTo();

代码示例来源：origin: eclipse/hono

  1. final String replyTo = message.getReplyTo();

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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