spring-jms 相关问题

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

如何为TomEE构建和部署Spring Boot no-web应用程序?

我有一个简单的Spring Boot JMS应用程序。它没有web层,我不想将web层添加到该应用程序。它应该只是一个隐藏在Web上的JMS微服务。但我想在里面运行它......

回答 1 投票 0

负载平衡客户端会话

我有一个2服务器ActiveMQ Artemis集群设置与发现使用JGroups正常工作。然后在我的应用程序中,ConnectionFactory通过ActiveMQJMSClient创建:final ...

回答 1 投票 0

Spring集成org.springframework.integration.MessageTimeoutException处理

我有以下spring集成流:@Bean public IntegrationFlow innerInFlow(@Value(“$ {jm s.concurrency:10}”)String concurrency){return IntegrationFlows ...

回答 1 投票 1

在Spring Boot中,如何声明我的JMS服务器是嵌入式的?

Spring Boot文档简要介绍了嵌入式JMS服务器:“你看不到定义的两个bean是JmsTemplate和ConnectionFactory。这些是自动创建的...

回答 1 投票 0

@jmslistener与同一容器工厂共享线程池

我在春季启动时有2个jmsliteners设置:@EnableJms @JmsListener(id =“A1”,destination =“dest1”,containerFactory =“factory1”)@JmsListener(id =“A2”,destination =“dest2”,. ..

回答 1 投票 0

ActiveMQ经纪人重新发送和DLQ没有工作

我在conf / activemq.xml中设置了关于Redelivery和DLQ处理的配置,如https://activemq.apache.org/message-redelivery-and-dlq-handling.html但是当我尝试将异常抛给...时

回答 1 投票 0

JMS和Spring批处理

我们的项目是使用每个的rest api集成两个应用程序,使用JMS(提供异步性质)和spring批处理从JMS队列读取批量数据并处理它然后发布它...

回答 1 投票 8

路由之间的JMS提交 - 我想在Camel中的路由之间提交事务

我在camel中使用JMS Transaction我有两条路由(“jms:queue:test).process(new Processor(Exchange exchange){//将消息放入hdfs //使用hadoop fs api})。to(”direct :ssh“)......

回答 1 投票 0

Spring JMS - 在消息转换之前访问原始消息

我使用消息转换器将XML消息从队列转换为Java对象,它工作正常。由于我的JMSMessageListener直接获得POJO,我想知道有什么方法我...

回答 1 投票 1

junit spring jms听众

我想在@Component公共类NotificationReader {@JmsListener(destination =“myAppQ”)下面单元测试一个简单的jms监听器代码public void receiveMessage(NotificationMessage ...

回答 1 投票 1

Spring Integration的DefaultMessageListenerContainer和JPA中的事务

假设我有简单的IntegrationFlow,它以异步方式读取JMS消息,转换,应用业务逻辑等。@Bean public IntegrationFlow upstreamEventFlow(){return ...

回答 1 投票 1

在发送消息之后立即检索JMS标题而不消耗消息

如何在发送消息后检索JMS消息头但不消息?这是我的消息发送代码jmsTemplate.convertAndSend(que,text,message - > {...

回答 1 投票 1

在spring中限制@JmsListener(阻止TaskRejectedException)

我目前有一个配置了以下线程池的JMSListener:ThreadPoolTask Executor executor = new ThreadPoolTask Executor(); executor.setCorePoolSize(5);执行....

回答 1 投票 0

Spring-boot应用程序与Apache Artemis集群连接

Spring-Boot可以在类路径上获得Artemis时自动配置连接工厂。但是我们如何将spring-boot应用程序配置为原生Artemis集群(多个节点)

回答 1 投票 0

发送到oracle aq时发生java.lang.NoClassDefFoundError

我在Spring应用程序中遇到以下异常:线程“Thread-0”中的异常线程“Thread-1”中的异常java.lang.NoClassDefFoundError:javax / transaction / Transaction at ...

回答 1 投票 0

ActiveMQ保护队列

我正在寻找一种机制来保护ActiveMQ上的队列访问。我们使用Spring JMS将JMS消息发送到ActiveMQ队列。现在队列在公司内部公开,我们不...

回答 2 投票 1

SimpleMessageConverter将ConcurrentHashMap转换为HashMap

我使用concurrenthashmap payload创建了一个集成消息,如下所示返回MessageBuilder.createMessage(emvMessage.getResponse(),headers);其中emvMessage.getResponse()方法返回...

回答 1 投票 0

如何访问@JmsListener使用的Spring Boot中的活动JMS连接/会话

我正在尝试恢复由于目标无法访问而发送回ActiveMQ队列的消息。我正在避免重新交付政策,因为它不符合我的要求。我需要 ...

回答 1 投票 0

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