org.apache.activemq.artemis.api.core.Message.setAddress()方法的使用及代码示例

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

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

Message.setAddress介绍

[英]Look at #setAddress(SimpleString) for the doc.
[中]查看#setAddress（SimpleString）获取文档。

代码示例

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

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

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

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

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

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

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

代码示例来源：origin: org.apache.activemq/artemis-core-client

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

代码示例来源：origin: org.apache.activemq/artemis-jms-client-all

  1. @Override
  2. public void setAddress(final Message message, final SimpleString address) {
  3.  logger.tracef("setAddress() Setting default address as %s", address);
  4.  message.setAddress(address);
  5. }

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

  1. private void move(final SimpleString toAddress,
  2.          final Transaction tx,
  3.          final MessageReference ref,
  4.          final boolean expiry,
  5.          final boolean rejectDuplicate,
  6.          final long... queueIDs) throws Exception {
  7.  Message copyMessage = makeCopy(ref, expiry);
  8.  copyMessage.setAddress(toAddress);
  9.  if (queueIDs != null && queueIDs.length > 0) {
  10.    ByteBuffer buffer = ByteBuffer.allocate(8 * queueIDs.length);
  11.    for (long id : queueIDs) {
  12.     buffer.putLong(id);
  13.    }
  14.    copyMessage.putBytesProperty(Message.HDR_ROUTE_TO_IDS.toString(), buffer.array());
  15.  }
  16.  postOffice.route(copyMessage, tx, false, rejectDuplicate);
  17.  if (expiry) {
  18.    acknowledge(tx, ref, AckReason.EXPIRED, null);
  19.  } else {
  20.    acknowledge(tx, ref);
  21.  }
  22. }

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

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

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

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

代码示例来源：origin: org.apache.activemq/artemis-core-client

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

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

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

代码示例来源：origin: org.apache.activemq/artemis-jms-client-all

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    // the caller must consume the first byte already, as that will be used to decide what persister (protocol) to use
  4.    long id = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new CoreMessage();
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    record.setAddress(address);
  10.    return record;
  11.   }
  12. }

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

  1. @Override
  2.   public Message decode(ActiveMQBuffer buffer, Message record) {
  3.    long id = buffer.readLong();
  4.    long format = buffer.readLong();
  5.    SimpleString address = buffer.readNullableSimpleString();
  6.    record = new AMQPMessage(format);
  7.    record.reloadPersistence(buffer);
  8.    record.setMessageID(id);
  9.    if (address != null) {
  10.      record.setAddress(address);
  11.    }
  12.    return record;
  13.   }
  14. }

代码示例来源：origin: org.apache.activemq/artemis-amqp-protocol

  1. @Override
  2. public Message decode(ActiveMQBuffer buffer, Message record) {
  3.  long id = buffer.readLong();
  4.  long format = buffer.readLong();
  5.  SimpleString address = buffer.readNullableSimpleString();
  6.  record = new AMQPMessage(format);
  7.  record.reloadPersistence(buffer);
  8.  record.setMessageID(id);
  9.  if (address != null) {
  10.    record.setAddress(address);
  11.  }
  12.  return record;
  13. }

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

  1. private Message createQueueInfoMessage(final NotificationType type, final SimpleString queueName) {
  2.  Message message = new CoreMessage().initBuffer(50).setMessageID(storageManager.generateID());
  3.  message.setAddress(queueName);
  4.  String uid = UUIDGenerator.getInstance().generateStringUUID();
  5.  message.putStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE, new SimpleString(type.toString()));
  6.  message.putLongProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP, System.currentTimeMillis());
  7.  message.putStringProperty(new SimpleString("foobar"), new SimpleString(uid));
  8.  return message;
  9. }

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

  1. /**
  2. * Prompt delivery and send a "forced delivery" message to the consumer.
  3. * <p>
  4. * When the consumer receives such a "forced delivery" message, it discards it and knows that
  5. * there are no other messages to be delivered.
  6. */
  7. @Override
  8. public void forceDelivery(final long sequence)  {
  9.  forceDelivery(sequence, () -> {
  10.    Message forcedDeliveryMessage = new CoreMessage(storageManager.generateID(), 50);
  11.    MessageReference reference = MessageReference.Factory.createReference(forcedDeliveryMessage, messageQueue);
  12.    reference.setDeliveryCount(0);
  13.    forcedDeliveryMessage.putLongProperty(ClientConsumerImpl.FORCED_DELIVERY_MESSAGE, sequence);
  14.    forcedDeliveryMessage.setAddress(messageQueue.getName());
  15.    applyPrefixForLegacyConsumer(forcedDeliveryMessage);
  16.    callback.sendMessage(reference, forcedDeliveryMessage, ServerConsumerImpl.this, 0);
  17.  });
  18. }

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

  1. @Test
  2. public void testAMQSize() throws Exception {
  3.  message.setAddress(RandomUtil.randomSimpleString());
  4.  int encodeSize = message.getEncodeSize();
  5.  Filter moreThanSmall = FilterImpl.createFilter(new SimpleString("AMQSize > " + (encodeSize - 1)));
  6.  Filter lessThanLarge = FilterImpl.createFilter(new SimpleString("AMQSize < " + (encodeSize + 1)));
  7.  Filter lessThanSmall = FilterImpl.createFilter(new SimpleString("AMQSize < " + encodeSize));
  8.  Filter moreThanLarge = FilterImpl.createFilter(new SimpleString("AMQSize > " + encodeSize));
  9.  Assert.assertTrue(moreThanSmall.match(message));
  10.  Assert.assertTrue(lessThanLarge.match(message));
  11.  Assert.assertFalse(lessThanSmall.match(message));
  12.  Assert.assertFalse(moreThanLarge.match(message));
  13. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Message类方法

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