SQS를 사용하여 처음부터 끝까지 한 번에 1 개의 메시지를 처리해야한다는 요구 사항이 있습니다. SQS에서 maxConcurrentConsumer를 1로 설정할 수 있습니까? 문서를 조사하고 있는데이 속성을 찾을 수 없습니다. Amazon 콘솔에서 구성 대기열 메뉴에이 특성이 표시되지 않습니다. 메시지를 검색 할 때 우리는 하나의 설문에서 읽으려는 메시지
spring-amqp를 사용하여 특정 대기열에 대한 모든 바인딩을 제거 할 수 있습니까? 해결 방법이있다 , 먼저 큐를 삭제 한 다음 amqpAdmin.deleteQueue("testQueue");
amqpAdmin.declareQueue(new Queue("testQueue"));
그것을 재 선언하지만이 꽤 추한 솔루션이며 나는 그것이
웹 서버의 작업을 ec2 작업자를 시작하는 작업자 관리자에게 전달하기 위해 AWS sqs를 사용하고 있습니다. 메시지가 작업자 관리자에게 전달되면 메시지를 읽고 작업자를 시작합니다. 나는 노동자 IP를 돌려주고 싶다. 어떻게 구현할 것인가? 응답을위한 별도의 대기열을 만들고 메시지에 작업자 또는 다른 방법을 추적 할 수있는 식별자를 표시해야합니까? 미리 감
현재 약 JMS에 대한 기사를 읽었으며 몇 기사를 읽은 후에는 내 머리 속에 비 영구 메시지가 포함 된 영구 가입에 대해 혼란이 있습니다. 이제 시작하자 : http://www2.sys-con.com/itsg/virtualcd/java/archives/0604/chappell/index.html - 그것은 말한다 : 비 지속적 메시지가 분리 내구성 가입자를
rabbitmq를 포트 15672의 IP 주소 10.8.11.12를 사용하는 다른 컴퓨터에서 실행 중이며 "hello"라는 큐가 있습니다. 나는 로컬 호스트에서 큐를 제거하려면 다음 CLI를 (명령 줄 인터페이스) 내가 시도를 사용하여 내 컴퓨터에서 안녕하세요 큐를 제거 할 rabbitmqctl의 purge_queue 이 잘 을 작동하고 내가 내가 cons
누구나 NATS 스트리밍 서버를 Java 클라이언트와 결합하여 사용해 본 경험이 있습니까? 특히 구독자가 오프라인 일 때 전송되는 Java 클라이언트를 사용하여 메시지를 검색하는 방법을 알 수 없습니다. Go client을 사용하면 메시지를 게시하고 나중에 구독을 추가하여 게시 된 모든 메시지를 검색 할 수 있습니다. 이것은 NATS 스트리밍 Getting
내 코드의 오류 위치를 알려줄 수있는 사람이 있습니까? 미리 감사드립니다. 나는이 코드를 실행 below.When 여기 내 code.I 내가 항상 수신 코드에서 헤더 파일을 삭제한다 : mq_open : I가 유래 검색 #define FILE_MODE S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH
struct mq_attr attr;
int
RabbitMQ 클라이언트 앱을 사용하고 있습니다. 나는 간단한 발행을 사용할 수 있으며 실제로이 간단한 발행 (큐가 아닌 교환)을 사용하여 서버에 메시지를 게시하려고합니다. 그러나 NSDictionary (또는 다른 개체, 나도 몰라)로 헤더를주고 싶습니다. RabbitMQ의 문서화로 Objective-C가 충분하지 않기 때문에이 방법을 찾지 못했습니다.
작업에서 여러 작업을 생성하는 것이 안전합니까? 작업자가 비어있는 작업을 시작할 수 있습니까? 현재 내 설정은 다음과 같습니다. 나는 일자리가 밀려나기를 기다리는 20 명의 노동자가 있습니다. 작업 중 하나는 iOS 푸시 알림을 보내는 것입니다. iOS의 문제입니다. 대량 메일을 보낼 수 없습니다. 현재 : 내가 한 것은 일괄 적으로 특정 사용자의 목록을