org.apache.activemq.artemis.core.config.WildcardConfiguration.getSingleWord()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-26 14:11:05 27 4

public String convert(String filter, WildcardConfiguration to) {
 return filter.replace(getDelimiter(), to.getDelimiter())
     .replace(getSingleWord(), to.getSingleWord())
     .replace(getAnyWords(), to.getAnyWords());
}

/**
* @param e
* @return
*/
protected void parseWildcardConfiguration(final Element e, final Configuration mainConfig) {
 WildcardConfiguration conf = mainConfig.getWildcardConfiguration();
 conf.setDelimiter(getString(e, "delimiter", Character.toString(conf.getDelimiter()), Validators.NO_CHECK).charAt(0));
 conf.setAnyWords(getString(e, "any-words", Character.toString(conf.getAnyWords()), Validators.NO_CHECK).charAt(0));
 conf.setSingleWord(getString(e, "single-word", Character.toString(conf.getSingleWord()), Validators.NO_CHECK).charAt(0));
 conf.setRoutingEnabled(getBoolean(e, "enabled", conf.isRoutingEnabled()));
 conf.setRoutingEnabled(getBoolean(e, "routing-enabled", conf.isRoutingEnabled()));
}

public AddressImpl(final SimpleString address, final WildcardConfiguration wildcardConfiguration) {
 this.address = address;
 this.wildcardConfiguration = wildcardConfiguration;
 addressParts = address.split(wildcardConfiguration.getDelimiter());
 containsWildCard = address.contains(wildcardConfiguration.getSingleWord()) || address.contains(wildcardConfiguration.getAnyWords());
}

@Test
public void testWildcardConfiguration() throws Exception {
 FileConfigurationParser parser = new FileConfigurationParser();
 String configStr = firstPart + "<wildcard-addresses>\n<routing-enabled>true</routing-enabled>\n<delimiter>/</delimiter>\n<any-words>></any-words></wildcard-addresses>" + lastPart;
 ByteArrayInputStream input = new ByteArrayInputStream(configStr.getBytes(StandardCharsets.UTF_8));
 Configuration config = parser.parseMainConfig(input);
 WildcardConfiguration wildCard = config.getWildcardConfiguration();
 assertEquals('/', wildCard.getDelimiter());
 assertTrue(wildCard.isRoutingEnabled());
 assertEquals('>', wildCard.getAnyWords());
 assertEquals('*', wildCard.getSingleWord());
}

final char sepSingleWord = wildcardConfiguration.getSingleWord();

27 4 0

• activemq - activemq connectionfactory类中ClientId有什么用

  场景: private readonly IConnection connection; this.connection = connectionFactory.CreateConnection();

• activemq - 安排将消息从 activemq DLQ 移动到 ActiveMQ 中的另一个队列

  想知道是否可以在 activeMQ 服务器中完成任何配置，将消息从 DLQ 重定向到同一服务器上的另一个队列。 例如。 我有一个队列“MAINQUEUE”，其中有很多消息已激活客户端确认，在处理时如果

