그래서 저는 셀 비트 v3.x를 약간의 시간 동안 사용해 왔으며 공식적으로 이후로 v4로 마이그레이션하는 것에 대해 생각했습니다. 현재 PyPI를 통해 제공되는 v4.0.2를 사용하고 있습니다. 이 두 버전에서 약간의 불일치가 있었다, 그러나 저를 혼란 하나는 이것이다 : 여기 내 작업 파일입니다 : from celery import group, chord
저는 CachingConnectionFactory가있는 Spring AMQP 프로젝트를 가지고 있습니다. AMQP Connection에서 State, Connected at, 채널 및 일부 런타임 메트릭과 같은 속성을 가져와야합니다. CachingConnectionFactory에 대한 메트릭 지원이 있습니까 (예 : https://www.rabbitmq.c
Azure 서비스 버스에 메시지를 보내면 먼저 컴퓨터의 보내는 대기열로 이동합니까? 다른 프로젝트 (Azure가 아닌)에서 MSMQ로 작업했을 때이 프로세스를 QueueExplorer로 시각화 할 수있었습니다. Azure 서비스 버스에서이 작업을 수행 할 수있는 방법이 있습니까?
Google에 단일 교환으로 게시하는 앱이 있습니다 (amqp 사용). 또한이 교환에서 메시지를 소비하는 데 관심이있는 많은 앱을 보유하고 있습니다. 이를 위해 대기열과 대기열에서 교환기로의 바인딩을 만듭니다. 각 앱의 대기열 및 바인딩은 해당 앱과 앱이 연결되는 사용자 만 관리 할 수 있도록하고 싶습니다. 나는 가상 호스트를 사용하여 교환기가 각각의
사용자가 팀에 속한 서비스 (웹 및 앱을 통해 액세스 가능)를 만들고 있습니다. 사용자가 인 경우을 수행 할 때마다 팀의 다른 모든 온라인 사용자 (*)에게 알림을 보내야합니다. 나는 이것을 위해 RabbitMQ를 평가 중입니다. (*) 동일한 사용자가 동시에 여러 세션을 가질 수 있습니다 (즉, 다른 브라우저에 동시에 로그인 할 수 있거나 브라우저 및 앱
현재 Azure 이벤트 허브에 정보를 보내려합니다. AMQP1.0 client for node.js. SAStoken을 통해 인증해야합니다. 과 같을 것이다 내가 SASkey 및 SASKeyName을 사용할 수 없습니다 var uri = protocol + '://' + encodeURIComponent(sasName) + ':' + encodeURICom
이것은 인터뷰에서 나에게 질문을 받았다. 오전 10시에 구독자가없는 대기열에 메시지가 게시되면 어떻게됩니까? 적절한 필터를 가진 가입자는 10.02 AM에 동일한 대기열에 가입합니다. 메시지가 브로커에 도착한 후에 구독자가 구독 할 때 메시지가 배달되는지 여부 (메시지가 구독자를 찾을 때까지 해당 메시지가 메모리에 저장됩니까?) 기본 동작이란 무엇입니까?
RabbitMQ를 사용하여 사용자에게 알림을 보내고 있습니다. 사용자는 언제든지 대기열을 읽을 수 있습니다. 내가 직면하는 문제는 대기열이 밤에 많은 알림으로 채워지고 사용자가 아침에 반환하면이 메시지를 순차적으로 처리해야한다는 것입니다. 이러한 알림은 대부분 중복 된 것입니다. 게시자 측에서이를 개선하는 것이 좋습니다. 즉, 새 알림을 추가하기 전에 대기
AMpP v1.0을 초과하는 ActiveMQ 브로커에 내구성이 강한 소비자로 가입 할 Qpid Proton Python 클라이언트를 얻으려고합니다. 내구력 구독을 만들 수는 있지만 다음에 스크립트를 실행할 때 동일한 구독을 가져 오는 방법을 잘 모릅니다. 각 실행 후 영구 가입이 생성되었으며 내 스크립트의 입력에 따라 이름이 지정되지만 다음 실행은 이전에