jms

0열

1답변

하나의 저장소 (하나의 마스터 서버에서 관리)에 '자동차'저장소 (다른 슬레이브 서버로 관리)를 동기화해야합니다. 저는 ActiveMQ를 사용하고 있습니다. 마스터가 듣게 될 대기열 (master.car.queue)을 정의했으며 모든 슬레이브는 자신의 자동차 저장소 (5 분마다)를 게시합니다. 나는 하나의 슬레이브가 리포지토리에 하나의 카를 가지고있는 시나

0열

1답변

AWS SQS를 JMS로, 온 프레미스 앱에서 보내고받은 메시지

전적으로 AWS를 처음 사용하고 Java 환경이 제한적입니다. 그러나, 나의 임무는 자바 클라이언트 애플리케이션이 온 - 프레미스 (on-premise)로 설치된 하이브리드 솔루션을 지원하여 JMS 메시지 (Spring JMS)를 Amazon SQS로 보내는 것이다. EC2에서 실행되는 서버 응용 프로그램은 SQS에서 메시지를 가져 와서 처리하고 다른 큐에

0열

1답변

스프링 및 JMS DynamicDestinationResolution

최신 Spring 4 및 ActiveMQ를 사용하여 JMS 메시지를 대기열에 넣습니다. JMSTemplate을 사용하면 기본 대기열이 있으며 샘플 코드를 사용하면 아무 문제없이 기본 대기열에 메시지를 넣을 수 있습니다. 또한 목적지에 메시지를 넣을 수있는 샘플 코드가 있습니다. 여기는 내가 끊긴 곳입니다. 원래 방법은 : 나는 대상이있는 경우 public

0열

1답변

다중 스레드 JMS 클라이언트 ActiveMQ

아래의 코드를 사용하여 여러 소비자가 메시지를 소비하도록 여러 JMS 세션을 만듭니다. 내 문제는 코드가 단일 스레드 방식으로 실행되고 있다는 것입니다. 대기열에 메시지가 있더라도 두 번째 스레드는 아무 것도 수신 할 수 없으며 폴링 만 유지합니다. 첫 번째 스레드는 첫 번째 일괄 처리를 마친 후 다시 돌아와 나머지 메시지를 소비합니다. 여기에 사용법에 문

0열

1답변

Java : Apache Qpid가 Java로 구현되었습니다.

저는 Qpid를 처음 사용하기 때문에 환경을 설정하려고합니다. 많은 수의 문서를 읽은 후 Apache Qpid를 다운로드하여 localhost에서 실행했습니다. 8080 또한 maven, cmake도 설치했습니다. 이제 간단한 메시지를 보내기 위해 Eclipse에서 새로운 maven 프로젝트를 시작하려고합니다. API 인터페이스와 개념에 익숙하지 않습니다.

0열

1답변

XA 트랜잭션을 사용하는 Oracle AQ JMS 연결을 가져 오는 동안 NullPointException이 발생합니다.

트랜잭션에 관련된 활성 MQ 및 DB와 같은 다른 데이터 소스가 있으므로 Oracle AQ 지원 XA 트랜잭션을 사용하려고합니다. 내가 오라클 대기열 queue1에 게시하려 했어요. 데이터 소스에서 XAconnection을 가져 오는 동안 NullPointerException이 발생하여 실패합니다. 내가 오라클 ojdbc6을 사용하고 , 내 콩 (고화질)

2열

1답변

브로커의 ActiveMQ 네트워크에서로드 밸런싱

우리는 ActiveMQ를 사용 중이며 브로커 네트워크를 정의했습니다 (테스트 설정에서 2). 우리는 AMQP 연결을 허용하도록 브로커를 구성하고 우리는과 같이 "updateClusterClients"와 "rebalanceClusterClients"을 수 있습니다 <transportConnector name="amqp" uri="amqp+ssl://0.0.0

1열

1답변

가 "연결 폐쇄"슬로우 반복

I는 Z/OS 큐 원격 는 WebSphere MQ 6.1 애플리케이션 서버로 는 WebSphere에서 실행하는 웹 애플리케이션에서 연결해야한다. WebSphere AS에서 QueueConnectionFactory와 Queue (원격 대기열 데이터의 일부를 포함하는 객체)를 구성했으며, 대부분의 설정은 기본값으로 설정되었습니다. 대기열 이름, 채널, 호스트,

0열

1답변

메시지 구동 형 채널 어댑터 또는 JMS 게이트웨이 용 오류 채널

누군가 내가 도와 줄 수있는 문제가 있습니까? webservice 게이트웨이 및 JMS 어댑터 클래스에 공통적으로 사용되는 서비스 활성기 클래스가 있습니다. 이는 webservices 게이트웨이 채널과 MQ 어댑터 채널에서이 클래스로 들어오는 요청을 의미합니다. 그리고 나는이 activator에서 예외를 던지고 있습니다. webservices 흐름에 대한

0열

1답변

AMQP/JMS 환경에서 BrokerProperty "setScheduledEnqueueTimeUtc"에 해당하는 것은 무엇입니까?

저는 Azure 서비스 버스에 메시지를 보내야하는 Java 응용 프로그램에서 작업 중이므로 특정 지연 후 다음 프로세스에서 메시지를 사용할 수 있습니다. Azure SDK를 사용하면 브로커 메시지에 setScheduledEnqueueTimeUtc BrokerProperty를 설정하여이를 수행 할 수 있지만 AMQP/JMS 환경에서는 이에 상응하는 항목을 찾