activemq

0열

1답변

내 응용 프로그램의 일부에는 "작업"에 대한 ActiveMQ 메시징 큐를 확인하는 상수 루프가 필요합니다. Spring이 모든것을 초기화 한 후에 시작하는 전용 스레드를 사용하여 이것을 설정 했으므로 필요로하는 모든 DI 항목이 있습니다. 스레드는 메시지를 찾기 위해 지금은 while(true) 루프의 모든 것을 처리합니다. 하나의 ActiveMQConne

1열

1답변

ActiveMQ 및 Spring 통합 JMS를 사용하여 여러 그룹에서 메시지를 한 번 수신하려면 어떻게해야합니까?

시스템의 사용자가 생성 될 때 메시징 서비스를 사용하여 다른 서비스에 메시지를 보내려고합니다. 메시지를 수신하는 서비스는로드 밸런싱 된 Spring Boot 어플리케이션 (우리의 경우, Kubernetes 환경의 포드)입니다. 내가 좋아하는 것 : 각 서비스의 모든 포드는 메시지를 수신하도록 구성되어 있습니다. 각 서비스의 하나 (단 하나) 포드는 실제로

0열

1답변

맞춤 헤더로 Stomp.py 보내기가 실패했습니다.

현재 사용자 정의 시스템에서 Python Stomp.py 라이브러리를 통해 ActiveMQ 인스턴스로 메시지를 보내고 있습니다. send 명령에서 "headers"매개 변수로 사용자 정의 헤더를 사전에 제공하면이 작업이 실패합니다. ValueError: dictionary update sequence element #0 has length 1; 2 is r

0열

1답변

20000 개의 스레드에 대한 activemq 조정

나는 메시지를 게시하고 소비하기 위해 스톰 포트와 20000 이상의 서버를 동시에 연결하는 ActiveMQ를 실행하고 있습니다. activemq 서버가 8CPU 및 32G 메모리를 실행 중입니다. JVM 최대 메모리를 -Xmx16384m으로 지정했습니다. 하지만 여전히 모든 서버가이 ActiveMQ에 연결되면 서버가로드되고 Virtual Memory 사용량

0열

1답변

내구성있는 소비자에게 연결 - Qpid Proton Python

AMpP v1.0을 초과하는 ActiveMQ 브로커에 내구성이 강한 소비자로 가입 할 Qpid Proton Python 클라이언트를 얻으려고합니다. 내구력 구독을 만들 수는 있지만 다음에 스크립트를 실행할 때 동일한 구독을 가져 오는 방법을 잘 모릅니다. 각 실행 후 영구 가입이 생성되었으며 내 스크립트의 입력에 따라 이름이 지정되지만 다음 실행은 이전에

0열

2답변

Node.js 응용 프로그램이 메시지 대기열을 수신하고 비동기 적으로 메시지를 추가합니다.

메시지 대기열 (ActiveMQ)을 수신하고받은 메시지를 일괄 적으로 redis에 추가하는 node.js 구성 요소를 개발 중입니다 (일괄 처리 당 20 개) . ActiveMQ에서받은 메시지 수가 초당 10 개가 될 때 문제가 없습니다. 제 문제는 메시지가 4 밀리 초마다 대기열에 추가된다는 것입니다. 따라서 일괄 처리에 추가되는 레코드 수가 일괄 처리

0열

1답변

ActiveMQ VM 전송을 사용하는 제작자로부터 메시지를받지 못합니다.

activeMQ tcp // localhost URL을 사용하고 있습니다. 잠시 조용 해졌고 문제가 없습니다. 현재 "VMm // localhost"커넥터를 사용하려하지만 프로듀서로부터 메시지를받는 데 문제가 있습니다. 나는 봄 부츠를 사용하고 있으며, 생산자와 소비자는 다른 항아리에 있습니다. 내 고객이 null 메시지를 받고 있습니다. 내가 놓친 게 있

-1열

2답변

kahaDB 로그 삭제

삭제되지 않는 많은 kahaDB 로그가 있습니다. 이전 "data-< id> -log"파일을 지우는 것이 안전합니까? kahaDB 파일을 수동으로 삭제 한 후에 activeMQ를 다시 시작하거나 응용 프로그램을 다시 배포해야합니까?

0열

1답변

활성 MQ 성능

활성 mq에 성능 문제가 있습니다. 나는 20 자의 문자열로 작은 메시지를 보낸다. 30.000 메시지를 보내면 활성 mq가 매우 느려집니다. 지금은 1GB가되기 전에 메모리를 2GB로 늘려야합니다. 이제 성능이 향상되었습니다. 내 질문이 지금, 왜 작은 메시지에 액티브 mq가 많은 메모리를 필요로합니까? 내가 ActiveMQ를 프로세스 ID 쓰레드 덤프와

0열

2답변

activemq 인스턴스의 재 연결 수를 제한하는 방법

activemq 브로커와 상호 작용하는 스프링 JMS 응용 프로그램이 있습니다. 응용 프로그램이 브로커에 도달 할 수없는 경우 무한정 재 시도합니다. activemq.xml 파일을 구성하거나 내 DefaultJmsListenerContainerFactory bean에서 soemthing을 무한정 재 시도하지 않으려면 어떻게해야합니까? 가 나는 ActiveM