amqp

0열

1답변

apache camel을 사용하여 quipid consumer exlusive를 만드는 방법은 무엇입니까?

고객에게 단일 qpid 브로커를 연결하려고합니다. 이 두 클라이언트 중 하나만 qpid 큐를 수신 대기해야합니다. 아파치 낙타로 이것을 시도하고 있습니다.

-1열

1답변

- 큐의 최대 우선 순위 Map<String, Object> args = new HashMap<String, Object>(); args.put("x-max-priority", 10); Queue queue = new Queue("myQueue", true, false, false, args); 하지만 우선 순위 11, 10 메시지와 함께 생산하고,

1열

2답변

동적으로 내 메시지 버스로 RabbitMQ를 선택 <p></p>, 나는 스트림 소요 하나의 교환이 대기열 및 라우팅 키, RabbitMQ

내가 주식을 제시 가정한다 실시간으로 인용 메시지 기반의 웹 응용 프로그램을 구축하고 을 변경 여러 유동성 공급자로부터 따옴표를 받고 라우팅 키에 따라 해당 대기열로 라우팅합니다. 그러면 견적이 파싱되어 화면의 관련 위젯에 표시됩니다. 이 Exchange 및 큐 구조 - 문제는 내가 큐의 라우팅 키를 변경하고자 할 때 시작의는 S & P500.ACN.200

3열

2답변

RabbitMQ에서 몇 개의 연결을 유지해야합니까?

RabbitMQ Java 클라이언트를 사용하고 있습니다. 내 앱에 여러 교환 및 대기열이 있습니다. Pub/Sub 모델과 유사한 것을 채택합니다. 연결과 관련하여 가장 좋은 방법은 무엇입니까? 앱당 하나의 연결을 설정해야합니까? 나는 채널 모델과 thread (un) 안전 모델을 이해한다. 내가 여러 개의 연결을해야하는지 아닌지 확실하지 않습니다.

1열

1답변

RabbitMQ "가상 호스트에 대한 액세스 권한이 없습니다"OWN '거부 됨 "

위와 같이 RabbitMQ에서 새로운 가상 호스트에 대한 사용 권한을 설정하고 사용하려고합니다. 나는 내 문제가 뭔지 알 수 없다. vhost를 "/"로 사용하면 모든 것이 정상적으로 작동합니다. Node.js를/amqps에 =INFO REPORT==== 18-Nov-2016::11:50:20 === Setting permissions for 'mqadm

0열

1답변

RabbitMQ의 대기열에 허용 된 최대 메시지

찾고 있습니다 RabbitMQ의 대기열에 허용되는 최대 메시지 일부 링크에서는 Google에서 지정하지 않는 한이 제한이 없습니다. 일부 RabbitMQ 정보는 승인되었지만 잠시 동안 찾으 셨지만 아래 링크 이외의 정확한 정보는 없습니다. [http://rabbitmq.1065348.n5.nabble.com/Max-messages-allowed-in-a-q

0열

1답변

MuleSoft에서 AMQP Connector를 설치할 수 없습니다. 어떤 지점에서든 Studio

전 MuleSoft Any point Studio를 처음 사용했습니다. MuleSoft 웹 사이트에서 제공하는 세부 정보를 사용하여 AMQP Connector를 설치하려고합니다. Link - https://docs.mulesoft.com/mule-user-guide/v/3.7/amqp-connector pom.xml 파일에 받는다는 지원 설정을 추가하는

0열

2답변

AMQP와의 팬 아웃 및 직접 교환

동일한 이벤트에 대해 두 종류의 작업자가 있습니다. "직접"교환과 같은 일부 직원 중 한 명에게만 메시지를 발송하고 싶습니다. 그러나 다른 노동자들은 메시지를 모두 처리해야합니다 (예 : 팬 아웃). 설명하기가 약간 어렵지만 아이디어는 여기에 있습니다. 그리고 아마도 다음 스키마는 제가 여러분이 원하는 것을 이해하는데 도움이 될 것입니다. 는 해결책이 있습

0열

1답변

네트워크 실패 후 RabbitMQ 연결 자동 복구

네트워크 인터페이스가 실패한 후 RabbitMQ가 연결 복구를 시도 할 때 문제가 있습니다. RMQ에 대한 연결을 만들고 네트워크 인터페이스 에뮬레이션에 실패했습니다 (Centos에서 sudo ifdown enp0s3). 요청한 하트 비트 시간 초과 후 UnknownHostException이 표시됩니다./etc/hosts RMQ 주소가 없기 때문에 괜찮습니

1열

1답변

RabbitMQ & NodeJS : 애플리케이션 당 1 개의 연결, 스레드 당 1 개의 채널, 채널 당 1 개의 소비자 지침에 따라

간단한 작업 대기열 보관 라이브러리를 구축하기 위해 NodeJS와 amqplib을 사용하고 있습니다 (서비스에서 사용되는 숫자는 Jackrabbit)과 다소 비슷합니다) 많은 다른 이벤트에 대한 정보를 포함하는 매우 큰 피드를 구문 분석해야합니다. 정보가 구문 분석 된 후 수천 개의 큐로 분산되고 (메시지 순서가 고려되어야하는 최소 단위 인 큐입니다.) 소