spring-jms 相关问题

Spring提供了一个JMS集成框架,它简化了JMS API的使用,就像Spring对JDBC API的集成一样。

有什么方法可以知道 IBM MQ 是否已经附加了任何 JMS 侦听器?

我正在开发一个应用程序,它从数据库中获取队列详细信息列表并为它们旋转 jms 侦听器。 for(final String queueName : queueList){ SimpleJmsListenerEndpoint 端点 =...

回答 0 投票 0

SpringBoot 3.x升级:AQjmsFactory与Jakarta命名空间的版本兼容性问题

在从 2.x 升级到最新的 SpringBoot 版本到 3.x 时,我遇到了 Oracle Advance 队列“AQjmsFactory”与 Jakarta.jms pa 的版本兼容性问题...

回答 0 投票 0

使用主题名称而不是主题字符串连接到 IBM MQ

下面的示例 - 主题名称是 TEST_TOP。但似乎以下方法适用于主题字符串而不是主题名称。想检查我是否可以使用主题名称而不是主题字符串?谢谢!

回答 0 投票 0

如何在Tomcat服务器上并发运行带有JMS的Spring Boot应用程序?

我正在使用 JMS 创建一个 Spring Boot 应用程序。我想使用嵌入式 Tomcat 服务器在本地运行应用程序,以便我可以调用 RestController 并将消息发布到队列。 这是...

回答 1 投票 0

JmsListener 重启时不会在队列中获取消息。如何在重启时获取所有消息?

我有一个 Spring Boot 应用程序可以监听来自 Artemis 的消息。 我注意到如果我停止侦听器应用程序,发送消息 A 并重新启动应用程序,则不会检索到消息 A。 当我...

回答 0 投票 0

添加动态监听数(Spring JMS)

我需要添加多个侦听器,如 application.properties 文件中所述。像下面一样, InTopics=样品.QUT4、样品.T05、样品.T01、样品.JT7 注意:这个数字可能更多...

回答 4 投票 0

IBM Websphere 和 JMS/Active MQ 集成

我想使用 JMS 或 spring-jms 从 IBM Websphere 中托管的应用程序向 Active MQ 发布消息。问题是我可以使用 JMS API 或通过添加 re... 来使用 spring-jms 来做到这一点吗?

回答 2 投票 0

使用 spring-cloud-azure-starter-servicebus-jms 连接到 Azure 服务总线

我正在尝试遵循有关使用 spring-cloud-azure-starter-servicebus-jms 连接到 azure 服务总线的 Microsoft 文档。 参考但没有运气。 文件: 我正在尝试遵循有关使用 spring-cloud-azure-starter-servicebus-jms 连接到 azure 服务总线的 Microsoft 文档。 Ref 但没有运气 . Pom文件: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>3.0.4</version> <relativePath /> <!-- lookup parent from repository --> </parent> <groupId>com.demo</groupId> <artifactId>demo</artifactId> <version>0.0.3-SNAPSHOT</version> <name>springcloud-servicebus-1</name> <description>Demo project for Spring Boot</description> <properties> <java.version>17</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>com.azure.spring</groupId> <artifactId>spring-cloud-azure-starter-servicebus-jms</artifactId> </dependency> </dependencies> <dependencyManagement> <dependencies> <dependency> <groupId>com.azure.spring</groupId> <artifactId>spring-cloud-azure-dependencies</artifactId> <version>4.6.0</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project> Java代码 package com.example.demo; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.jms.annotation.EnableJms; import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.core.JmsTemplate; @SpringBootApplication @EnableJms public class Sample implements CommandLineRunner { private static final Logger LOGGER = LoggerFactory.getLogger(Sample.class); private static final String TOPIC_NAME = "loan-app"; private static final String SUBSCRIPTION_NAME = "loan-app-sub"; @Autowired private JmsTemplate jmsTemplate; public static void main(String[] args) { SpringApplication.run(Sample.class, args); } @Override public void run(String... args) { LOGGER.info("Sending message"); jmsTemplate.convertAndSend(TOPIC_NAME, "Hello Word"); } @JmsListener(destination = TOPIC_NAME, containerFactory = "topicJmsListenerContainerFactory", subscription = SUBSCRIPTION_NAME) public void receiveMessage(String message) { LOGGER.info("Message received: {}", message); } } 错误: 应用程序启动失败 描述: com.example.demo.Sample 中的字段 jmsTemplate 需要一个无法找到类型为“org.springframework.jms.core.JmsTemplate”的 bean。 注入点有如下注解: - @org.springframework.beans.factory.annotation.Autowired(required=true)

回答 0 投票 0

SimpleJdbc调用存储过程参数交换

我们正在使用 AMQP jms 队列和 spring boot 微服务,我们正在从 jms 消息中获取要调用的存储过程名称和参数,我们将调用并使用结果来形成有效载荷以...

回答 0 投票 0

ActiveMQ 5.17.0 和 Spring JMS 6.0.4 不工作

我正在尝试将 spring-jms 5.3.23 迁移到 6.0.4 版本。使用 jakarta jms api 库的 Spring JMS 不适用于 activemq 5.17.0 库。我找不到最新的 activemq

回答 1 投票 0

Spring Integration JMS--Spring代码在RuntimeException时提交了。

我想请教有经验的Spring集成开发者甚至代码作者,关于我的代码遇到的奇怪行为。问题是Spring代码在我的代码上执行COMMIT ...

回答 1 投票 0

jms - MappingJackson2MessageConverter用运行时类设置TypeIdPropertyName。

我试图使用java 11、spring boot 2.2.6和MappingJackson2MessageConverter创建一个通用服务,来处理向MQ发送消息。我想在我的其他服务中使用它作为bean。但是...

回答 1 投票 0

原因是 经纪人:localhost - 客户端:tata_consumer已经从tcp:/127.0.0.1:52917连接。

我是一个新的ActiveMQ和尝试实验工作的主题。我已经创建了一个使用JMS的生产者和两个使用Spring配置的消费者听众。我知道,如果使用多个消费者......

回答 1 投票 0

Spring集成写到IBM MQ

使用Boot 2.2.2和Spring Integration 5.2.2通过IBM MQ Series 9与另一个应用程序交互;消息需要是纯文本(不是JMS)。SI可以正确获取文本消息,但是我...

回答 1 投票 1

在Spring Boot+JMS+IBM MQ耐用主题监听器中设置brokerDurSubQueue属性。

我试图通过Spring引导应用程序使用IBM MQ主题订阅来监听消息。可用的信息(由MQ管理员提供)。Topic name Host Port QueueManager BrokerDurableSubscriptionQueue ...

回答 1 投票 1

Spring Integration Transform故障回滚JMS,未转发到错误通道

使用Boot 2.2.2和Integration 5.2.2--当XML消息从一个文件中获取,并且未能解开marshalling(即它不是XML)时,消息会像预期的那样进入errorChannel。然而,当...

回答 1 投票 0

多个生产者可以在同一时间从不同的java应用中向队列发送消息吗?

我有2个应用程序A和B,试图从这两个应用程序发送消息到一个队列。在两个地方都放置了一个 while 循环,它正在发送消息到队列中。

回答 1 投票 0

春天的批量消息监听器(从DefaultMessageListenerContainer扩展而来)。

我在spring中有一个基本的JMS相关问题。与其一次只消耗一条消息,不如在短时间内(比如说几秒钟)批量处理消息,这样更方便。

回答 1 投票 3

用JMS进行Spring Batch并行处理

我实现了一个spring批处理项目,从weblogic Jms队列中读取数据(自定义项目读取器,而非消息驱动),然后将Jms消息数据传递给一个项目写入器(chunk = 1),在那里我调用了一些API......。

回答 1 投票 0

Artemis集群--多个接受者的负载均衡。

我有一个由4个节点组成的Artemis集群(2个主节点,2个备份节点)。每一个broker都有2个接受者--一个用于核心协议,一个用于stomp协议(因为stomp需要前缀属性)。所以他们...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.