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

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

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

Message.getSubject介绍

暂无

代码示例

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

  1. /**
  2.  * Creates a new (request) message from an AMQP 1.0 message.
  3.  * <p>
  4.  * The operation will be determined from the message's
  5.  * <em>subject</em>.
  6.  * 
  7.  * @param message The AMQP message.
  8.  * @return The request message.
  9.  * @throws NullPointerException if message is {@code null}.
  10.  * @throws IllegalArgumentException if the message has no subject set.
  11.  */
  12. public static EventBusMessage forOperation(final Message message) {
  13.   if (message.getSubject() == null) {
  14.     throw new IllegalArgumentException("message has no subject");
  15.   } else {
  16.     return new EventBusMessage(message.getSubject());
  17.   }
  18. }

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

  1. /**
  2.  * Creates a new (request) message from an AMQP 1.0 message.
  3.  * <p>
  4.  * The operation will be determined from the message's
  5.  * <em>subject</em>.
  6.  * 
  7.  * @param message The AMQP message.
  8.  * @return The request message.
  9.  * @throws NullPointerException if message is {@code null}.
  10.  * @throws IllegalArgumentException if the message has no subject set.
  11.  */
  12. public static EventBusMessage forOperation(final Message message) {
  13.   if (message.getSubject() == null) {
  14.     throw new IllegalArgumentException("message has no subject");
  15.   } else {
  16.     return new EventBusMessage(message.getSubject());
  17.   }
  18. }

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

  1. /**
  2.  * Gets the name of this command.
  3.  *
  4.  * @return The name.
  5.  * @throws IllegalStateException if this command is invalid.
  6.  */
  7. public String getName() {
  8.   if (isValid()) {
  9.     return message.getSubject();
  10.   } else {
  11.     throw new IllegalStateException("command is invalid");
  12.   }
  13. }

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

  1. /**
  2.  * Return an AMQP_PUBREL message from the raw AMQP one
  3.  *
  4.  * @param message   raw AMQP message
  5.  * @return  AMQP_PUBREL message
  6.  */
  7. public static AmqpPubrelMessage from(Message message) {
  8.   if (!message.getSubject().equals(AMQP_SUBJECT)) {
  9.     throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  10.   }
  11.   return new AmqpPubrelMessage(message.getMessageId());
  12. }

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

  1. /**
  2.  * Return an AMQP_CLOSE message from the raw AMQP one
  3.  *
  4.  * @param message   raw AMQP message
  5.  * @return  AMQP_CLOSE message
  6.  */
  7. public static AmqpCloseMessage from(Message message) {
  8.   if (!message.getSubject().equals(AMQP_SUBJECT)) {
  9.     throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  10.   }
  11.   return new AmqpCloseMessage(AmqpHelper.getClientIdFromPublishAddress((String) message.getCorrelationId()));
  12. }

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

  1. /**
  2.  * Return an AMQP_LIST message from the raw AMQP one
  3.  *
  4.  * @param message   raw AMQP message
  5.  * @return  AMQP_LIST message
  6.  */
  7. public static AmqpListMessage from(Message message) {
  8.   if (!message.getSubject().equals(AMQP_SUBJECT)) {
  9.     throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  10.   }
  11.   return new AmqpListMessage(AmqpHelper.getClientIdFromPublishAddress((String) message.getCorrelationId()));
  12. }

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

  1. /**
  2.  * Checks if the client is authorized to execute a given operation.
  3.  * 
  4.  * This method is invoked for every request message received from a client.
  5.  * <p>
  6.  * This default implementation simply delegates to {@link AuthorizationService#isAuthorized(HonoUser, ResourceIdentifier, String)}.
  7.  * <p>
  8.  * Subclasses may override this method in order to do more sophisticated checks.
  9.  * 
  10.  * @param clientPrincipal The client.
  11.  * @param resource The resource the message belongs to.
  12.  * @param message The message for which the authorization shall be checked.
  13.  * @return A future indicating the outcome of the check.
  14.  *         The future will be succeeded if the client is authorized to execute the operation.
  15.  *         Otherwise the future will be failed with a {@link ServiceInvocationException}.
  16.  * @throws NullPointerException if any of the parameters is {@code null}.
  17.  */
  18. protected Future<Boolean> isAuthorized(final HonoUser clientPrincipal, final ResourceIdentifier resource, final Message message) {
  19.   Objects.requireNonNull(message);
  20.   return getAuthorizationService().isAuthorized(clientPrincipal, resource, message.getSubject());
  21. }

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

  1. /**
  2.  * Checks if the client is authorized to execute a given operation.
  3.  * 
  4.  * This method is invoked for every request message received from a client.
  5.  * <p>
  6.  * This default implementation simply delegates to {@link AuthorizationService#isAuthorized(HonoUser, ResourceIdentifier, String)}.
  7.  * <p>
  8.  * Subclasses may override this method in order to do more sophisticated checks.
  9.  * 
  10.  * @param clientPrincipal The client.
  11.  * @param resource The resource the message belongs to.
  12.  * @param message The message for which the authorization shall be checked.
  13.  * @return A future indicating the outcome of the check.
  14.  *         The future will be succeeded if the client is authorized to execute the operation.
  15.  *         Otherwise the future will be failed with a {@link ServiceInvocationException}.
  16.  * @throws NullPointerException if any of the parameters is {@code null}.
  17.  */
  18. protected Future<Boolean> isAuthorized(final HonoUser clientPrincipal, final ResourceIdentifier resource, final Message message) {
  19.   Objects.requireNonNull(message);
  20.   return getAuthorizationService().isAuthorized(clientPrincipal, resource, message.getSubject());
  21. }

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

  1. /**
  2.  * Return an AMQP_SUBSCRIPTIONS message from the raw AMQP one
  3.  *
  4.  * @param message   raw AMQP message
  5.  * @return  AMQP_SUBSCRIPTIONS message
  6.  */
  7. @SuppressWarnings("unchecked")
  8. public static AmqpSubscriptionsMessage from(Message message) {
  9.   if (!message.getSubject().equals(AMQP_SUBJECT)) {
  10.     throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  11.   }
  12.   Section section = message.getBody();
  13.   if ((section != null) && (section instanceof AmqpValue)) {
  14.     Map<String, String> map = (Map<String, String>) ((AmqpValue) section).getValue();
  15.     // build the unique topic subscriptions list
  16.     List<AmqpTopicSubscription> topicSubscriptions = new ArrayList<>();
  17.     for (Map.Entry<String, String> entry: map.entrySet()) {
  18.       topicSubscriptions.add(new AmqpTopicSubscription(entry.getKey(), MqttQoS.valueOf(Integer.valueOf(entry.getValue()))));
  19.     }
  20.     return new AmqpSubscriptionsMessage(topicSubscriptions);
  21.   } else {
  22.     throw new IllegalArgumentException("AMQP message wrong body type");
  23.   }
  24. }

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

  1. /**
  2.  * Return an AMQP_UNSUBSCRIBE message from the raw AMQP one
  3.  *
  4.  * @param message   raw AMQP message
  5.  * @return  AMQP_UNSUBSCRIBE message
  6.  */
  7. @SuppressWarnings("unchecked")
  8. public static AmqpUnsubscribeMessage from(Message message) {
  9.   if (!message.getSubject().equals(AMQP_SUBJECT)) {
  10.     throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  11.   }
  12.   Section section = message.getBody();
  13.   if ((section != null) && (section instanceof AmqpValue)) {
  14.     List<String> topics = (List<String>) ((AmqpValue) section).getValue();
  15.     return new AmqpUnsubscribeMessage(AmqpHelper.getClientIdFromPublishAddress((String) message.getCorrelationId()),
  16.                      topics);
  17.   } else {
  18.     throw new IllegalArgumentException("AMQP message wrong body type");
  19.   }
  20. }

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

  1. /**
  2.  * Return an AMQP_SUBSCRIBE message from the raw AMQP one
  3.  *
  4.  * @param message   raw AMQP message
  5.  * @return  AMQP_SUBSCRIBE message
  6.  */
  7. @SuppressWarnings("unchecked")
  8. public static AmqpSubscribeMessage from(Message message) {
  9.   if (!message.getSubject().equals(AMQP_SUBJECT)) {
  10.     throw new IllegalArgumentException(String.format("AMQP message subject is no %s", AMQP_SUBJECT));
  11.   }
  12.   Section section = message.getBody();
  13.   if ((section != null) && (section instanceof AmqpValue)) {
  14.     Map<String, String> map = (Map<String, String>) ((AmqpValue) section).getValue();
  15.     // build the unique topic subscriptions list
  16.     List<AmqpTopicSubscription> topicSubscriptions = new ArrayList<>();
  17.     for (Map.Entry<String, String> entry: map.entrySet()) {
  18.       topicSubscriptions.add(new AmqpTopicSubscription(entry.getKey(), MqttQoS.valueOf(Integer.valueOf(entry.getValue()))));
  19.     }
  20.     return new AmqpSubscribeMessage(AmqpHelper.getClientIdFromPublishAddress((String) message.getCorrelationId()),
  21.                     topicSubscriptions);
  22.   } else {
  23.     throw new IllegalArgumentException("AMQP message wrong body type");
  24.   }
  25. }

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

  1. ResourceIdentifier.fromPath(new String[] { resource.getEndpoint(), tenantId });
  2. return getAuthorizationService().isAuthorized(clientPrincipal, specificTenantAddress, request.getSubject());

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

  1. if (message.getSubject() == null) {
  2.   switch (message.getSubject()) {

代码示例来源：origin: org.apache.beam/beam-sdks-java-io-amqp

  1. @Test
  2. public void encodeDecode() throws Exception {
  3.  Message message = Message.Factory.create();
  4.  message.setBody(new AmqpValue("body"));
  5.  message.setAddress("address");
  6.  message.setSubject("test");
  7.  AmqpMessageCoder coder = AmqpMessageCoder.of();
  8.  Message clone = CoderUtils.clone(coder, message);
  9.  assertEquals("AmqpValue{body}", clone.getBody().toString());
  10.  assertEquals("address", clone.getAddress());
  11.  assertEquals("test", clone.getSubject());
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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