지금까지 내가 이해, 당신 subscribed 특정 QoS와 topic A를, 가입자가 QoS 수준과 같거나 항목을 게시에 명시된 QoS에 아래로 MQTT 브로커에 의해 제공되는 topic에서 메시지 만 표시됩니다. 즉 의 topic = news하기 위해, exampe를 들어, 가입하고 QoS = 1으로, 그는이와 topic = news에 QoS = 1 O
테스트를 위해 clean sessin = false 및 setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, true);의 클라이언트를 생성하고 응용 프로그램을 실행했습니다. 나중에 응용 프로그램을 실행할 때 setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, false);을 설정하면 이전에 작성한 LWT
아파치 아폴로 배포판을 다운로드하여 압축을 풉니 다. described in their site. ~/Developer/Web/MQTT/apache-apollo-1.7.1/bin/apollo create mybroker
아래 출력이 터미널에 있습니다. 명령 Creating apollo instance at: mybroker ERROR: mybroker/
나는 activemq 브로커를 가지고 있으며 구성을 여러 파일로 분할하려고합니다. 자동으로 생성되고 큐 정의 만 포함하는 별도의 구성 파일을 준비하려고합니다. 파일 1 : activemq.xml <beans ...>
<broker ...>
</broker>
</beans>
파일 2 : 봄 가져 오기을 : queues.xml <bea
, 내가 사용 오류가 이미 주소를 얻을 : 나는 NETSTAT와 포트 5672에서 실행중인 서비스를 검사하기 위해 노력했다 2015-01-17 18:41:32,828 | ERROR | Failed to start Apache ActiveMQ ([localhost, ID:Laptop-44709-1421516492312-0:1], java.io.IOExcept
비동기 적으로 요청 된 엔티티에 대한 요청 - 응답을 처리하는 브로커와 클라이언트를 (Python으로) 구현하기 위해 ZMQ를 활용하고 싶습니다. 클라이언트에는 요청과 응답을 수행하는 기능이 있습니다 (누락 된 것은 정확한 소켓 유형/패턴입니다). 요청이 차단 될 수 있지만 수신 측에서는 병렬 (스레드) 요청을 처리 할 수 있어야합니다 (예 : 다음 수
내 요구 사항은 activemq 메모리 사용률이 특정 한도에 도달하면 경고를 발생시키고 싶습니다. 예 : 내 activemq 메모리 백분율이 JVM 힙 공간의 70 %로 설정되었습니다. 따라서 기억력이 65에 도달하면 경고를 불러 일으키고 싶습니다. Java 코드 또는 다른 방법을 통해 어떻게 접근 할 수 있습니까?
카프카에서는 하나의 브로커, 단일 주제 및 하나의 생산자와 다수의 소비자 (각 소비자는 브로커로부터 자체 데이터 복사본을 얻음)가있는 단일 파티션 만 사용하고자합니다. 이 점을 감안할 때, 나는 사육사 (Zookeeper) 사용의 오버 헤드를 원하지 않는다. 브로커 만 사용하면 안됩니까? 사육사는 왜해야합니까?