- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
在 Spring-Boot 中,默认的 ActiveMQ (JMS) 属性是:
spring.activemq.broker-url=tcp://192.168.1.210:9876
spring.activemq.user=admin
spring.activemq.password=secret
如果我想发送到多个broker-url或监听不同的broker-url该怎么做?
最佳答案
您无法使用默认的 Spring-Boot
自动配置访问两个不同的代理。
为了解决这个问题,您必须创建自己的配置 Bean,如下例所示:
@Configuration
class JmsUtilsConfiguration {
@Value("${activemq.broker-one.url}")
private String brokerOneUrl;
// Im my case, broker-two is secured -> hence username and password need to be configured
@Value("${activemq.broker-two.url}")
private String brokerTwoUrl;
@Value("${activemq.broker-two.username}")
private String brokerTwoUser;
@Value("${activemq.broker-two.password}")
private String brokerTwoPwd;
@Bean
@Primary
public ConnectionFactory jmsConnectionFactoryOne() {
return new ActiveMQConnectionFactory(brokerOneUrl);
}
@Bean
public QueueConnectionFactory jmsConnectionFactoryTwo() {
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
activeMQConnectionFactory.setBrokerURL(brokerTwoUrl);
activeMQConnectionFactory.setUserName(brokerTwoUser);
activeMQConnectionFactory.setPassword(brokerTwoPwd);
return activeMQConnectionFactory;
}
// JmsListenerContainerFactory declarations
@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactoryOne(
ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
configurer.configure(factory, connectionFactory);
return factory;
}
@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactoryTwo(
@Qualifier("jmsConnectionFactoryTwo") ConnectionFactory connectionFactory,
DefaultJmsListenerContainerFactoryConfigurer configurer) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
configurer.configure(factory, connectionFactory);
return factory;
}
// JMS Template Declaration
@Bean
@Primary
public JmsTemplate jmsTemplateOne() {
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(jmsConnectionFactoryOne());
return jmsTemplate;
}
@Bean
public JmsTemplate jmsTemplateTwo() {
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(jmsConnectionFactoryTwo());
return jmsTemplate;
}
}
在我的application.yml
中,我只引用注入(inject)的属性(没有设置默认的spring.activemq
属性):
activemq:
broker-one:
url: tcp://localhost:61616
local-queue: TEST.LOCAL.INBOUND
broker-two:
url: failover:(ssl://myremote-amq-1:61617,ssl://myremote-amq-2:61617)?jms.watchTopicAdvisories=false&timeout=5000&maxReconnectDelay=10000
username: myuser
password: mypass
remote-queue: TEST.REMOTE.QUEUE
在我的监听器 Bean 中(假设我只想从两个队列中消费)
@Component
public class ConsumeQueuesBean {
private static final Logger LOGGER = LoggerFactory.getLogger(ConsumeQueuesBean.class);
@JmsListener(destination = "${activemq.broker-one.local-queue}", containerFactory = "jmsListenerContainerFactoryOne")
public void onMessageReceiveB1(final Message message) throws JMSException {
if (message instanceof TextMessage) {
String text = ((TextMessage) message).getText();
LOGGER.info(text);
}
}
@JmsListener(destination = "${activemq.broker-two.remote-queue}", containerFactory = "jmsListenerContainerFactoryTwo")
public void onMessageReceivedB2(final Message message) throws JMSException {
if (message instanceof TextMessage) {
String text = ((TextMessage) message).getText();
LOGGER.info(text);
}
}
}
您还可以使用配置中定义的jmsTemplates
将消息发布到您想要的代理。
关于java - Spring-Boot:如何访问多个 JMS 代理 URL,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42640648/
假设我拥有域 mydomain.com,并且我在服务器上有一个 Web 应用程序,网址为 http://99.99.99.99:1234/MyApplication/startpage.somethi
我正在尝试通过以下方式更新已解析的 URL: u, _ := url.Parse(s) if u.Scheme == "" { u.Scheme = "https" } if u.Path =
如何将 www.somesite.com/api(.*) 映射到 www.somesite.com/$1:9000? (我需要将/api 映射到运行 @ 端口 9000 的 Play 框架应用程序)
我有一个资源结构,如航类 > 座位 > 预订,所以预订属于某个航类的某个座位: http://example.com/jdf_3prGPS4/1/jMBDy46PbNc
我想知道以下网址是否有效。 路径中的点,在主机之后: http://www.example.com/v.b.w..com 主机中的点,作为子域的一部分: http://v.b.w..co.manufa
我有两个域 - crmpicco.co.uk 和 ayrshireminis.com - 如果我浏览到: www.crmpicco.co.uk/mini/new我希望能够重定向到 www.ayrshi
我正在尝试使用 URL 重写和应用程序请求路由来重写到外部 URL。我设置了以下规则: 在规则中,“patternToMatch”是我试
我已经安装了带有 SharePoint 和 Url Rewrite 模块的 IIS 7.0。 是以下句子还是我配置错误才能看到这个结果? Url Redirect 可以将 url 重定向到任何内部(在
我想知道,为了获得良好的 SEO,您必须在 URL 中使用自然语言。您知道字符中单词或短语的最大大小吗?例如: www.me.com/this-is-a-really-long-url.htm 我问这
有人知道在 SEO 友好 URL 中使用逗号有什么问题吗?我正在使用一些在其 SEO 友好 URL 中使用大量逗号的软件;但我 100% 肯定我见过一些程序/平台无法正确识别 URL 并在第一个逗号后
我有一个网站,我正在为所有链接使用干净的 URL。我想知道对于简短的基本 URL 与较长的描述性 URL 有何看法。 例如,如果我的网站是关于 Georgia Bulldog 足球新闻的,那么哪个网站
我正在编写一个类似于 tinyurl 的 URL 缩短器,我想知道如何跟踪已经使用我的服务缩短的 URL?例如,tinyurl 为相同的长 URL 生成相同的小 URL,而不管是谁创建的。如
我是 magento 的新手。我正在开发一个模块。为此,我有一些要显示链接的 css 和 js 文件。我目前有类似 的链接 getSkinUrl('module_tryouts/css/jquery.
我想基于 HTTP_URL 重写 URL 以重定向到不同的端口,同时保留其余的 URL 和查询字符串(如果指定)。例如, http://host/john/page.aspx 应该重定向到 http:
我遇到了以下问题: 我的 Grails (2.2.0) 应用程序具有以下 URL 映射: "/api/clientQuote/$labcode/$cliCode/$quoCode"(controlle
我有一个很长的 URL,它不适合 URL 字段。它一直在修剪。该怎么办?有没有办法增加 SharePoint 2010 中的 URL 字段字符限制? 或者解决方法来容纳长 URL。例如,以下 URL
关闭。这个问题是off-topic .它目前不接受答案。 想改进这个问题? Update the question所以它是on-topic对于堆栈溢出。 9年前关闭。 Improve this que
我们从客户以前的开发人员那里继承了相当多的 Google Apps 脚本项目。 Apps 脚本通过嵌入式小部件部署在 Google 网站 (sites.google.com) 的各个页面上。每当我们需
我正在编写一些文档,但遇到了一些词汇问题: http://www.example.com/en/public/img/logo.gif 被称为“绝对”网址,对吗? ../../public/img/l
我们从客户以前的开发人员那里继承了相当多的 Google Apps 脚本项目。 Apps 脚本通过嵌入式小部件部署在 Google 网站 (sites.google.com) 的各个页面上。每当我们需
我是一名优秀的程序员,十分优秀!