• activemq - 在未来某个时间点重试消息 (ActiveMQ)

  我正在 ActiveMQ 中的一个系统上工作，我真的不想丢失消息。我的问题是重试消息导致我的消费者阻塞(而不是处理他们可以处理的消息)。我想给失败的消息几天重试(例如，我的潜在目的地之一是我将通过 S

• activemq - 如何使用池正确配置 ActiveMQ？

  我们对 AMQ 使用以下配置 定期我有奇怪的问题 - 松散的消息。实际上AMQ说一切正常并且消

• activemq - 设置 ActiveMQ

  我已按照教程安装 ActiveMQ http://servicebus.blogspot.com/2011/02/installing-apache-active-mq-on-ubuntu.html

• activemq - ActiveMQ 是否保证消息传递？

  当我们使用 ActiveMQ 时，我们可以信任 ActiveMQ 服务器的可靠性。例如在开发非实时软件时(不需要立即发送数据。但应该发送)。我们能否信任 activeMQ 作为确认消息传递的可靠来源。

• activemq - 如何观察 ActiveMQ 底层发生的事情？

  我遇到了 issue使用 ActiveMQ 并希望跟踪/查看所有 ActiveMQ 事件。我能找到的唯一日志文件是与持久数据相关联的(如果打开的话)。我是否查看或生成了任何其他日志文件来告诉我 Act

• activemq - 消费者未从 ActiveMQ 接收消息

  我们正面临 ActiveMQ 及其使用者的随机问题。我们观察到，即使连接到 ActiveMQ 队列，也很少有消费者没有收到消息。但是在消费者重启后它工作正常。 我们在 ActiveMQ 端有一个名为

• activemq - 在 ActiveMQ 中查看延迟消息？

  有什么方法可以跟踪 ActiveMQ 中的延迟(计划)消息？ 我在 AMQ 网络控制台中没有看到任何东西，它们似乎只有在延迟到期时才进入队列……而且我在 JMX 控制台中也找不到它，也许我搜索得不够好

• activemq - 了解 Apache ActiveMQ

  我对Apache ActiveMQ的功能感到困惑。 我从this link下载了ActiveMQ 。所以我这样使用它(环境:Windows 7):我启动 bin/activemq.bat，然后它就可以

• activemq - 如何让我的 ActiveMQ 代理删除离线持久订阅者

  我们有一个 ActiveMQ 代理，它使用 JMS、AMQP 和 MQTT 连接到不同的客户端。由于某种原因，我们还没有弄清楚一组特定的 MQTT 客户端经常(并非总是)持久订阅。这是一个测试环境，其

• activemq - Activemq 获取每秒消耗/产生的消息数

  在activemq中有什么方法可以获取消息的数量代理端每秒/每分钟消耗/产生的数量？ 我已经尝试使用http://activemq.apache.org/jmeter-performance-test

• activemq - 如何在队列上设置 ActiveMQ redeliveryPolicy？

  如何在队列上的 ActiveMQ 中设置 redeliveryPolicy？ 1) 在文档中，请参阅:activeMQ Redelivery ，说明您应该在 ConnectionFactory 或 C

• activemq - ActiveMQ 的用途是什么 - 我们可以使用数据库应用消息传递概念吗？

  我查了一下，它用于在两个系统之间发送消息。 但为什么？为什么不直接使用数据库？ 一定有一些 ActiveMQ 具有 数据库 没有的功能吗？ 最佳答案 它用于在两个分布式进程之间进行可靠的通信。 是的，

• activemq - 是否可以在 ActiveMQ 中镜像单个队列？

  我在生产系统中运行 ActiveMQ。我们的一些队列的流量非常大，而有些队列的流量非常低。我对镜像其中一个低容量队列感兴趣，这样我就可以围绕接收到的消息构建非正式的监控服务。 不幸的是，the onl

• activemq - 使用 ActiveMQ 监控代理重新交付

  我们已经使用此配置为 ActiveMQ Broker 配置了 Broker redelivery 插件。

• activemq - 检查 ActiveMQ 中特定队列的可用性？

  有什么方法可以检查特定队列是否已存在于 ActiveMQ 中？ 最佳答案 http://activemq.apache.org/how-can-i-get-a-list-of-the-topics-a

• activemq - 如何将 activemq-core.xsd url 与 jar 文件中找到的 activemq.xsd 关联？

  有人知道如何将 activemq-core.xsd url 与 jar 文件 (activemq-core-5.2.0.jar) 中的 activemq.xsd 关联起来？ 我在互联网上找到了一些解决

• activemq - 是否可以使用 ActiveMQ 进行发布/订阅消息传递

  我是 activemq 的新手。我试图使用 activemq 代理来订阅/发布消息。但至于缺乏经验，我不知道该怎么做，也不知道是否真的可以做到。我在谷歌上搜索了很多，但不幸的是，没有适合此类功能的示例

• activemq - ActiveMQ 中的 NIO 缺点

  我一直在努力配置 ActiveMQ 代理，让我感到困惑的一件事是，我读过的所有内容都将 NIO 描述为“如果您需要扩展的不错选择”或“如果您需要更快的速度” ，所以我的问题是他们为什么不说“总是使用