我有一个复杂的技术栈。我正在利用Netflix提供GraphQL服务。幕后有一堆JMS组件,它们从各种服务中发送和接收数据。除了GraphQL订阅之外,我拥有所有的功能。
具体来说,我要做的是为来自一个GraphQL主题的消息创建一个ActiveMQ订阅。
所以我有一个SubscriptionDataFetcher,如下所示:
@DgsComponent
public class SurveyResultsSubscriptionDataFetcher {
private final Publisher<SurveyResult> surveyResultsReactiv
目标
我想向一个主题发送一条信息,稍后我将处理一个客户端应用程序。为此,我使用Spring和及其JMS模块。作为消息代理,我使用本机ActiveMQ Artemis。
,这是我的设置
DemoApplication.java
@SpringBootApplication
public class DemoApplication {
private static final Logger logger = LoggerFactory.getLogger(DemoApplication.class);
public interface StarGate {
v
我已经创建了一个连接到Azure队列并使用消息的应用程序。问题是在240000毫秒的连接自动关闭后,我得到了异常"org.apache.qpid.amqp_1_0.jms.MessageConsumerException: The connection was inactive for more than the allowed 240000 milliseconds and is closed by container。PFB我的配置代码以连接到Azure队列。
@Bean
public ConnectionFactory jmsConnectionFactory() {
我在运行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 camel组件推送到IBM-MQ时出现以下错误。 Error:-
Caused by: com.ibm.msg.client.jms.DetailedMessageFormatException: JMSCC0050: The property name 'JMS_Solace_DeadMsgQueueEligible' is reserved and cannot be set. 下面是我正在使用的pom罐子- <camel-spring-boot-starter.version>2.21.0</camel-spring-boot-s
在尝试从WebSphere 8运行Java8MQ应用程序时,遇到了以下错误:
java.lang.IllegalStateException: Cannot convert value of type 'com.ibm.ejs.jms.JMSQueueConnectionFactoryHandle' to required type 'javax.jms.ConnectionFactory"
经过一些研究,我在这里看到了一些建议,即可以通过删除所有javax.jms jars来解决上述错误。我的war文件中有jms-api-2.0和geronimo-jms_1.
我试图连接到应用程序中的通用消息传递队列。这是我的Config课。
@Configuration
@EnableJms
public class Config {
@Bean
public ActiveMQConnectionFactory receiverActiveMQConnectionFactory() {
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
var properties = new Propert
我试图将application.yml与@value注释一起使用,以便从外部获取jms的设置。但我有个错误:好几天来我都不明白为什么会这样。如果我创建了一个新项目并实现了我的代码,那么所有的对象都会被初始化,而不会出现错误。
错误:
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'appConfiguration': Injection of autowired dependencies failed; nested exception is java
您好,我正在使用Spring集成和JMS集成,我注意到当我尝试在jms-message-drive-outbound-adapter中使用error-channel时,它给出了以下错误;
根据我之前问题的建议,我想检索异常和回滚事务,这样我就不会丢失消息。如果错误通道是不可能的,我该如何实现。
cvc-complex-type.3.2.2: Attribute 'error-channel' is not allowed to appear in element 'jms:message-driven-channel-adapter'.
我的XML如下:
<
我正在编写报告服务以接收来自Azure service Bus主题订阅的消息。我遵循了最初的指南- How to use the Spring Boot Starter for Azure Service Bus JMS,并在我的服务文件中简单地配置了@JmsListener,使其不指定JmsConnectionFactory,这样它将回退到默认值,但是这将返回如下所示的错误日志,其中jmsConnectionFactory Bean返回NullPointerException。 我随后查看了Bauldung - Getting Started with Spring JMS 和Baeldu
我在我的spring boot测试文件中使用了以下注释
@RunWith(SpringRunner.class) // tells JUnit to run using Spring’s testing support.
@SpringBootTest // is saying “bootstrap with Spring Boot’s support” (e.g. load application.properties and give me all the Spring Boot goodness)
@AutoConfigureMockMvc
当我测试rest控制器时,它将显示java.l
我使用Spring JMS IBM MQ来连接SAP bapi服务,但是在发送jms消息时,根据中间件团队的说法,它会自动创建MQMD头作为MQHRF2而不是MQRFH2,这是不正确的。我使用Spring JMS IBM MQ连接SAP BAPI服务,以便将jms消息发送到中间件,但它们得到的是MQHRF2头而不是MQRFH2。所以为了改变这一切我必须做什么?我尝试设置非jms (MQSTR),但它仍然只发送MQHRF2。
我对JNDI解析有问题。 对于这个页面,如果它在Weblogic下,它应该只有这个属性: https://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#boot-features-jms-jndi spring.jms.jndi-name=java:/jms/MyCF JmsTemplate是自动创建的。或者说它应该。但事实并非如此。 我得到了这个例外。 Caused By: javax.naming.NameNotFoundException: While trying to look up /
我有一个基本的项目,我正在使用Spring工具套件。我正在尝试用RabbitMQ实现一个基本的消息传递,但是我无法导入RabbitListener注释。我在IDE RabbitListener is not an annotation type中得到错误消息。
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/