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

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

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

Message.getAddress介绍

暂无

代码示例

代码示例来源:origin: vert-x3/vertx-examples

  1. String address = remoteTarget.getAddress() ;
  2. if (address == null) {
  3. address = msg.getAddress();

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

  1. private AmqpContext createContext(
  2. final ResourceIdentifier validatedAddress,
  3. final ProtonDelivery delivery,
  4. final Message message,
  5. final Device authenticatedDevice) {
  6. final String to = validatedAddress.toString();
  7. if (!to.equals(message.getAddress())) {
  8. LOG.debug("adjusting message's address [orig: {}, updated: {}]", message.getAddress(), to);
  9. message.setAddress(to);
  10. }
  11. return new AmqpContext(delivery, message, authenticatedDevice);
  12. }

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

  1. /**
  2. * Creates an AmqpContext instance using the specified delivery, message and authenticated device.
  3. * <p>
  4. * This constructor <b>does not</b> validate the message address. It is the responsibility of the caller to make
  5. * sure that the message address is valid i.e matches the pattern {@code endpointName/tenantId/deviceId}.
  6. *
  7. * @param delivery The delivery of the message.
  8. * @param message The AMQP 1.0 message. The message must contain a valid address.
  9. * @param authenticatedDevice The device that authenticates to the adapter or {@code null} if the device is unauthenticated.
  10. * @throws NullPointerException if the delivery or message is null.
  11. */
  12. AmqpContext(final ProtonDelivery delivery, final Message message, final Device authenticatedDevice) {
  13. this.delivery = Objects.requireNonNull(delivery);
  14. this.message = Objects.requireNonNull(message);
  15. this.authenticatedDevice = authenticatedDevice;
  16. this.resource = ResourceIdentifier.fromString(message.getAddress());
  17. this.payload = MessageHelper.getPayload(message);
  18. }

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

  1. String topic = (message.getAddress() == null) ?
  2. kafkaTopic :
  3. message.getAddress().replace('/', '.');

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

  1. URI address = new URI(m.getAddress());
  2. if (address.getHost() == null)
  3. throw new MessengerException("unable to send to address: " + m.getAddress());
  4. throw new MessengerException("Invalid address: " + m.getAddress(), e);

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

  1. @Override
  2. public void processMessage(final UpstreamReceiver client, final ProtonDelivery delivery, final Message data) {
  3. LinkStatus status = statusMap.get(client.getLinkId());
  4. if (status == null) {
  5. LOG.debug("creating new link status object [{}]", client.getLinkId());
  6. status = new LinkStatus(client);
  7. statusMap.put(client.getLinkId(), status);
  8. }
  9. LOG.debug("processing telemetry data [id: {}, to: {}, content-type: {}]", data.getMessageId(), data.getAddress(),
  10. data.getContentType());
  11. if (messageConsumer != null) {
  12. messageConsumer.accept(data);
  13. }
  14. ProtonHelper.accepted(delivery, true);
  15. status.onMsgReceived();
  16. }

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

  1. private void rewriteMessage(Message m)
  2. {
  3. _original = m.getAddress();
  4. if (_rewrites.apply(_original)) {
  5. m.setAddress(_rewrites.result());
  6. } else {
  7. m.setAddress(defaultRewrite(_original));
  8. }
  9. }

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

  1. private void rewriteMessage(Message m)
  2. {
  3. _original = m.getAddress();
  4. if (_rewrites.apply(_original)) {
  5. m.setAddress(_rewrites.result());
  6. } else {
  7. m.setAddress(defaultRewrite(_original));
  8. }
  9. }

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

  1. String topic = message.getAddress();

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

  1. StoreEntry entry = _outgoingStore.put( m.getAddress() );
  2. _outgoingTracker = new TrackerImpl(TrackerImpl.Type.OUTGOING,
  3. _outgoingStore.trackEntry(entry));
  4. String routedAddress = routeAddress(m.getAddress());
  5. Address address = new Address(routedAddress);
  6. if (address.getHost() == null)
  7. pumpOut(m.getAddress(), sender);

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

  1. String topic = message.getAddress();

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

  1. String topic = (message.getAddress() == null) ?
  2. kafkaTopic :
  3. message.getAddress().replace('/', '.');

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

  1. msg.getMessageId(), msg.getAddress(), msg.getContentType(), getDownstreamContainer(), sender.getCredit(), sender.getQueued());
  2. forwardMessage(sender, msg, delivery);

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

  1. if (amqpMessage.getUserId() != null)
  2. receiveProperties.put(AmqpConstants.AMQP_PROPERTY_USER_ID, amqpMessage.getUserId());
  3. if (amqpMessage.getAddress() != null)
  4. receiveProperties.put(AmqpConstants.AMQP_PROPERTY_TO, amqpMessage.getAddress());
  5. if (amqpMessage.getSubject() != null)
  6. receiveProperties.put(AmqpConstants.AMQP_PROPERTY_SUBJECT, amqpMessage.getSubject());

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

  1. StoreEntry entry = _outgoingStore.put( m.getAddress() );
  2. _outgoingTracker = new TrackerImpl(TrackerImpl.Type.OUTGOING,
  3. _outgoingStore.trackEntry(entry));
  4. String routedAddress = routeAddress(m.getAddress());
  5. Address address = new Address(routedAddress);
  6. if (address.getHost() == null)
  7. int port = Integer.valueOf(ports);
  8. Sender sender = getLink(address.getHost(), port, new SenderFinder(address.getName()));
  9. pumpOut(m.getAddress(), sender);

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

  1. MqttQoS qos = MqttQoS.AT_MOST_ONCE;
  2. String topic = message.getAddress();

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

  1. String topic = message.getAddress();

代码示例来源:origin: io.vertx/vertx-proton

  1. @Override
  2. public ProtonDelivery send(byte[] tag, Message message, Handler<ProtonDelivery> onUpdated) {
  3. if (anonymousSender && message.getAddress() == null) {
  4. throw new IllegalArgumentException("Message must have an address when using anonymous sender.");
  5. }
  6. // TODO: prevent odd combination of onRecieved callback + SenderSettleMode.SETTLED, or just allow it?
  7. Delivery delivery = sender().delivery(tag); // start a new delivery..
  8. ProtonWritableBufferImpl buffer = new ProtonWritableBufferImpl();
  9. MessageImpl msg = (MessageImpl) message;
  10. msg.encode(buffer);
  11. ReadableBuffer encoded = new ProtonReadableBufferImpl(buffer.getBuffer());
  12. sender().sendNoCopy(encoded);
  13. if (link.getSenderSettleMode() == SenderSettleMode.SETTLED) {
  14. delivery.settle();
  15. }
  16. sender().advance(); // ends the delivery.
  17. ProtonDeliveryImpl protonDeliveryImpl = new ProtonDeliveryImpl(delivery);
  18. if (onUpdated != null) {
  19. protonDeliveryImpl.setAutoSettle(autoSettle);
  20. protonDeliveryImpl.handler(onUpdated);
  21. } else {
  22. protonDeliveryImpl.setAutoSettle(true);
  23. }
  24. getSession().getConnectionImpl().flush();
  25. return protonDeliveryImpl;
  26. }

代码示例来源: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. }

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

  1. items.put(Tags.MESSAGE_BUS_DESTINATION.getKey(), message.getAddress());
  2. msgSpan.log(items);
  3. validateEndpoint(message.getAddress(), delivery)
  4. .compose(address -> validateAddress(address, authenticatedDevice))
  5. .recover(t -> {

相关文章