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

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

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

Message.setSubject介绍

暂无

代码示例

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   message.setCorrelationId(String.format(AmqpHelper.AMQP_CLIENT_PUBLISH_ADDRESS_TEMPLATE, this.clientId));
  10.   return message;
  11. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   message.setCorrelationId(String.format(AmqpHelper.AMQP_CLIENT_PUBLISH_ADDRESS_TEMPLATE, this.clientId));
  10.   message.setReplyTo(String.format(AmqpHelper.AMQP_CLIENT_CONTROL_ADDRESS_TEMPLATE, this.clientId));
  11.   return message;
  12. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   message.setMessageId(this.messageId);
  10.   return message;
  11. }

代码示例来源：origin: apache/activemq-artemis

  1. /**
  2. * Sets the Subject property on an outbound message using the provided String
  3. *
  4. * @param subject the String Subject value to set.
  5. */
  6. public void setSubject(String subject) {
  7.  checkReadOnly();
  8.  lazyCreateProperties();
  9.  getWrappedMessage().setSubject(subject);
  10. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   message.setCorrelationId(String.format(AmqpHelper.AMQP_CLIENT_PUBLISH_ADDRESS_TEMPLATE, this.clientId));
  10.   // map with topic -> qos (in String format)
  11.   Map<String, String> map = new HashMap<>();
  12.   this.topicSubscriptions.stream().forEach(amqpTopicSubscription -> {
  13.     map.put(amqpTopicSubscription.topic(), String.valueOf(amqpTopicSubscription.qos().value()));
  14.   });
  15.   message.setBody(new AmqpValue(map));
  16.   return message;
  17. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   // map with topic -> qos (in String format)
  10.   Map<String, String> map = new HashMap<>();
  11.   this.topicSubscriptions.stream().forEach(amqpTopicSubscription -> {
  12.     map.put(amqpTopicSubscription.topic(), String.valueOf(amqpTopicSubscription.qos().value()));
  13.   });
  14.   message.setBody(new AmqpValue(map));
  15.   return message;
  16. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   message.setCorrelationId(String.format(AmqpHelper.AMQP_CLIENT_PUBLISH_ADDRESS_TEMPLATE, this.clientId));
  10.   message.setBody(new AmqpValue(this.topics));
  11.   return message;
  12. }

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

  1. /**
  2.    * Verifies that the endpoint forwards a request message via the event bus.
  3.    */
  4.   @Test
  5.   public void testProcessMessageSendsRequestViaEventBus() {
  7.     final Message msg = ProtonHelper.message();
  8.     msg.setMessageId("4711");
  9.     msg.setSubject(RegistrationConstants.ACTION_ASSERT);
  10.     msg.setBody(new AmqpValue(new JsonObject().put("temp", 15).encode()));
  11.     MessageHelper.annotate(msg, resource);
  12.     endpoint.processRequest(msg, resource, Constants.PRINCIPAL_ANONYMOUS);
  14.     verify(eventBus).send(eq(RegistrationConstants.EVENT_BUS_ADDRESS_REGISTRATION_IN), any(JsonObject.class), any(DeliveryOptions.class));
  15.   }
  16. }

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

  1. /**
  2.    * Verifies that the endpoint forwards a request message via the event bus.
  3.    */
  4.   @Test
  5.   public void testProcessMessageSendsRequestViaEventBus() {
  7.     final Message msg = ProtonHelper.message();
  8.     msg.setMessageId("random-id");
  9.     msg.setSubject(TenantConstants.TenantAction.get.toString());
  10.     MessageHelper.addTenantId(msg, Constants.DEFAULT_TENANT);
  11.     MessageHelper.annotate(msg, resource);
  13.     endpoint.processRequest(msg, resource, Constants.PRINCIPAL_ANONYMOUS);
  15.     verify(eventBus).send(eq(TenantConstants.EVENT_BUS_ADDRESS_TENANT_IN), any(JsonObject.class), any(DeliveryOptions.class));
  16.   }
  17. }

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

  1. private static Message givenAValidMessageWithoutBody(final CredentialsConstants.CredentialsAction action) {
  2.     final Message msg = ProtonHelper.message();
  3.     msg.setMessageId("msg");
  4.     msg.setReplyTo("reply");
  5.     msg.setSubject(action.toString());
  6.     return msg;
  7.   }
  8. }

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

  1. private Message givenAMessageHavingProperties(final TenantConstants.TenantAction action) {
  2.     final Message msg = ProtonHelper.message();
  3.     msg.setMessageId("msg");
  4.     msg.setReplyTo("reply");
  5.     msg.setSubject(action.toString());
  6.     return msg;
  7.   }
  8. }

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

  1. /**
  2.  * Verifies that the endpoint rejects request messages for operations the client
  3.  * is not authorized to invoke.
  4.  */
  5. @Test
  6. public void testHandleMessageRejectsUnauthorizedRequests() {
  7.   final Message msg = ProtonHelper.message();
  8.   msg.setSubject("unauthorized");
  9.   msg.setReplyTo(REPLY_RESOURCE.toString());
  10.   final ProtonConnection con = mock(ProtonConnection.class);
  11.   final ProtonDelivery delivery = mock(ProtonDelivery.class);
  12.   final AuthorizationService authService = mock(AuthorizationService.class);
  13.   when(authService.isAuthorized(any(HonoUser.class), any(ResourceIdentifier.class), anyString())).thenReturn(Future.succeededFuture(Boolean.FALSE));
  14.   final Future<Void> processingTracker = Future.future();
  15.   final RequestResponseEndpoint<ServiceConfigProperties> endpoint = getEndpoint(true, processingTracker);
  16.   endpoint.setAuthorizationService(authService);
  17.   endpoint.onLinkAttach(con, sender, REPLY_RESOURCE);
  18.   // WHEN a request for an operation is received that the client is not authorized to invoke
  19.   endpoint.handleMessage(con, receiver, resource, delivery, msg);
  20.   // THEN the the message is rejected
  21.   final ArgumentCaptor<DeliveryState> deliveryState = ArgumentCaptor.forClass(DeliveryState.class);
  22.   verify(delivery).disposition(deliveryState.capture(), booleanThat(is(Boolean.TRUE)));
  23.   assertThat(deliveryState.getValue(), instanceOf(Rejected.class));
  24.   verify(receiver, never()).close();
  25.   verify(authService).isAuthorized(Constants.PRINCIPAL_ANONYMOUS, resource, "unauthorized");
  26.   assertFalse(processingTracker.isComplete());
  27. }

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

  1. private static Message givenAMessageHavingProperties(final String deviceId, final String action) {
  2.     final Message msg = ProtonHelper.message();
  3.     msg.setMessageId("msg-id");
  4.     msg.setReplyTo("reply");
  5.     msg.setSubject(action);
  6.     if (deviceId != null) {
  7.       MessageHelper.addDeviceId(msg, deviceId);
  8.     }
  9.     return msg;
  10.   }
  11. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   Map<Symbol, Object> map = new HashMap<>();
  10.   map.put(Symbol.valueOf(AMQP_RETAIN_ANNOTATION), this.isRetain);
  11.   map.put(Symbol.valueOf(AMQP_QOS_ANNOTATION), this.qos.value());
  12.   MessageAnnotations messageAnnotations = new MessageAnnotations(map);
  13.   message.setMessageAnnotations(messageAnnotations);
  14.   message.setAddress(this.topic);
  15.   Header header = new Header();
  16.   header.setDurable(this.qos != MqttQoS.AT_MOST_ONCE);
  17.   message.setHeader(header);
  18.   // the payload could be null (or empty)
  19.   if (this.payload != null)
  20.     message.setBody(new Data(new Binary(this.payload.getBytes())));
  21.   return message;
  22. }

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

  1. /**
  2.  * Return a raw AMQP message
  3.  *
  4.  * @return
  5.  */
  6. public Message toAmqp() {
  7.   Message message = ProtonHelper.message();
  8.   message.setSubject(AMQP_SUBJECT);
  9.   Map<Symbol, Object> map = new HashMap<>();
  10.   map.put(Symbol.valueOf(AMQP_RETAIN_ANNOTATION), this.isRetain);
  11.   map.put(Symbol.valueOf(AMQP_QOS_ANNOTATION), this.qos.value());
  12.   MessageAnnotations messageAnnotations = new MessageAnnotations(map);
  13.   message.setMessageAnnotations(messageAnnotations);
  14.   message.setAddress(this.topic);
  15.   Header header = new Header();
  16.   header.setDurable(this.qos != MqttQoS.AT_MOST_ONCE);
  17.   message.setHeader(header);
  18.   // the payload could be null (or empty)
  19.   if (this.payload != null)
  20.     message.setBody(new Data(new Binary(this.payload.getBytes())));
  21.   return message;
  22. }

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

  1. /**
  2.    * Verifies that the endpoint forwards a request message via the event bus.
  3.    */
  4.   @Test
  5.   public void testProcessMessageSendsRequestViaEventBus() {
  7.     final Message msg = ProtonHelper.message();
  8.     msg.setMessageId("random-id");
  9.     msg.setSubject(CredentialsConstants.CredentialsAction.add.toString());
  10.     MessageHelper.addDeviceId(msg, "4711");
  11.     MessageHelper.addTenantId(msg, Constants.DEFAULT_TENANT);
  12.     MessageHelper.annotate(msg, resource);
  14.     msg.setBody(new AmqpValue(new JsonObject().put("temp", 15).encode()));
  16.     endpoint.processRequest(msg, resource, Constants.PRINCIPAL_ANONYMOUS);
  18.     verify(eventBus).send(eq(CredentialsConstants.EVENT_BUS_ADDRESS_CREDENTIALS_IN), any(JsonObject.class), any(DeliveryOptions.class));
  19.   }
  20. }

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

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public Future<Void> sendOneWayCommand(final String command, final String contentType, final Buffer data, final Map<String, Object> properties) {
  6.   Objects.requireNonNull(command);
  7.   final Span currentSpan = newChildSpan(null, command);
  8.   if (sender.isOpen()) {
  9.     final Future<BufferResult> responseTracker = Future.future();
  10.     final Message request = ProtonHelper.message();
  11.     AbstractHonoClient.setApplicationProperties(request, properties);
  12.     final String messageId = createMessageId();
  13.     request.setMessageId(messageId);
  14.     request.setSubject(command);
  15.     MessageHelper.setPayload(request, contentType, data);
  16.     sendRequest(request, responseTracker.completer(), null, currentSpan);
  17.     return responseTracker.map(ignore -> null);
  18.   } else {
  19.     TracingHelper.logError(currentSpan, "sender link is not open");
  20.     return Future.failedFuture(new ServerErrorException(
  21.         HttpURLConnection.HTTP_UNAVAILABLE, "sender link is not open"));
  22.   }
  23. }

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

  1. @Test
  2.  public void encodeDecodeLargeMessage() throws Exception {
  3.   Message message = Message.Factory.create();
  4.   message.setAddress("address");
  5.   message.setSubject("subject");
  6.   String body = Joiner.on("").join(Collections.nCopies(32 * 1024 * 1024, " "));
  7.   message.setBody(new AmqpValue(body));
  9.   AmqpMessageCoder coder = AmqpMessageCoder.of();
  11.   Message clone = CoderUtils.clone(coder, message);
  13.   clone.getBody().toString().equals(message.getBody().toString());
  14.  }
  15. }

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

  1. @Test
  2. public void encodeDecodeTooMuchLargerMessage() throws Exception {
  3.  thrown.expect(CoderException.class);
  4.  Message message = Message.Factory.create();
  5.  message.setAddress("address");
  6.  message.setSubject("subject");
  7.  String body = Joiner.on("").join(Collections.nCopies(64 * 1024 * 1024, " "));
  8.  message.setBody(new AmqpValue(body));
  9.  AmqpMessageCoder coder = AmqpMessageCoder.of();
  10.  byte[] encoded = CoderUtils.encodeToByteArray(coder, message);
  11. }

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