jmstemplate

0열

1답변

리스너를 듣고 일정 기간 중지하고 시작 : <bean id="msglistenerForAuditEvent" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="jmsFactory"/>

0열

1답변

애플리케이션 서버가 갑자기 멈추었을 때 Spring JMS와 ActiveMQ로 JMS 메시지가 손실된다.

애플리케이션 시작시 액티브 MQ 큐에 연결하는 JMS Listener가있는 Spring JMS 애플리케이션이있다. 이 JMS 수신기는 메시지를 가져 와서 내용을 풍부하게 한 다음 동일한 ActiveMQ 브로커의 항목으로 전달하는 응용 프로그램의 일부입니다. sessionTransacted가 True로 설정됩니다. 데이터베이스 트랜잭션을 수행하지 않으므로 @

0열

2답변

JMS 메시지의 JMSMessageID를 사용자 정의하지 않습니다.

Azure Queue로 푸시하기 전에 JMSMessageID를 사용자 정의하려고합니다. 어떤 이유로이 ID가 대기열에 들어 가지 않고 MessageID에 대해 생성 된 임의의 ID가 표시됩니다. 코드를 디버깅 할 때 messageProducer.send (message)가 호출 될 때까지 messageID가 올바르게 설정되어 있음을 알 수 있습니다. JMS

0열

1답변

JmsTemplate with CachingConnectionFactory IBM MQ 큐용 연결 복구

JmsTemplate을 사용하여 동일한 클라이언트에서 두 개의 IBM MQ 서버에 연결하고 있습니다. IBM MQ 연결 팩토리의 setClientReconnectOptions뿐만 아니라 JmsTemplate의 reconnectOnException도 구성했습니다. 스프링 빈 정의 : <bean id="firstMQCachingConnectionFactory"

0열

1답변

봄 JMS 웹 스피어 MQ 연결 오류에

AppConfig.xml 설정 : <bean id="connectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="hostName" value="abchost.com /> <property name="port" value="1414" /> <property name

1열

1답변

큐에서 다른 메시지를 차단하지 않고 요청/응답과 함께 Spring JMSTemplate/ActiveMQ 사용

우리는 응답을 기다리고 싶은 특정 유스 케이스에 대해 분산 요청/응답 유형 아키텍처를 구현했습니다. 우리가 사용하는 JMS 브로커는 ActiveMq이고 코드는 Spring을 사용하여 함께 연결됩니다. 같은 대상에 많은 요청을 보내는 경우 완료하는 데 많은 시간이 걸리는 요청은 그 다음에 오는 요청 메시지를 차단하는 것처럼 보입니다. 소비자가 사용하는 Ses

-2열

1답변

Camel ProducerTemplate은 모든 메시지에 동일한 JMSCorrelationID를 사용하고 생성 된 각 메시지에 대해 고유 ID를 얻는 방법은 무엇입니까?

는 내가 메시지를 생성하는 내 서비스 중 하나에이 빈을 주입하고 <camel:template id="msgProducerTemplate" /> 낙타 를 사용하여 생산자 템플릿을 정의했다. 이것은 CorrelationID를 생성 생산하고 모든 메시지에 대한 msgProducerTemplate.sendBodyAndHeaders(endpointUri, messa

2열

1답변

Setsessiontransacted가 Pub/Sub 모델을 사용하여 JMSTemplate 및 DefaultMessageListenerContainer에서 작동하는 방식

JMSTemplate을 사용하여 주제에 메시지를 게시하는 게시자/구독자 모델을 사용하고 있습니다. defaultmessagelistenercontainer를 사용하여 메시지를 구독하고 수신합니다. 두 설정 모두에서 sessionTransacted를 true로 설정할 수 있음을 알고 있습니다. 하지만 넣으면 어떻게 될까요? 1) JMSTemplate sets

0열

1답변

JMS 템플릿, 내가 어떻게 하나의 큐에서 메시지를 수신하고 이미 받았다 될 때 수신 된 메시지는 메시지의 손실이있을 것입니다 전송하는 동안 예외가 발생하면 JMS 템플릿을

public void sendSimpleMessage(String receiver, String sender) { try { Message message = jmsTemplate.receive(receiver); System.out.println(message.getIntProperty("OlQuestionId"));

0열

1답변

어떻게 봄 3.05 및 J 보스 5.1 (JBossMQ와)를 사용하여 JMS 로컬 큐를 구현하는 방법?

는 보스 5.1 서버에 봄 3.0.5 프레임 워크 실행을 기반으로하는 응용 프로그램이 있습니다. 나는이 tutorial을 따르려고했는데, 그것은 ActiveMQ를 브로커 대신 JBossMQ와 (기본 JBoss의 5.1 브로커)를 사용합니다. 는 나는 이미 보스의 설정에서이 MyQueue (목적지를-service.xml) 라는 대기열을 설정 한 : <mbea