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

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

/**
* @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()));
}

private WildcardConfiguration createWildCardConfiguration() {
 WildcardConfiguration wildcardConfiguration = new WildcardConfiguration();
 wildcardConfiguration.setAnyWords('#');
 wildcardConfiguration.setDelimiter('/');
 wildcardConfiguration.setRoutingEnabled(true);
 wildcardConfiguration.setSingleWord('+');
 return wildcardConfiguration;
}

private void addWildCardConfiguration(Configuration configuration) {
 WildcardConfiguration wildcardConfiguration = new WildcardConfiguration();
 wildcardConfiguration.setAnyWords('#');
 wildcardConfiguration.setDelimiter('/');
 wildcardConfiguration.setRoutingEnabled(true);
 wildcardConfiguration.setSingleWord('+');
 configuration.setWildCardConfiguration(wildcardConfiguration);
}

@Override
public void configureBroker() throws Exception {
 super.configureBroker();
 WildcardConfiguration wildcardConfiguration = new WildcardConfiguration();
 wildcardConfiguration.setDelimiter('.');
 wildcardConfiguration.setSingleWord('*');
 wildcardConfiguration.setAnyWords('>');
 server.getConfiguration().setWildCardConfiguration(wildcardConfiguration);
}

wildcardConfiguration.setDelimiter('/');
wildcardConfiguration.setRoutingEnabled(true);
wildcardConfiguration.setSingleWord('+');

wildcardConfiguration.setDelimiter('/');
wildcardConfiguration.setRoutingEnabled(true);
wildcardConfiguration.setSingleWord('+');

26 4 0

• activemq-artemis - Artemis 从节点未在完整集群中实时启动

  我正在尝试将 6 节点 Apache Artemis 静态集群作为 3 个实时备份对运行。为了在整个集群重启期间不丢失数据，我还创建了一种机制来确定这对节点中的哪一个具有更新的数据，并基于此服务器自动

• activemq-artemis - 如何监控ActiveMQ Artemis

  我正在 Windows .NET 环境中使用 RabbitMQ、ActiveMQ“Classic”和 ActiveMQ Artemis 进行一些测试。 RabbitMQ 和 ActiveMQ“经典”附

• activemq-artemis - 无法访问 Artemis 控制台

  我刚刚在我的新服务器上安装了一个新的artemis，可以正常运行服务但无法从外部访问。 我也关注了这个问题，似乎和我有类似的问题，但是似乎无法工作。 Artemis-2.6.3 console: Se

• activemq-artemis - 如何解锁 ActiveMQ Artemis 代理

  我做了一些事情来锁定我的 ActiveMQ Artemis 2.8.1 代理。我需要运行 > ./artemis data exp获取有关我的队列设置的数据。运行失败，报错说代理被锁定:/var/li

• activemq-artemis - 无法通过 artemis Web 控制台删除队列

  我正在 Docker 上试验 artemis 2.13.0。 我可以以编程方式创建队列，但无法通过 Web 控制台删除它。 有时，destroyQueue 作为队列操作中的一个选项出现。其他时候没有。

• activemq-artemis - ActiveMQ Artemis 传输方案无法识别 [vm] 错误

  我尝试运行此代码: EmbeddedActiveMQ server = new EmbeddedActiveMQ(); server.setConfiguration(new Configuratio

• activemq-artemis - Docker 中的 ActiveMQ Artemis 显示空屏幕

  简短版本 当我在 docker 中运行 ActiveMQ Artemis 时，我看到这个基本上是空的屏幕: 这看起来不对......我期待着这个，就像我在使用 zip 文件时得到的那样: 无论我使用d

• activemq-artemis - 连接 Artemis 和 Amazon MQ 代理

  我正在尝试将 Apache Artemis 代理与 Amazon MQ 代理连接起来以创建混合架构。我已经尝试将 ActiveMQ 与 Amazon MQ 连接起来，我可以通过在 broker.xml

• activemq-artemis - 如何通过 GUI 将消息发送到 ActiveMQ Artemis 中的队列

  我安装了 Apache ActiveMQ Artemis，并希望通过 GUI 用消息填充队列。 我导航到队列 --> 选择队列 --> 操作 有一个功能sendMessage(java.util.Ma

• java - 在哪里可以找到使用 Apache ActiveMQ Artemis 中的 artemis create 创建的队列和地址

  我已使用 artemis.cmd create 选项在 Apache ActiveMQ Artemis 中创建了地址和队列。但是，当我检查我的broker.xml时，我没有找到我使用artemis.c

• activemq-artemis - Apache ActiveMQ Artemis 2.20，如何在 Web 控制台的浏览队列中查看全身按摩

  我向 ActiveMQ Artemis 2.20 中的队列发送一条消息，然后导航到 Web 控制台以查看该消息，但我只能看到有限的字符。我可以配置 Web 控制台以显示队列中的完整消息正文吗？ 最佳答

• activemq-artemis - 监听 0.0.0.0 时无法访问 Artemis GUI

  我正在以两种不同的方式初始化代理。一个听 0.0.0.0另一个监听节点 IP，即 172.29.245.17 . 经纪人1: [root@amq-1 apache-artemis-2.4.0]# bi

• activemq-artemis - Artemis : AMQ222210: Storage usage is beyond max-disk-usage. 系统将开始阻止生产者

  我正在从应用程序 A 向 Artemis 发送消息，但我从应用程序 A 收到此错误: AMQ212054: Destination address=my-service is blocked. If

• activemq-artemis - Artemis : AMQ222210: Storage usage is beyond max-disk-usage. 系统将开始阻止生产者

  我正在从应用程序 A 向 Artemis 发送消息，但我从应用程序 A 收到此错误: AMQ212054: Destination address=my-service is blocked. If

• com.artemis.WorldConfigurationBuilder类的使用及代码示例

  本文整理了Java中com.artemis.WorldConfigurationBuilder类的一些代码示例，展示了WorldConfigurationBuilder类的具体用法。这些代码示例主要来

• stomp - ApacheMQ Artemis 保留没有路由的消息

  我使用的是 Artemis 2.6.2，只有 STOMP 和以下星座: 经纪人: 没有在 broker.xml 中配置队列，一切都是自动创建的。 服务器: 订阅目标 TaskResponse 没有选择

• kubernetes - ActiveMQ Artemis 消费者在崩溃后不会重新连接到同一个集群节点

  我在 Kubernetes 中设置了一个 Artemis 集群，有 3 组主/从: activemq-artemis-master-0 1/

• kubernetes - ActiveMQ Artemis 集群在一个实例崩溃后不重新分发消息

  我在 Kubernetes 中有一个 Artemis 集群，有 3 组主/从: activemq-artemis-master-0 1/1

• activemq-artemis - 如何在ActiveMQ Artemis中实现虚拟主题功能

  ActiveMQ“经典”有 virtual topic功能。这意味着消费者可以动态创建。 ActiveMQ Artemis 如何管理此功能？ 最佳答案 ActiveMQ“Classic”中虚拟主题的要

• java - ActiveMQ Artemis 中的消息重复在消息被消费后仍然被拒绝

  我使用的是 ActiveMQ Artemis 2.10，在我的用例中，我希望避免队列中出现重复的消息，因此我在向队列发送消息之前设置了属性 Message.HDR_DUPLICATE_DETECTIO