我得到了camel (3.5.0)应用程序的弹簧引导(2.3.2.RELEASE)和两个测试路线:
这样做的目的是检查从多播调用的子路由异常发生时会发生什么,以及它如何处理事务。
@Component
public class MyRoute1 extends RouteBuilder {
@Override
public void configure() {
onException(Exception.class)
.useOriginalBody()
.log("Error handler parent. Body is: ${body}
我们有一个使用Spring Boot和Tibco EMS JMS实现的应用程序。当我创建war并在我本地的Tomcat上部署时,我可以毫无问题地发送和接收消息。但是,如果我从main()方法运行应用程序:
@SpringBootApplication
public class Main {
public static void main(String[] args) {
SpringApplication.run(Main.class, args);
}
}
在运行as> Spring Boot App时,只要消息被发送使用,我就会看到这个错误。
这是创建和发送
我在运行Pro Spring 5书籍中的一个示例时获得了JTA异常(12.使用Spring,boot-jms项目)。以下是整个代码(不包括导入)。它只有一个文件Application.java:
@SpringBootApplication
public class Application {
private static Logger logger = LoggerFactory.getLogger(Application.class);
@Bean
public JmsListenerContainerFactory<DefaultMessageListe
我正在使用Apache ActiveMQ 5.15.13和SpringBoot2.3.1.RELEASE,我正在尝试配置持久订阅服务器,但我做不到。运行时的应用程序给出了一个错误,如
Cause: setClientID call not supported on proxy for shared Connection. Set the 'clientId' property on the SingleConnectionFactory instead.
下面是Spring的完整ActiveMQ设置。
JMSConfiguration
public class JMSConfi
我们在weblogic10.3.4和JMS队列上设置,下面是消息监听器代码,它使用Spring JMS,MessageProducer被设置为ClientAcknowledgeMode。当发生异常时,消息仍然被移出队列并重新获得rolle,下面的代码有什么问题吗?
public class EmailListener implements MessageListener,ExceptionListener{
private EmailSend emailSend;
@SuppressWarnings("unchecked")
public v
我开发了一个spring引导应用程序,它使用JMS在Activemq中发送和侦听消息,但是在运行应用程序时,JMS还没有开始使用spring引导
这是主类,Application.java
@SpringBootApplication
@EnableJms
public class Main {
public static void main(String[] args) {
SpringApplication.run(Main.class, args);
}
}
配置类: Config.java
@Configuration
public class Conf
我们有一个将JMS与Tibco消息服务器结合使用的应用程序。它是用Spring实现的。我们的会话是经过处理的会话,确认模式设置为auto。我们可以接收发送到队列的消息,但由于某种原因,commit()方法失败了。
这是一个错误:
2018-07-13 15:50:35.858 WARN 2576 --- [enerContainer-8] o.s.j.l.DefaultMessageListenerContainer : Execution of JMS message listener failed, and no ErrorHandler has been set.
javax.jm
我在我的应用程序中使用了Spring Boot & Spring Data JPA。现在我正致力于将JMS集成到我的应用程序中。添加以下代码后,我将在查询数据库时看到一个错误。 @Configuration
public class ActiveMQProducerConfig {
@Bean
public PlatformTransactionManager createTransactionManager(ConnectionFactory connectionFactory) {
return new JmsTransactionManager(conn
目标
我想向一个主题发送一条信息,稍后我将处理一个客户端应用程序。为此,我使用Spring和及其JMS模块。作为消息代理,我使用本机ActiveMQ Artemis。
,这是我的设置
DemoApplication.java
@SpringBootApplication
public class DemoApplication {
private static final Logger logger = LoggerFactory.getLogger(DemoApplication.class);
public interface StarGate {
v
我有一个spring-jms,spring-boot和rabbitmq-jms的应用程序。
当我尝试发送消息并接收应用程序时,成功地运行。但是,当我在rabbitmq控制台上手动发布消息时,在应用程序侦听时出现了以下错误:
com.rabbitmq.jms.util.RMQJMSException: invalid stream header: 61736466
at com.rabbitmq.jms.client.RMQMessage.fromMessage(RMQMessage.java:1140) ~[rabbitmq-jms-2.3.0.jar:2.3.0]
at co
我在5.1.3中使用JMS入站网关进行了测试
但我犯了以下错误:
Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:138) ~[spring-integration-core-5.1.3.RELEASE.jar:5.1.3.REL
当我使用solace作为消息服务器时,我遇到了这个异常。 MessageListenerContainer - Setup of JMS message listener invoker failed for destination 'XXX.QUE' - trying to recover. Cause: Transacted sessions or XA sessions are not supported with direct transport 我使用SESSION_TRANSACTED手动提交事务 以下是一些配置。 <bean id="solac
我正在使用spring integration int-jms:message-driven-channel-adapter来消费来自solace queue的消息。
我在服务器日志中看到下面提到的错误
org.springframework.jms.listener.DefaultMessageListenerContainer- Execution of JMS message listener failed, and no ErrorHandler has been set.
javax.jms.TransactionRolledBackException: Error comittin
我们正在将我们的项目从Spring2.5.6升级到3.2.3,Hibernate/JPA升级到4.2.3。
在用于事务管理的Springds.xml中,我们替换了下面的配置。
<bean id="transactionManager"
class="org.springframework.transaction.jta.WebSphereUowTransactionManager">
<!-- This property is specifically required for JMS -->
我使用了一个带@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
TLDR:我想知道如何使用apache路由连接到使用spring引导java和默认配置创建的内存中JMS队列。目前,我尝试连接,但它一直显示错误:
未能连接到tcp://localhost:61616之后: 10次继续重试。
我尝试通过添加参数来编辑属性以修改配置和路由,但没有成功。任何帮助都是非常感谢的。我把下面的全部代码留给那些想要详细信息的人。
MainApplication.java
public class MainApplication{
public static void main(String[] args) {
SpringApplicati