@JmsListener未从集成测试调用
是一个问题，它涉及到消息队列的集成测试和消息监听器的调用问题。
消息队列是一种在应用程序之间传递消息的机制，它可以实现解耦和异步通信。而@JmsListener是Spring框架提供的注解，用于监听和处理消息队列中的消息。
在集成测试中，我们通常会模拟消息的发送和接收，以验证消息队列的功能是否正常。然而，如果@JmsListener未被调用，可能有以下几个原因：
- 配置错误：检查消息队列的配置是否正确，包括队列名称、连接信息、认证等。确保@JmsListener注解与消息队列的配置相匹配。
- 消息发送问题：检查消息的发送是否成功，可以通过查看消息队列的监控工具或日志来确认消息是否被正确发送到队列中。
- 监听器注册问题：确保@JmsListener注解被正确注册，并且监听器的方法签名和参数与消息队列中的消息类型相匹配。可以检查Spring配置文件或注解扫描的设置。
- 测试环境问题：检查集成测试环境是否正确配置，包括消息队列的连接、权限等。确保测试环境与生产环境的配置一致。
针对这个问题，腾讯云提供了一系列的云原生解决方案，包括消息队列服务、容器服务、云原生数据库等，可以帮助开发者构建可靠的云原生应用。推荐使用腾讯云的消息队列服务（CMQ）来实现消息队列功能，详情请参考腾讯云CMQ产品介绍：腾讯云消息队列 CMQ
同时，腾讯云还提供了云原生应用开发框架TKE（Tencent Kubernetes Engine），可以帮助开发者快速搭建和管理容器化应用，详情请参考腾讯云TKE产品介绍：腾讯云容器服务 TKE
总结：@JmsListener未从集成测试调用可能是配置错误、消息发送问题、监听器注册问题或测试环境问题导致的。腾讯云提供了消息队列服务和云原生应用开发框架，可以帮助解决这些问题。
相关·内容
1回答
我已经将ActiveMQ与我的Spring-Boot应用程序集成在一起，它工作得很好。但是当我试图为我的带有嵌入式ActiveMQ的@JmsListener创建集成测试时，它只查找外部ActiveMQ，而不是内部But。 所以我的案子总是失败。有没有办法用application-test.yml覆盖默认的application.yml，这样我的接收器调用就会让@JmsListner查找嵌入式代理url，而不是外部url(我已经在application.yml中声明了)
浏览 5提问于2019-01-02得票数 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
回答已采纳
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
当使用spring集成时，我看到性能下降。
IntegrationFlows.from(Jms.inboundGateway(connectionFactory)
.destination("orderQueue")
.jmsMessageConverter(new MarshallingMessageConverter(jaxbMarshaller()))
.transform(orderTransformer)
浏览 1提问于2018-05-15得票数 0
回答已采纳
我正在尝试将我的工作spring集成xml配置转换为注释，我想知道应该为消息驱动的通道使用什么注释，或者是否有注释？会是@JMSListener吗？
<jms:message-driven-channel-adapter id="jmsIn"
channel="jmsInChannel"
destination="request"
error-channel="errorChannel"/>
浏览 8提问于2016-03-16得票数 2
回答已采纳
1回答
我有一个@JmsListener方法，它接收一个参数并返回一个对象实例，所有这些都使用XML和JAXB编组。
@JmsListener(
containerFactory = ...,
destination = ...,
selector = ...
)
public RunReport.Response run(RunReport runReport) throws Exception
{
// ...
RunReport.Response response = new RunReport.Response();
return respon
浏览 1提问于2018-06-28得票数 0
回答已采纳
我有两个应用程序，一个是发送请求，另一个是应答，我正在尝试使用@JmsListener实现它。 下面的代码可以工作： public JmsTemplate jmsTemplate (ConnectionFactory connectionFactory){
JmsTemplate jmsTemplate = new JmsTemplate();
jmsTemplate.setConnectionFactory(connectionFactory);
Destination destination = new ActiveMQQueue(
浏览 33提问于2021-01-05得票数 0
1回答
JMS集成测试
、、、、
我正在尝试为JMS服务编写一个集成测试，它看起来像这样。
@JmsListener(destination = "mailbox", containerFactory = "myFactory")
public void receiveMessage(Email message) throws InterruptedException {
try {
sendEmail(message);
}catch (Exception e){
LOGGER.log(Level.SEVERE,"Failed to
浏览 1提问于2017-08-04得票数 0
回答已采纳
我在我的应用程序中使用了spring集成，并使用@ServiceActivator而不是@JmsListener。我需要给MessageListenerContainer分配ID，这样我才能以编程方式启动和停止容器。
有人能帮我理解如何为messageListenerContainer设置id吗？
浏览 4提问于2018-08-31得票数 1
回答已采纳
2回答
@Component
@RequiredArgsConstructor
public class EventListener {
private final EventProcessingService eventProcessingService;
@JmsListener(destination = "inputQueue", constainerFactory = "myContainerFactory)
public void receiveMessage(Message mes
浏览 0提问于2021-02-10得票数 0
回答已采纳
我想使用spring为ActiveMQ JMS侦听器编写spock测试用例。有人能分享一下该怎么做吗。我遵循这里提到的步骤，来创建侦听器。下面是我想编写单元测试的代码
@JmsListener( containerFactory = "myFactory", destination = "some q")
public void processMesg( OrderRequest order ) {
-------------------------
}
浏览 0提问于2016-11-21得票数 0
回答已采纳
我想测试一个ActiveMQ消息传递(SpringBoot in-memory)系统。我的问题是JUnit @Test不允许方法使用参数，但是@JmsListener需要一个参数。我该如何测试这个案例呢？我也不知道如何使用JUnit Parameterized.class做到这一点？有没有办法用SpringBoot @JmsListener运行测试？有谁可以帮我？ 注意：mqSend.sendJson()发送的jsonString与您在代码片段中看到的相同。 谢谢你的建议。 @Autowired
private MqSend mqSend;
@MockBean
private JmsTem
浏览 61提问于2020-07-21得票数 3
回答已采纳
我在集成测试中有一个实例，在我的SetUp方法中，我想清除服务器中的所有队列。我似乎找不到任何方法可以做到这一点。出于性能原因，我希望避免为每个测试重新创建Artemis服务器bean。我只是遗漏了什么吗？
我都试过了：
System.out.println(testBroker.locateQueue(new SimpleString(queueName)).deleteAllReferences());
System.out.println(testBroker.locateQueue(new SimpleString(queueName)).getMessageCount());
以
浏览 0提问于2019-04-23得票数 0
回答已采纳
我有一个与JMS - Spring Boot和ActiveMQ相关的相当标准的设置。它可以正常工作，直到我尝试做一个简单的集成测试。经过一些调查后，我发现Spring上下文和嵌入式代理都是在第一个JMS消息被消耗后关闭的，不管在消费期间触发了另一个事件。我能够通过在测试设置中添加useShutdownHook=false连接选项来解决代理问题，即
spring.activemq.broker-url = vm://broker?async=false&broker.persistent=false&broker.useShutdownHook=false
我所要寻找的基本上是一
浏览 2提问于2018-03-14得票数 15
回答已采纳
我使用的是spring引导版本1.3.2。我使用@JmsListener来使用activemq中的消息，用于我使用JmsTemplate创建/生成的消息。以下是代码：
@JmsListener(destination = "myqueue")
public void consumeMsg(Object requestBody)
try {
javaMailSender.send(requestBody);
} catch (MailException ex) {
LOG.error(ex.getLocalizedMessage()
浏览 1提问于2016-03-16得票数 2
回答已采纳
我正在编写一个Spring应用程序，它将侦听一个或多个JMS主题。我们选择了ActiveMQ作为我们的JMS实现。
我们主要关注的是性能和可伸缩性。我们期待着每一秒都会有数千条信息到达。我们提出了两种选择：
使用单个主题和一个@JmsListener方法。在侦听器内部，检查JMS属性以确定处理消息的正确策略。
@JmsListener(目的=“响应”，containerFactory = "myTopicFactory")公共空onMessage(消息)抛出IOException { message.getProperty("message.type") J
浏览 1提问于2016-09-29得票数 1
我在我的context.xml中定义了一个JMS*监听器-容器*，如下所示：
<jms:listener-container connection-factory="connectionFactory" acknowledge="auto" destination-type="topic" >
<jms:listener id="listener" destination="${jms_topic}" ref="jmsListener" method="onMess
浏览 3提问于2013-04-29得票数 0
回答已采纳
我这样创建一个消息处理程序： @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
我想用Spring boot为ActiveMQ配置独占消费者，用java配置很容易
queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true");
consumer = session.createConsumer(queue);
但是使用Spring引导时，listener的配置如下所示。
@JmsListener(destination = "TEST.QUEUE", containerFactory = "myFactory")
public void receive
浏览 0提问于2018-12-03得票数 2
2回答
我目前有一个JMSListener，如下所示。它使用属性文件中的值的选择器。这可以很好地工作。
@JmsListener(destination = "myQueueDest",
selector = MyHeaders.SELECTOR_KEY + " = '${myapp.selector_val}'")
private void consumeData(MyCustomObj mycustomObj) { }
我现在需要使用一个在内存中有值的动态选择器，而不是spring属性。有没有一种方法可以使用JMSListener (或
浏览 7提问于2016-09-13得票数 2
根据this教程，我正在使用@EnableJms和@JmsListener注释在我的应用程序中注册一个队列侦听器。我正在连接到IBM MQ，使用jndi获取连接工厂。我读过关于确认模式等的文章，但这对我来说仍然是一个新事物。我的问题是消息不会返回到队列中(侦听器再也不会被调用)。 @Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
DefaultJmsListenerContainerFactory factory
= new DefaultJmsListener
浏览 75提问于2019-01-29得票数 0
1回答
我在一个队列上有两个@JmsListener实例，我希望从队列中获取固定数量的消息，然后将其余消息保存在挂起的时间内进行批量处理。我添加了条件来检查挂起消息的数量，但是由于两个侦听器失败了。另外，我必须只在@JmsListener中添加这个条件。
请建议如何添加从队列中获取固定消息的逻辑，并将其余消息保存在挂起中以实现节流。
浏览 11提问于2022-09-29得票数 0
如何像spring中的@JmsListener一样在micronaut中创建自定义注释并为其实现逻辑？ @Component
public class ArtemisCusumer {
@JmsListener(destination = "someQueue")
public void processMessage(String content) throws Exception {
System.out.println("recivemessage:"+content);
throw new Excepti
浏览 32提问于2019-02-19得票数 0
我一直在Springboot应用程序中编写JMS侦听器。我用了两种方法：
1)定义一个类似于SimpleMessageListenerContainer的bean：
@Bean
SimpleMessageListenerContainer getMyMessageListenerContainer(ConnectionFactory connectionFactory) {
MessageListenerAdapter messageListener = new MessageListenerAdapter(myService);
message
浏览 2提问于2015-05-10得票数 1
回答已采纳
使用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
回答已采纳
我使用的是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
我目前有一个JMSListener，它配置了以下线程池：
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);
executor.setMaxPoolSize(10);
executor.initialize();
我所侦听的队列有100多条消息，当我启动侦听器时，它将处理前10条消息，没有问题，然后我将获得其余消息的TaskRejectedException异常。
我的意图是，如果没有可用的线程来处理所述消息，@JmsListen
浏览 4提问于2017-12-20得票数 0
我想澄清的是，如果我将多个@jmsListener放在一个方法上，那么它是如何工作的呢？它是否会像多个单独的JMS侦听器一样并行工作？或者，它将像一个JMS侦听器一样依次工作？
比如：
@JmsListener(destination = "queue.name1", containerFactory = "jmsListenerContainerFactory")
@JmsListener(destination = "queue.name2", containerFactory = "jmsListenerContai
浏览 3提问于2020-12-29得票数 1
回答已采纳
我有一个使用JMS的Spring (ActiveMQ)
我有以下几点：
@Bean
public DefaultJmsListenerContainerFactory jmsListenerQueueContainerFactoryForSection01(ConnectionFactory selectedConnectionFactory) {
DefaultJmsListenerContainerFactory djlcf = new DefaultJmsListenerContainerFactory();
djlcf.setClientId("
浏览 2提问于2016-05-25得票数 0
回答已采纳
在寻找了几天之后，我在使用来自IBM MQ的消息时遇到了问题。我遵循了文档，但系统仍然不能正常工作。我使用的是4.8.0和MQ 7.5.0.2
错误
[2014-02-06 01:06:14,341] ERROR - JMSListener Unable to continue server startup as it seems the JMS Provider is not yet started. Please start the JMS provider now.
[2014-02-06 01:06:14,342] ERROR - JMSListener Connection atte
浏览 2提问于2014-02-06得票数 4
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
我使用JMS并通过注释创建了一个WebSphere侦听器来读取传入的消息：
@JmsListener(目的地= "${queues.input}"，containerFactory = "listenerFactory")
传入的消息有一个名为会计令牌 set的MQMD字段，我想阅读它。在阅读IBM时，我需要将目标的WMQ_MQMD_READ_ENABLED属性设置为true。但是，我配置JmsListener的方式只是注释中的一个字符串名称。我该如何设置这个属性？
浏览 4提问于2017-04-26得票数 2
回答已采纳
使用以下JmsListener：
@JmsListener(destination = JMS_FOO_QUEUE, concurrency = "1", selector = JMS_BAR_SELECTOR)
public void receiveMessage(Message message) {
logger.debug("ENTER receiveMessage(), message= {}", message);
service.doStuff(message); //slow or long running task in spri
浏览 0提问于2018-09-28得票数 0
如何通过@JmsListener只更改一个方法的默认并发性？我向@JmsListener添加了并发性(如下所示)，但是在"JBoss管理控制台运行时JmsListener“中没有任何改变。我有JBoss 6.4，SpringJMSVersion4.3.1.RELEASE。
我的听众：
@JmsListener(containerFactory = "myJmsQueueListenerContainerFactory", destination = "some.destination", concurrency = "3-10")
@Se
浏览 1提问于2016-12-01得票数 3
以下代码不起作用：
@JmsListener(destination = "${myDestination}", containerFactory = "jmsContainerFactory")
public void receive(String message) {
// do something
}
如何将application.properties文件中定义的application.properties值注入JmsListener？
浏览 0提问于2016-07-05得票数 1
回答已采纳
2回答
我使用@JmsListener注释从队列接收所有消息
@JmsListener(destination = MyQueue, selector = "MAINST = '" + instanceName + "'")
public void receivMsg(Message message) {
但是另一个系统不能处理消息属性。它使用关联id进行响应。当LinkedList<String>中有相关in时，如何根据相关in过滤消息
浏览 0提问于2018-01-22得票数 2
我正在阅读关于如何启动spring应用程序的正式入门文章。
@EnableJms触发使用@JmsListener注释的方法的发现，从而在封面下创建消息侦听器容器。
但是我的应用程序看到没有@JmsListener注释的@EnableJms方法。
也许是其他的东西迫使spring搜索@EnableJms方法。我想知道。
项目结构：
听众：
@Component
public class Listener {
@JmsListener(destination = "my_queue_new")
public void receive(Email
浏览 1提问于2017-08-21得票数 5
回答已采纳
在我的项目中，我添加了两个不同的JmsListener，但是当我在ActiveMQ面板中运行项目时，只有其中一个主题有使用者！
那么，我应该为每个jmsListenerContainerFactory添加单独的JmsListener配置吗？
@JmsListener(destination = "foo1")
public void foo1(final Message jsonMessage) throws JMSException {
...
}
@JmsListener(destination = "foo2")
public void foo1
浏览 1提问于2018-02-03得票数 15
回答已采纳
我使用@JmsListener来使用队列中的消息。因为这需要DefaultJmsListenerContainerFactory作为连接工厂，所以我们可以将并发设置为
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory ()
factory.setConcurrency("1-1");
问题是，我们能否以编程的方式获得并发消费者的数量？
就像使用DefaultMessageListenerContainer一样，我们能够使用getConcurrentConsum
浏览 17提问于2022-04-11得票数 0
回答已采纳
1回答
我使用@JmsListener注释的方法监听JMS消息，如下所示。
@JmsListener(destination = "Queue")
public void handleMessage(String message) {//implicit message type conversion
System.out.println("received: "+message);
}
如何将其转换为活页夹？
浏览 6提问于2018-02-23得票数 0
我可以将多个类型的实例写到给定的目的地，例如：
JmsTemplate template = ...
Alpha alpha = new Alpha(...);
Beta beta = new Beta(...);
template.convertAndSend("my-destination", alpha);
template.convertAndSend("my-destination", beta);
我想我可以提供多个带@JmsListener注释的方法来接收不同的消息负载-就像这样：
@JmsListener(destination = "
浏览 0提问于2017-03-08得票数 5
我有一个设置，在这里我必须从ActiveMQ代理中的队列读取一条消息。一旦消息被读取，我必须对消息执行一个长时间运行的操作。
由于对消息的这一长期运行操作，我希望尽快确认消息，以便释放代理上的资源。计划是在收到消息后执行下列步骤：
从ActiveMQ获取消息
将消息插入DB中
确认讯息
使用消息执行一些长时间运行的操作。
我读过JMS和不同的确认模式，所以在尝试之前，我决定建立一个应用程序，在那里我可以尝试不同的模式来理解它们是如何的进程，不幸的是，我似乎无法获得我想要的输出。
根据答案和中的信息，我认为使用AUTO_ACKNOWLEDGE可以在调用侦听器之前确认消息，
浏览 0提问于2019-07-21得票数 2
回答已采纳
我正在使用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
回答已采纳
1回答
MyProjectJmsListenerContainerFactory类：
@Configuration
public class MyProjectJmsListenerContainerFactory {
@Bean
public JmsListenerContainerFactory<?> myFactory(
ConnectionFactory connectionFactory,
DefaultJmsListenerContainerFactoryConfigurer configurer,
浏览 0提问于2018-04-16得票数 0
回答已采纳
2回答
我已经开发了一个@JMSListener，它可以从Java属性获得目的地，并且工作得很好。
但是现在我需要能够在运行时更改队列的“目的地”，而不必重置整个应用程序，即使在运行时修改Properties，队列“目的地”也不会改变。
下面是如何实现@JMSListener：
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
impo
浏览 0提问于2020-02-28得票数 0
回答已采纳
1回答
我已经实现了@JmsListener来监听生产者的消息。
APP <- Consumer <- Producer
因此，正如上面所示，Consumer正在使用来自生产者和调用应用程序(APP)的消息来处理这些消息，在这种情况下，应用程序是缓慢的，我们希望限制我们从队列(Consumer <- Producer)中消费的消息的速率。
@JmsListener(
containerFactory = XXX destination = XXX) public void receive(Message message) throws JMSException {
浏览 3提问于2020-10-27得票数 0
回答已采纳
1回答
我有一个通过注释配置的Spring应用程序，并且在JMS监听器启动之前，我试图向应用程序提供一些信息。之后，我想手动启动侦听器。
具有以下配置：
@Bean(name = "queueContainerFactory")
public JmsListenerContainerFactory<?> queue(ConnectionFactory cf) {
SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
Active
浏览 6提问于2016-09-20得票数 2
回答已采纳
3回答
如何停止和启动jms监听器
、、、、
我使用的是Spring，并且我有一个JMS队列来将消息从客户端发送到服务器。我想在服务器关闭时停止发送消息，并在服务器重新启动时重新发送它们。
我知道以前有人问过，但我不能让它起作用。我创建了一个JmsListener并给它一个ID，但是我不能为了停止\启动它而得到它的容器。
@Resource(name="testId")
private AbstractJmsListeningContainer _probeUpdatesListenerContainer;
public void testSendJms() {
_jmsTemplate.convertAndS
浏览 1提问于2017-02-07得票数 2
几个月前，我在这篇文章中问到了一个基本相同的问题：，但我得到的只是一条微不足道的评论，暗示我“重写我的听众，做我想做的事”。这句话很有道理，但在我眼里还不清楚，因为我还在应付Spring。从那时起，我就学到了，我想更直接地问这个问题(而不是对旧的问题悬赏)。
我用@Configuration和@EnableJms设置了一个带注释的bean类，容器工厂如下所示：
@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
DefaultJmsListenerContaine
浏览 0提问于2016-08-04得票数 6
回答已采纳
我有一个使用JMSListener从WebsphereMQ队列中读取消息的项目。我对此的要求之一是连接到多个队列，并将它们放到JMSListener连接到的“主”队列中。为此，我循环遍历队列列表，并使用IBM的MQ包从循环中的队列进行浏览，然后写入“主”队列。这是我的读写方法(它们没有错，只是为了获取信息)：
public String readFromErrorQueue(MyErrorQueue errorQueue,
MQGetMessageOptions getMsgOpts) throws MQException, IOException {
浏览 2提问于2016-05-13得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
