spring-jms相关内容
我们使用IBM MQ以请求/答复的方式与第三方进行通信.我们向他们发送请求,他们给我们答复. 当前,我们两个都有一个基于Java的简单本机IBM MQ应用程序. 我们计划使用spring jms重写我们的代码. 但是当使用spring jms时,在给定的时间内我们没有得到任何响应.我们正在使用JMSTemplate来发送或接收消息. 我正在分享我的代码段.我在这里做错什么了吗?我应该在这里设置其他
..
在Spring JMS项目中,我尝试连接到放置在远程服务器中的IBM MQ QUEUE.该代码可以到达IBM MQ服务器并识别MQ Manager,但是当它尝试与QUEUE通信时,该队列的名称在.bindings文件中提到(此文件在IBM MQ Server中生成,我将其复制到本地文件夹中) ,并且我将此文件夹的名称提到为JNDI资源),出现以下错误: INFO - Setup of JMS
..
我们正在尝试使用具有Spring-JMS和Spring事务支持的IBM MQ管理器作为XA事务管理器. IBM MQ Manager在spring-jta支持方面能否很好地发挥作用? 解决方案 您不能将WMQ JMS客户端(spring-jms使用的客户端)与MQ QueueManager用作XA事务管理器一起使用.目的是通过JTA实现的事务管理器(即Java EE应用程序服务器)控制JM
..
我正在使用blueprint.xml构建与我的JMS队列对话的骆驼路线.我遇到了一些神秘的错误,我的Spring Boot应用程序充当队列的使用者,正在将我的xml作为字节消息而不是文本消息发送给我,而Spring使用者对此感到窒息. 这是两条消息,文本之一有效: 2016-06-24 07:08:22,671 | INFO | Sending message: ActiveMQBy
..
试图弄清楚使用JMS设置ApplicationIdData的骆驼/Spring配置. 我知道这样做的Java方法,我在下面设置了MQOO_SET_IDENTITY_CONTEXT int putOptions = MQConstants.MQPMO_SET_IDENTITY_CONTEXT; pmo.options =putOptions; 然后将applicationIdDat
..
我正在研究一个从Azure服务总线读取消息的应用程序.该应用程序是使用Spring Boot,Spring jms和Qpid jms客户端创建的.我能够从Queue正确读取消息,而没有任何问题. PFB我用来阅读消息的代码. @Service public class QueueReceiver { @JmsListener(destination = "testing") public v
..
我是spring boot jms的新手,我看到了类似提供程序配置的内容-> set要预取功能的消息数,我找不到太多有关它的意思,并且我对它的含义不甚了解. 我的并发设置为5-100.这是否意味着,每当产生一个新的使用者时,它将获得消息的数量,如果我将其设置为5,它将立即从队列中获得5条消息吗? 在不使用spring jms的情况下,我们使用一个可以接收最多10条消息的接收调用,在这里
..
我想对下面的简单jms侦听器代码进行单元测试 @Component public class NotificationReader { @JmsListener(destination = "myAppQ") public void receiveMessage(NotificationMessage notificationMessage) { Syste
..
与DefaultMessageListenerContainer相比,使用DefaultJmsListenerContainerFactory有什么优势? 如果我直接配置DMLC,则可以通过调用isRunning()来获取检查状态的句柄.我也确实有启动和停止DMLC的功能 但是,根据新的春季规格,如果我配置DefaultJmsListenerContainerFactory,则无法获得
..
我在任何地方都找不到此信息.我有两个队列,@JmsListener(destination = "p1"),@JmsListener(destination = "p2").如何确保即使我正在侦听2个队列,一次也只能处理1条消息,以及如何配置对首先从中获取消息的队列的轮询,也就是在处理了要轮询的消息之后p1首先.或进行加权轮询:p1:90%,p2:10%.等等. 基本上,我在问如何为Spri
..
用于org.springframework.jms.listener.AbstractMessageListenerContainer的Javadoc指出,如果 将"sessionAcknowledgeMode"设置为"CLIENT_ACKNOWLEDGE":成功执行侦听器后自动进行消息确认;如果发生异常,则不进行重新交付. 我猜想,“如果抛出异常,则不会重新交付"的意思是,即使在jm
..
我正在尝试使用以下代码段收听主题.但是,默认情况下,其监听队列.在这种情况下,没有xml配置.我完全依靠注释.此外,我完全依赖于Spring boot提供的AutoConfiguration.我不确定如何在JmsListener中将目标类型设置为主题.春季JMS专家请帮忙. @Component public class MyTopicListener {
..
在我的Spring Boot应用程序中,我配置了MQQueueConnectionFactory的两个不同实例(不同的ID),因为这是应用程序的需要.为此,我添加了ibm客户端jar. 我还在代码中添加了spring-jms依赖项,因为我想要JmsTemplate等类.添加此依赖项后,JmsAutoConfiguration在类路径中找到JmsTemplate并尝试配置Bean.在此过程中,
..
我正在尝试基于@JmsListener注释创建用于发布-订阅的示例:相关代码段: @Slf4j @SpringBootApplication @EnableScheduling public class JmsPublishSubscribeApplication { public static void main(String[] args) throws Interrupted
..
我需要将消息从一个ActiveMQ实例上的队列移动到另一个ActiveMQ实例上.有没有一种方法可以使用Spring Boot配置连接到两个不同的ActiveMQ实例? 我需要创建多个connectionFactories吗?如果是这样,那么JmsTemplate如何知道要连接到哪个ActiveMQ实例? @Bean public ConnectionFactory con
..
嗨,我是Spring JMS和Websphere MQ的新手.任何人都可以给我逐步的过程或示例,以了解如何从Websphere MQ接收消息并能够在控制台中打印该消息. 非常感谢您的帮助 解决方案 以下是使用Spring MDP/Activation Spec for Websphere MQ的工作示例 mdp-listener.xml
..
我正在尝试在我们非常小的和简单的Spring Boot应用程序中跟踪和识别导致内存泄漏的根本原因. 它使用以下内容: -Spring Boot 2.2.4 -azure-servicebus-jms-spring-boot-starter 2.2.1 -MSSQL 功能: 该应用程序仅调度Azure ServiceBus队列并存储数据,并将数据发送到其他目标. 这是一个小型应用程序,因
..
如果我对Spring文档的理解正确,请向我解释. Spring docs指出: https ://docs.spring.io/spring/docs/current/spring-framework-reference/integration.html#jms-tx (...)在非托管环境中使用JmsTemplate时,可以通过使用sessionTransacted和sessionA
..
在使用JMSTemplate连接到IBM Websphere MQ时遇到了这个非常奇怪的问题.代码在Eclipse中运行得很好,但是当我使用阴影插件将项目和所有依赖项打包到Uber jar中时,执行jar文件时出现此错误: com.ibm.msg.client.jms.DetailedJMSException: JMSCC0091: The provider factory for con
..
我正在使用ActiveMQ(带有Spring)将消息发送到远程OSGi-Container。 这很好用,但是有一个问题。 我有两个实现Serializable的类。一个类是另一个类的类成员,例如: public类成员实现Serializble { private int someValue; private static final long serialVersionUID
..