activemq

5열

1답변

처리를 위해 X? -GB 대용량 파일을 스트림으로 ActiveMQ 대기열로 보내려고합니다. 저는 ActiveMQ supports streams을 알고 있습니다. 따라서 camel-jms도 있습니다.하지만 대기열에 설정하려고 시도하는 것은 아무런 차이가없는 것 같습니다. 변화가있는 유일한 것은 스트림 캐싱 결과를 끄는 것이 대신 "스트림 폐쇄"예외입니다. 프

2열

2답변

Dead Letter 큐에서 Activemq에 대한 메시지를 분석하는 방법

브로커는 메시지를 받아 데드 레터 큐 으로 보내 나중에 나중에 분석 할 수 있도록합니다. 다음은 apache activemq article의 인용문입니다. 내 전략도 같습니다. 나중에 데드 레터 큐에있는 메시지를 분석하려고합니다. 어떻게해야합니까?

0열

1답변

Activemq에서 주제가 작동하는 여러 수신기는 어떻게 작동합니까?

ActiveMq 내장 브로커를 사용하고 있습니다. 나는 술집/하위 모델을 사용하고 있습니다. 주제에 구독하는 여러 명의 청취자가 있습니다. 기본 메시지 수신기 컨테이너를 사용하고 있습니다. 그래서 주제와 구독자 통계를 얻기 시작했습니다. 주제의 메시지 수에 대한 통계는 항상 0입니다.입니다. DestinationStatistics statistics = d

0열

1답변

KahaDB 오류 "디스크에 공간이 없습니다". 어떻게 해결할 수 있을까요?

activemq를 사용하고 있습니다. KahaDB는 activemq의 기본 메시지 저장소입니다. 그러나 크기가 계속 증가하고 결국 디스크 공간이 부족합니다. 모든 메시지가 확인 된 경우에도 계속 크기가 커지고 데이터 저장소에 새 로그 파일이 계속 만들어집니다. KahaDB와 관련된 속성을 설정하지 않았으므로 기본 속성을 사용하고 있습니다. broker =

0열

1답변

ActiveMQ JNDI 작동 방법

ActiveMQ를 처음 사용하고 ActiveMQ 네이밍 서비스 작동 방식을 이해하려고합니다. 제대로 이해했다면, activeMQ 브로커를 사용하려면 connectionFactory와 대상 (주제, 대기열)을 검색하기 위해 JNDI를 전달해야합니다. ActiveMQ는 jndi.properties 파일에서 java.naming.provider.url 변수를 통

0열

1답변

cocoaMQTT를 사용하여 iOS에서 가입자를 오프라인으로 만드는 방법

신속한 iOS에서 작업하고 있습니다. 내 iOS 앱에서 사용하는 코코아 mqtt 프로토콜을 사용하고 있습니다. 또한 메시지 브로커에 Activemq를 사용하고 있습니다. 내가 ActiveMQ를에 만든 주제에 가입 한 목적. 그 후 ActiveMQ에서 주제를 구독 취소하면 사용자는 주제의 구독자로 남아 있지만 메시지는받지 못합니다. 그것은 오프라인이됩니다.

0열

1답변

동적 mule을 동적 mule로 보내도록 대기 메시지를 설정하는 방법

mule에서 활성 mq로 메시지를 보낼 대기 값을 동적으로 설정할 수있는 방법이 있습니까? 활성 mq의 대기열에 보내기 전에 메시지를 기다려야하는 요구 사항이 있습니다. 그 대기 값 구성을 변수에서 동적으로 만들 수있게해야합니다. 나는 groovy에 얼마 동안 메시지를 보관할 수 있는지 알지 못한다. 몇 가지 예를 보았지만 그루비 나 sleep() 또는 해

-1열

1답변

공유 노드 현명한 대기열

Java를 사용하여 프록시 서버를 구축 중입니다. 이 응용 프로그램은 도커 컨테이너 (다중 인스턴스)에 배포됩니다. 다음은 현재 작업하고있는 요구 사항입니다. 클라이언트는 프록시 서버가 목적지 노드 서버에 수신 된 순서에 프록시 서버 앞으로 이러한 요청을 HTTP 요청을 보냅니다. 대상에 도달 할 수없는 경우 프록시 서버는 해당 요청을 저장하고 나중에 사용

1열

1답변

JMS 게시자/고객의 clientID를 설정하는 목적은 무엇입니까?

내구성있는 주제에 대해 jms 토픽 구독자를 작성할 때 clientId 및 subscription 이름을 설정해야한다는 것을 알고 있습니다. 하지만 주제를 게시 할 때 clientID를 설정하는 목적은 무엇입니까? 나는 사람들이 발행인/소비자를 위해 클라이언트 ID를 설정하는 것을 보았지만 아무도 그것이 왜 필요한지 설명하지 못했습니다. Connection

-1열

1답변

Java 프로그래밍에서 ActiveMQ를 사용하여 대기열 메시지의 만료 시간을 설정하려면 어떻게해야합니까?

이 코드에서는 게시자 쪽에서 대기열에있는 1 초의 만료 메시지에 대해 setJMSExpiration (1000)을 사용하고 있습니다. 하지만 Consumer Side에서 null 대신 1 초 후에 메시지를 제대로 반환하고 있습니다. public class RegistrationPublisher extends Thread{ public void