Spring JMS和参数化类型(带有List<String>参数的@JmsListener)？
Spring JMS是Spring框架中用于支持Java消息服务（Java Message Service，JMS）的模块。它提供了一种简化的方式来发送和接收消息，并与消息代理进行交互。JMS是一种用于在分布式系统中发送、接收和传递消息的标准API。
参数化类型是Java语言中的一种特性，它允许在定义类、接口或方法时指定参数的类型。带有List<String>参数的@JmsListener表示使用Spring JMS框架时，通过@JmsListener注解来定义一个消息监听器方法，并且该方法的参数类型为List<String>，即接收一个字符串列表作为参数。
Spring JMS的优势包括：
- 简化的API：Spring JMS提供了简化的API，使得与JMS消息代理的交互变得更加容易和直观。
- 松耦合：通过使用Spring框架的依赖注入和控制反转机制，Spring JMS实现了与JMS消息代理的松耦合，使得应用程序更加灵活和可维护。
- 异步消息处理：Spring JMS支持异步消息处理，可以提高系统的吞吐量和响应性能。
- 事务管理：Spring JMS提供了对JMS事务的支持，可以确保消息的可靠传递和处理。
Spring JMS适用于以下场景：
- 分布式系统中的消息通信：当系统需要在不同的组件或模块之间进行消息通信时，可以使用Spring JMS来实现异步的、松耦合的消息传递。
- 异步任务处理：当系统需要处理大量的异步任务时，可以使用Spring JMS来将任务转化为消息，并通过消息队列进行分发和处理。
- 高可靠性系统：当系统对消息的可靠传递和处理有较高要求时，可以使用Spring JMS的事务管理功能来确保消息的可靠性。
腾讯云提供了一系列与消息队列相关的产品，可以与Spring JMS结合使用，例如：
- 云消息队列CMQ：腾讯云的消息队列服务，提供高可靠、高可用的消息传递能力。详情请参考：云消息队列CMQ
- 云订阅消息服务CNS：腾讯云的发布-订阅消息服务，支持消息的广播和订阅。详情请参考：云订阅消息服务CNS
- 云函数SCF：腾讯云的无服务器计算服务，可以与消息队列结合使用，实现事件驱动的异步处理。详情请参考：云函数SCF
以上是关于Spring JMS和参数化类型的简要介绍和相关腾讯云产品的推荐。如需了解更多细节和具体使用方法，请参考相关文档和官方网站。
相关·内容
我正在听MQ使用Spring JMS @JmsListener注解。
@JmsListener(destination = "${qNmae}",
containerFactory = "jmsListenerContainerFactory2")
public void processMessage(Message<String> msg) throws JMSException {
}
我需要将Spring Message对象转换为New JMS TextMessage。我知道我
浏览 1提问于2017-01-24得票数 2
1回答
我是Spring JMS的新手，我正在尝试测试一个使用@JMSListener的方法。
你知道如何使用mockrunner或其他你知道的工具来测试它吗？
我看过这个示例，但我不确定它是否适用于我的情况。
@Service
public class MyJMSService {
@JmsListener(destination = "jms/queuename")
public void processMessage(ObjectMessage msg) throws JMSException {
//do stuff
}
}
浏览 0提问于2016-12-20得票数 1
我有一个带有方法的Controller，如
@MessageMapping("${my.topic}")
public void receiveCommand(Message content) {
log.info("Received command: " + content);
}
我还向这个控制器注入了一个SimpMessagingTemplate和一个JmsMessagingTemplate。我认为，我的receiveCommand方法的问题是，Spring希望这是一个JMS消息，而不是一个WebSocket消息。然而，这似乎无法确定，如何确保此方
浏览 0提问于2018-05-30得票数 0
回答已采纳
我试图使用@ bean注释bean来使用通过spring JmsTemplate发送的JMS消息。当使用JmsTemplate发送消息时，使用者不会接收消息。
然而，当使用骆驼的ProducerTemplate发送时，就会收到消息。
@org.springframework.jms.annotation.JmsListener和@org.apache.camel.Consume有什么区别？
生产者逻辑
jmsTemplate.convertAndSend("jms:mailbox", message);
消费者逻辑
@Consume(uri="jms:mailbox&#
浏览 1提问于2019-09-06得票数 0
回答已采纳
因此，我正在尝试对基于Spring (v4.1.6)的JMS处理代码进行一些集成测试。
这是一个非常标准的带有@JmsListener注释方法的Spring设置，以及一个concurrency设置为1的DefaultMessageListenerContainer，因此只允许一个侦听线程。
现在，我利用ActiveMQ的嵌入式代理不依赖任何外部jms代理在任何时间在任何地方运行测试(我应该从事营销工作)。
所以一切都很好，然后我做了我的JUnit测试：
@Test
public void test() {
sendSomeMessage();
//how to wait her
浏览 2提问于2015-07-31得票数 3
回答已采纳
使用Spring，如何从config属性注入JMS主题？我想在application.properties中定义要在运行时注入的主题/队列名。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;
@Se
浏览 24提问于2022-03-11得票数 1
回答已采纳
下面是我在spring boot中的Hornetq配置。
spring.hornetq.mode=embedded
spring.hornetq.embedded.enabled=true
spring.hornetq.embedded.persistent=true
spring.hornetq.port=5445
spring.hornetq.embedded.queues=jms.testqueue
这是我的制片人
public class Producer {@Inject
private JmsTemplate jmsTemplate;
public void resolveE
浏览 20提问于2016-01-12得票数 2
我想澄清的是，如果我将多个@jmsListener放在一个方法上，那么它是如何工作的呢？它是否会像多个单独的JMS侦听器一样并行工作？或者，它将像一个JMS侦听器一样依次工作？
比如：
@JmsListener(destination = "queue.name1", containerFactory = "jmsListenerContainerFactory")
@JmsListener(destination = "queue.name2", containerFactory = "jmsListenerContai
浏览 3提问于2020-12-29得票数 1
回答已采纳
我这样创建一个消息处理程序： @JmsListeners(
JmsListener(destination = "queue1"),
JmsListener(destination = "queue2"),
JmsListener(destination = "queue3"),
JmsListener(destination = "queue4")
)
fun handleMessage(message: String) {
// handle a message
} 当我检查我的消息代理时，我看到我的应用
浏览 36提问于2021-01-17得票数 0
我使用了一个带@JmsListener注释的方法来监听JMS消息，如下所示。
@JmsListener(destination="exampleQueue")
public void fetch(@Payload String message){
process(message);
}
当此方法执行导致异常时，我得到了一个警告日志
Execution of JMS message listener failed, and no ErrorHandler has been set.
如何设置ErrorHandler来处理这种情况。我使用的是spring boo
浏览 1提问于2016-11-17得票数 12
回答已采纳
2回答
我有一个简单的服务发送电子邮件。可以使用REST和JMS调用它。我希望在处理之前对请求进行验证。
当我使用REST调用它时，我可以看到org.springframework.validation.DataBinder调用了void validate(Object target, Errors errors, Object... validationHints)，然后从Hibernate调用了验证器。这如预期的那样起作用。
问题是，我无法在JMS侦听器中实现相同的效果。侦听器的实现方式如下：
import lombok.AllArgsConstructor;
import lombok.exte
浏览 11提问于2016-01-13得票数 2
回答已采纳
1回答
如何将多个队列名传递给我的JmsListener。
@JmsListener(destination = "#{'${solace.jms.queueNames}'.split(',')}"
在我的财产档案中：
solace.jms.queueNames =q1,q2,q3
但是，当我启动Spring应用程序时，我会得到以下错误：
.s.j.l.DefaultMessageListenerContainer : Setup of JMS message listener invoker failed for destination '[
浏览 4提问于2022-02-18得票数 -1
1回答
根据Spring ，带有@JmsListener注解并具有非void返回类型的方法将将调用结果封装在javax.jms.Message中，并发送到原始消息的JMSReplyTo标题中指定的目的地或在侦听器上配置的默认目的地中。
如果没有找到目标，那么将抛出一个InvalidDestinationException。
是否有一种方法可以禁用这种自动回复行为？
编辑
我使用一个@Around建议来记录执行的结果，这就是为什么我需要在侦听器上有一个返回类型。
浏览 0提问于2018-03-09得票数 0
回答已采纳
我在数据库中有2条记录，因为在不同的线程中找不到本地创建和保存的实体。 我的配置如下： @Configuration
@EnableJms
@EnableJpaRepositories
public class MyConfiguration {
@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(ConnectionFactory connectionFactory,
浏览 26提问于2020-07-08得票数 0
当使用spring集成时，我看到性能下降。
IntegrationFlows.from(Jms.inboundGateway(connectionFactory)
.destination("orderQueue")
.jmsMessageConverter(new MarshallingMessageConverter(jaxbMarshaller()))
.transform(orderTransformer)
浏览 1提问于2018-05-15得票数 0
回答已采纳
我正在开发一个从Azure服务总线读取消息的应用程序。此应用程序是使用spring boot、Spring jms和Qpid jms客户端创建的。我能够正确地从队列中读取消息，没有任何问题。PFB我的代码，我用来阅读消息。
@Service
public class QueueReceiver {
@JmsListener(destination = "testing")
public void onMessage(String message) {
if (null != message) {
System.out.println("Recei
浏览 2提问于2017-03-01得票数 1
回答已采纳
我有一个包含@JmsListener方法的spring服务。它由客户端调用，通过JmsMessagingTemplate.convertSendAndReceive()发送消息。这个很好用。
@Service
public class JmsMessageProcessor {
@JmsListener(destination = "myDestination")
protected Message<MyResponseObj> handleRequest(final MyInputObj myObj) {
return Messag
浏览 3提问于2016-05-12得票数 1
我有一个使用SpringBoot应用程序使用SpringData来持久化Oracle和spring-boot-starter-activemq上的数据来处理JMS。
我正在公开一个需要一段时间的DELETE Rest WebService。我不想让我的用户挂在回应上。
因此，我添加了一个带有@JmsListener注释的方法，它完成了这项工作，我用jmsTemplate.convertAndSend()调用它。
但是，如果我处理的findAll()部分工作得很好，那么只要我试图访问使用findAll()方法检索的数据(例如，简单显示数据)，我就会在惰性集合上面对LazyLoadingExcep
浏览 2提问于2016-11-08得票数 2
我使用的是Wildfly 14中部署的Spring-Boot-WAR，并实现了一个连接到队列的JmsListener。JmsListener将并发设置为5，当Spring-App独立启动时，我看到5个并行工作的侦听器。但是结合Wildfly 14，只有一个监听器在运行。 在JEE中，我会用@ MessageDrivenBean注释池，然后可以为给定池配置最大池大小。但是我认为Spring-Listener只是连接到默认的MDB-Pool，它的大小是1。 有没有一种方法可以将JmsListener与特定的bean-instance-pool连接起来？或者，有没有其他方法可以为这个JmsList
浏览 68提问于2021-11-18得票数 0
1回答
我需要在所有jms侦听器上应用一些预检查和常见步骤，比如根据模式(JSON模式)验证原始消息。例子-
@Component
public class MyService {
@JmsListener(destination = "myDestination")
public void processOrder(Order order) { ... }
}
现在，在spring将消息从队列转换为订单之前，我需要执行以下操作-
将带有头的原始消息记录到自定义记录器中。
根据json模式验证json消息(文本消息)(为了简单起见，让我们假设这里只有一个模式)
浏览 1提问于2018-04-05得票数 1
回答已采纳
我有一个Spring Boot应用程序，它在从ActiveMQ代理检索TextMessage类型的JMS消息时出现问题。
如果使用者尝试从代理检索消息，它不能自动将消息转换为TextMessage，而是将其视为ByteMessage。应该有一个作为TextMessage从队列中读取消息的JmsListener：
...
@JmsListener(destination = "foo")
public void jmsConsumer(TextMessage message) {
...
JmsListener会生成如下警告，并删除消息：
org.springframework.
浏览 0提问于2019-01-29得票数 3
我使用spring引导并拥有@EnableJms
如果我只使用注释@JmsListener(destination = "xxxxxx")并依赖于spring自动配置，那么如何启动和停止jmslistener，知道我将其设置为自动启动false。
jms:
listener:
max-concurrency: 10
concurrency: 1
auto-startup: false
问题是如何访问SimpleMessageListenerContainer或DefaultMessageListenerContainer
浏览 3提问于2016-03-31得票数 1
回答已采纳
2回答
我有个与spring有关的项目
我在试着和交易所合作。我创建了4个监听器，默认情况下它们都被绑定到名为“jms.durable.queues”的交换中。即使我创建自己的交换并将队列手动绑定在兔子控制台上，spring仍然在创建默认的exchange。
我如何创建自己的队列并绑定到我的交换中，或者禁用spring来创建队列并绑定到默认的exchange‘jms.durable.Quees’？
我的配置类
import javax.jms.ConnectionFactory;
import com.rabbitmq.jms.admin.RMQConnectionFactory;
import
浏览 13提问于2021-12-06得票数 0
回答已采纳
我想在需要JMS侦听器的应用程序中使用Spring4.1中提供的新注释和特性。
我仔细阅读了中的注释，但我仍然怀念@JmsListener和DestinationResolver之间的关系，以及如何设置应用程序以指示正确的Destination或Endpoint。
下面是@JmsListener的建议用法
@Component
public class MyService {
@JmsListener(containerFactory = "myContainerFactory", destination = "myQueue")
public
浏览 1提问于2014-09-18得票数 12
回答已采纳
我能够将消息发布到ActiveMQ中，但是我的@JmsListener并没有使用这些消息。下面是我的密码。
JmsConfig.java
import javax.jms.ConnectionFactory;
import org.springframework.beans.factory.annotation.Configurable;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
import org.springframework.conte
浏览 0提问于2020-07-16得票数 1
我发现了许多用于创建JMS队列项目的代码示例，但是没有找到activemq(主题)的代码示例，这个示例称为PUB-SUB(Publisher-订户)。
对于Spring，我发现下面的代码，但正在寻找spring引导完整的代码。
Topic topic = topicConsumerSession.createTopic("customerTopic");
// Consumer1 subscribes to customerTopic
MessageConsumer consumer1 = topicConsumerSession
浏览 3提问于2017-02-11得票数 0
1回答
我想在java Spring boot项目中使用JMS队列和主题。因此，对于主题，我必须在application.properties spring.jms.pub-sub-domain = true中使用此主题。现在在同一个项目中，我也想接收队列消息，购买ActiveMQ没有看到我的队列的任何消费者…我怎么才能让它工作呢？用于从ActiveMq本地主机发送邮件的JmsListener示例:8161
@JmsListener(destination = "FROMACTIVEMQ")
public void getMessageFromActiveMq(TextMessa
浏览 16提问于2016-08-29得票数 1
回答已采纳
我正在使用Spring4.3.3，我正在尝试侦听目标类型为topic的消息。
我可以用xml实现它：
<jms:listener-container connection-factory="connectionFactory"
destination-type="topic"
message-converter="jackson2MessageConverter">
<jms:listener destination="
浏览 2提问于2016-10-15得票数 1
回答已采纳
我正在尝试以一种可伸缩的方式将Spring JMS消息传递与@JmsListener结合使用，但我并没有看到它的实现。我有一个JMS，它返回一个工厂，该工厂通过ConnectionFactory和一个数据库DataSource池连接到Oracle Advanced队列。
当每个@JmsListener接收器再次连接到JMS (从而连接到数据库池)时，问题就开始了。我的理解是，我可以有许多@JmsListener方法，每个服务一个，但在这种方式下，我非常有限。
共享连接是打开的，但是因为每个@JmsListener创建不同的DefaultMessageListenerContainer，所以每个
浏览 2提问于2018-07-04得票数 2
1回答
我有这样一个JMS“端点”：
@JmsListener(destination = "TestQueue")
public void doSomething(MyJaxbAnnotatedClass myclass) {
}
当然，使用所需的applicationContext配置，如<jms:注释驱动/>以及类似的配置。当我的方法签名只是一个
public void doSomething(String xmlString)
但我希望Spring能够自动解除编组，就像在Spring上下文中使用JSON那样。但是，为了实现这一点，Spring需要更多的配置，因为在尝
浏览 1提问于2014-12-10得票数 4
回答已采纳
我有两个接收器应该阅读一个主题。但是只有一个随机接收者收到消息，就好像它实际上是从队列中读取的，而不是一个主题。我读过的答案，但似乎没有用。这是我的密码。
Application.java:
package hello;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jms.DefaultJmsListener
浏览 3提问于2017-01-13得票数 2
回答已采纳
我有一条jms消息，报头中有一个名为id的属性。
在我的监听器中，当此jms消息被转换为消息时
@JmsListener(id = "cis-listener", destination = "${amiga.service.jms.cis-listener.destination-fqdn}",
containerFactory = "containerFactoryListener")
public void receiveMessage(Message<Object> event) throws UnknownMes
浏览 0提问于2021-03-18得票数 0
我正在尝试使用下面的片段来收听主题。然而，它在默认情况下侦听队列。在这种情况下没有xml配置。我完全依赖于注解。此外，我完全依赖于Spring boot提供的AutoConfiguration。我不确定如何在JmsListener中将目标类型设置为topic。Spring JMS专家请帮帮忙。
@Component
public class MyTopicListener {
@JmsListener(destination = "${trans.alert.topic}")
public void receiveMessage
浏览 10提问于2016-10-20得票数 8
回答已采纳
1回答
我已经创建了几个spring 4.1.6 @JmsListener方法，用于从队列接收消息。我想要获取监听程序名称的列表，用于管理目的：
@JmsListener(
destination = "${jms.destination.name}"
, containerFactory = "myJmsContainerFactory"
, id ="myListener")
public void receiveMessage(String message) {
Sys
浏览 1提问于2015-07-06得票数 1
1回答
我有一个通过注释配置的Spring应用程序，并且在JMS监听器启动之前，我试图向应用程序提供一些信息。之后，我想手动启动侦听器。
具有以下配置：
@Bean(name = "queueContainerFactory")
public JmsListenerContainerFactory<?> queue(ConnectionFactory cf) {
SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
Active
浏览 6提问于2016-09-20得票数 2
回答已采纳
我在我的项目上使用了Spring(引导)，并且我使用以下命令访问JMS队列(ActiveMQ)：
@JmsListener(destination = "mydestinationQueue")
public void processMessage(String content) {
//do something
}
它工作得很好，但我需要能够以编程方式停止/暂停/启动这个bean ( REST调用或类似的调用)。
当我停止或暂停这个bean时，我希望确保已经完全处理了当前消息。
对此有什么想法吗？
谢谢
浏览 47提问于2015-09-15得票数 12
1回答
我用spring引导实现了jms，我使用@JmsListener来收听主题
@Component
public class AMQListner {
BlockingQueue<MessageBO> queue = new ArrayBlockingQueue<>(1024);
@JmsListener(destination = "${spring.activemq.topic}")
public void Consume(TextMessage message) {
浏览 1提问于2018-03-14得票数 1
回答已采纳
我用的是弹簧和天蓝色的服务巴士。我试图使用选择器来区分消息类型，但是我无法让它工作。这是我的密码。
@Component
@Slf4j
public class MessageTestRunner implements CommandLineRunner {
private static final String QUEUE_NAME = "lva-test-queue";
private static final String PING_SELECTOR = "selector = 'PING'";
private s
浏览 1提问于2021-12-02得票数 2
回答已采纳
下载Artemis2.13.0，预先创建一个多播地址测试，然后在这个地址上创建一个多播队列123，使用控制台向123队列发送1条消息
使用IDEA创建一个springboot项目，pom文件导入以下依赖项
org.springframework.boot spring-启动器-artemis org.springframework spring-jms 5.2.5. compile编译org.apache.activemq artemis-jms-client 2.13.0编译
pplication.properties添加配置
spring.artemis.mod
浏览 0提问于2020-06-06得票数 2
我有一个Spring应用程序，我想使用JmsListener连接到IBM。这是我的配置：
package com.in28minutes.example.layering.model;
import com.ibm.mq.jms.JMSC;
import com.ibm.mq.jms.MQQueueConnectionFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.spri
浏览 3提问于2021-07-18得票数 0
回答已采纳
我使用的是“SpringBoot-2.1.5.RELEASE”和“SpringFramework-5.1.7.RELEASE”。JMS侦听器注释不是从MQ队列中选择消息。没有错误日志在我的IntelliJ想法中滚动。关于我的项目，我公开了一个REST服务，它发送和接收来自MQ的消息(使用JMSTemplate注释)。直到现在它才起作用。现在我必须添加另一个类，它应该侦听队列。因此添加了@JMSListener注释，它没有选择任何消息。任何洞察力都会很有帮助。
pom低于指定的依赖项。
<dependency>
<groupId>com.ibm.mq</gr
浏览 2提问于2020-06-13得票数 0
喂，
有了这三门课，我发现了一个问题：
package xpadro.spring.jms;
import javax.jms.ConnectionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.conte
浏览 1提问于2016-01-25得票数 0
回答已采纳
3回答
如何停止和启动jms监听器
、、、、
我使用的是Spring，并且我有一个JMS队列来将消息从客户端发送到服务器。我想在服务器关闭时停止发送消息，并在服务器重新启动时重新发送它们。
我知道以前有人问过，但我不能让它起作用。我创建了一个JmsListener并给它一个ID，但是我不能为了停止\启动它而得到它的容器。
@Resource(name="testId")
private AbstractJmsListeningContainer _probeUpdatesListenerContainer;
public void testSendJms() {
_jmsTemplate.convertAndS
浏览 1提问于2017-02-07得票数 2
1回答
我使用带有CLIENT_Acknowledge会话类型的jmsListener在我的spring boot应用程序中轮询sqs，它工作得很好，对于错误，我只是抛出一个异常，JmsListener会将消息放回SQS上。我添加了@Async和@EnableAsync的注释(在配置中) SimpleAsyncUncaughtExceptionHandler.class正在捕获异常。我相信这就是为什么sqs消息在出错的情况下没有发送到sqs的原因。请让我知道带有@jmsListener注释的@Async注释是否有意义。 @Async
@JmsListener(destination = "$
浏览 56提问于2021-04-15得票数 0
由于无法到达目标，我正在尝试恢复发送回ActiveMQ队列的消息。由于不符合我的要求，我避免了再交货的政策。我需要使用session.recover()在我的应用程序中的确切时间恢复这些消息。
目前，我在spring引导中使用了接近默认的jms配置，该配置允许使用@JmsListener注释。但是，我找不到一种方法来获取这个注释使用的活动jms会话的句柄？
浏览 0提问于2019-03-07得票数 3
回答已采纳
我有Spring启动应用程序 它正在从ActiveMQ接收Json格式的消息 @Component class Receiver {
@JmsListener(destination = "queue")
public void receiveMessage(BusMessage message) {
System.out.println("Received <" + message + ">");
} 问题是，有时Json可能会在没有正确的报头的情况下到达 在这种情况下，我会得到异常 org
浏览 12提问于2019-03-05得票数 0
回答已采纳
我需要使用mockito测试JMS侦听器方法。 在测试类中，当我添加@MockBean来验证对模拟bean的某些方法调用时，测试失败。 package com.practice.ActiveMqPractice.listner;
import com.practice.ActiveMqPractice.utility.StringUtility;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.EnableJms;
import
浏览 17提问于2021-05-06得票数 0
3回答
我有一个使用spring的spring引导应用程序。有没有办法告诉测试方法等待jms lister使用它完成执行而不使用将要测试的实际代码中的闩锁？
以下是JMS侦听器代码：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
import javax.jms.Message;
import javax.jms.Q
浏览 0提问于2019-01-29得票数 1
我正在编写一个Spring应用程序，它将侦听一个或多个JMS主题。我们选择了ActiveMQ作为我们的JMS实现。
我们主要关注的是性能和可伸缩性。我们期待着每一秒都会有数千条信息到达。我们提出了两种选择：
使用单个主题和一个@JmsListener方法。在侦听器内部，检查JMS属性以确定处理消息的正确策略。
@JmsListener(目的=“响应”，containerFactory = "myTopicFactory")公共空onMessage(消息)抛出IOException { message.getProperty("message.type") J
浏览 1提问于2016-09-29得票数 1
1回答
我正在使用JMS从IBM MQ message broker发送接收消息。我目前正在处理侦听器服务抛出未处理的异常和没有确认就发送回队列的消息。我希望服务重试可配置的次数，并抛出完整的异常消息，表明侦听器服务不可用。
我的监听器和容器工厂如下所示。
@JmsListener(destination = "testqueue", containerFactory = "queuejmsfactory")
public void consumer(String message) throws JMSException
{ handle(message); }
@
浏览 20提问于2020-05-24得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
