Autofac 및 EasyNetQ 단위 : 내가 가입자 class Program
{
static void Main(string[] args)
{
var container = AutofacContainerFactory.Build();
using (var scope = container.BeginLife
EasyNetQ 주위에 래퍼를 작성하여 RabbitMQ에 메시지를 게시합니다. 많은 수의 메시지가 게시되어야합니다. IBus를 사용하여 메시지를 게시하는 패턴을 사용해야합니까? 아니면 IBus 유형 var를 클래스 수준 static var로 선언하고 응용 프로그램이 종료 될 때 처리해야합니까? using (IBus bus = RabbitHutch.Creat
데드 레터 대기열에서 메시지를 읽은 다음 유형, 내용 등을 기반으로 메시지로 무언가를 처리하는 데드 레터 처리기 서비스를 작성하려고합니다. C# 응용 프로그램에서 EasyNetQ를 사용하여. MyMessage라는 기본 메시지 유형과 여러 하위 유형이 있습니다. EasyNetQ는 메시지를 직렬화하고, 교환기로 전송하고, 대기열에서 꺼내어 원래 형식으로 다시
일부 POC project에서 작업 중이며 다음 문제를 해결하려고합니다. 내가 가지고 대기열에 메시지를 보내는 Publisher : bus.PublishAsync<IBaseScenario>(new TestScenario())
.ContinueWith(task =>
{
if (task.IsCompleted && !tas
내 시나리오를 라우팅 메시지를 기반으로 : 우리는 네트워크에 약 300 다른 컴퓨터에 메시지를 방송을위한 RabbitMQ를 사용하는 . 우리는 각 대상 컴퓨터에 대한 routingkey를 할당 교환을 정의하고 한 큐에 각 routingKey을 결합하고 각각에 삽을 정의하는 윈도우 서버, C# .NET 클라이언트 (EasyNetQ) 염기성 용액에 Rabbit
C# EasyNetQ 및 Java과 Spring Amqp가있는 마이크로 서비스간에 메시지를 보내야합니다. 문제는 속성 메시지입니다. 스프링 부트의 유형 Ampp는 __type__ 헤더 컨테이너이고 EasynetQ는 type이라는 외부 속성이 필요합니다. 아무도 내가 그들을 comunicate하게하기 위해 필요로하는 것을 나에게 말할 수 없었 을까? Spri
최근에 게시 - 가입 및 요청 - 응답 방식 및 공통 대기열 연결/끝점에서 easynetq 대기열을 설정했습니다. 목표는 큐를 사용하는 로직을 개발하는 것이 개발자들간에 독립적이어야한다는 점에서 easynetq를 설정하는 것입니다. 현재 모든 개발자 머신이 자신의 접두어로 된 큐를 가져 오는 easynetq를 구성했습니다.하지만 개발자가 2 명 더 많으면
나는 rabbitmq에 기존 대기열을 구독하는 작업자가 있습니다. 중복을 위해 같은 대기열에 연결하는 다른 작업자를 추가하기로 결정했습니다. 첫 번째 작업자가 대기열에 대한 독점적 인 연결을 확보하여 두 번째 작업자가 메시지를 대기열에서 제외하고 대기 작업자 역할을 수행하도록 설정할 수 있습니까?
메시지를 대기열로 보낼 수있는 웹 API를 만들었습니다. My Web API는 CQRS와 DDD를 염두에두고 설계되었습니다. 내 메시지 소비자가 대기열의 모든 메시지를 수신하기를 항상 기다리고 싶습니다. 현재 API가 메소드를 실행하도록 요청하면 메소드가 완료되는 방식으로 메시지를 읽습니다. 웹 응용 프로그램에서 요청하지 않고도 언제든지 메시지를 소비하도록
easynetq를 사용할 때 rabbitmq.client 버전에 문제가 있습니다. 그러나 정확히 어떤 원인인지는 알지 못합니다! 내 솔루션에는 WindowsService (exe 파일) 및 여러 라이브러리 프로젝트 용 프로젝트가 포함되어 있으며 모두 .NET 4.6.2에 맞게 작성되었습니다. 2017-10-20 09:58:49,185; [9]; INFO ;