jms

0열

1답변

JmsTemplate with CachingConnectionFactory IBM MQ 큐용 연결 복구

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

-1열

2답변

ActiveMQConsumer.receive (1000)가 null을 반환합니다.

ACtiveMQ에 메시지를 넣고 있습니다.이 메서드로 예제 프로그램을 실행하고 있습니다. ActiveMessageConsumer.receive(1000)은 항상 null 메시지를 반환합니다. 대기열에 메시지가 있지만 여전히 해당 메시지를 수신 할 수 없습니다. url = "http : //"; connectionFactory = new ActiveMQCon

0열

1답변

Alpakka - 메시지 처리시 콜백

각 메시지가 JMS로 성공적으로 전송되거나 실패 할 경우 콜백을 수행하는 방법은 무엇입니까? val jmsSink = JmsSink.textSink( JmsSinkSettings(connectionFactory).withQueue("My_Queue") ) Source(Stream.from(1)) .map(_.toString) .

0열

1답변

임시 대기열 자동 방지 ActiveMQ의 주제 작성

응답을 수신하기 위해 activeMQ에 임시 대기열을 작성하는 Rest 서비스가 있습니다 ( 응답). 모든 요청은 임시 대기열을 만듭니다. 각 임시 큐에 대한 자동으로 항목을 작성 : 나는 항목 목록에 갈 때, 나는 다음을 볼 수 있습니다. 그것의 주요 문제는 주제가 1,000 개의 주제에 제한이 있다는 것입니다. 한계를 초과하면 더 이상 ActiveMQ의

0열

1답변

Java EE 응용 프로그램에서 Java SE 응용 프로그램으로 JMS 메시지를 보냅니다.

내가 가진 문제가 잘못된 것 때문에 오히려 개념적인 것이거나 기술적 인 것인지 확실하지 않습니다. 목표는 표준 JMS 프로토콜과 주제를 사용하여 응용 프로그램 컨테이너 (여기서는 WildFly)에서 호스팅되는 Java EE 응용 프로그램과 독립 실행 형을 실행하는 Java SE 응용 프로그램 사이에 양방향 메시지를 보내는 것입니다. 나는 이것이 동일한 브로

0열

1답변

JMS 메시지 수신 시간 가져 오기

JMS 메시지 수신 시간 (배달 안 함, 타임 스탬프를 게시하지 않음)을 가져 오는 메소드/API가 있습니까? 아니면 수동으로 onMessage(Message msg) 방법으로 수정해야합니까?

0열

1답변

MQJavaClient

I는 다음과 같습니다위한 그래서 내가 한 일을 MQJavaClient를 통해 메시지 ID로 사용자 정의 문자열을 설정하려고 통해 메시지 ID를 설정하는 방법 : 문자열 내가 메시지 ID에 배치 할 example :92f5fd96300e8dce 은 진수 번호를 가져옵니다 온라인 [codebeautify.org] 자바 클라이언트 코드 A의 example:3

0열

1답변

JMS 대기열로 보낸 메시지는 단일 사용자 만 사용합니까?

보낸 사람이 큐에 메시지를 보내는 경우 (예 : message1)는 sender1에 의해 대기열로 보내집니다. 이제 consumer1이라는 소비자가 대기열에 연결하고 message1 메시지를 읽습니다. consumer2이라는 또 다른 소비자가 있습니다. 그러나 메시지 message1은 이미 consumer1에 의해 소비되었으므로 consumer2에는 사용할

0열

1답변

ActiveMq의 Topic에서 메시지가 전달되는 최대 구독자 수를 제한합니다.

ActiveMq 인스턴스가 있고 Topic을 수신하는 클라이언트가 100 개 있다고 가정 해 봅시다. 새 메시지가 주제에 게시되면 수신하는 구독자 수를 제한 할 수 있습니까 (예 : 10)? 이제 다른 메시징 구성 요소가이를 수행 할 수 있거나 문제 해결/통합 된 모범 사례가 있습니까?

0열

1답변

Activemq - 불안정한 연결을 통해 거대한 파일을 보내는 최상의 프로토콜

사용 사례 : 한 서버에서 다른 서버로 대기열을 통해 거대한 파일 (100MB 배수)을 보내야합니다. 현재 Activemq Artemis 서버를 사용하여 재시도 간격이 -1 인 TCP 프로토콜을 통한 입력 스트림의 도움으로 ByteMessage로서 거대한 파일을 무제한 페일 오버 재 시도를 위해 -1로 보냅니다. 여기서 주요한 문제는 소비자 엔드 포인트 연