masstransit

0열

1답변

MassTransit의 버스 대기열은 무엇입니까? <code>bus-{MachineName}-{ApplicationName}-{Identifier}</code></p> <p>이 큐/교환의 목적은 무엇 :

소비자가 수신 엔드 포인트에 연결하는 고유 교환 및 대기열 이름과 같은 만들어? 어떤 세부 문서가 있습니까?

0열

2답변

IConsumer를 등록하십시오 Autofac를 사용하여 Masstransit에 의존성이있는 <T>을 등록하십시오.

두 가지 시스템, 하나는 게시 메시지 용이고 다른 하나는 시스템 용입니다. 둘 다 Masstransit (RabbitMQ 사용)을 사용하며 ASP.Net 웹 API 2와 OWIN (및 IoC 컨테이너로 Autofac)을 사용하여 구현됩니다. 내 소비자가 종속성이없는 경우 모두 작동합니다 (). 소비자에게 dependenciy를 주입하면 Consume 메서드

1열

1답변

vhost에 대한 액세스가 MassTransit Sample-RequestResponse 샘플과 함께 거부되었습니다.

최신 RabbitMQ 서버 (guest는 admin 임)에서 기본 구성을 사용하고 있는데 RequestResponse 샘플을 실행하면 다음 예외가 발생합니다. OperationInterruptedException은 다음 AMQP 작업이 중단되었습니다 AMQP 근접 이유, 피어, 코드 = (530), 텍스트 =에 의해 시작 "NOT_ALLOWED - 액세스

1열

1답변

CQRS 구현을 위해 Masstransit을 포장하는 것이 좋습니다.

차라리 것 별도의 CommandBus 및 EventBus 또한 ICommandHandler<TCommand> 및 IEventHandler<TCommand> 그래서 같은 OrderEventHandler 클래스는 보이는 것을 : 가능한 솔루션은 Masstransit 인프라와 내 CQRS (같은 ConsumerToHandlerAdopter<T> 사이의 채택을 제

1열

1답변

데드 - 레터 (dead-letter) 메시지가있을 때 건너 뛴 대기열을 만들지 마십시오.

요청/응답 시나리오에서 _skipped 대기열을 만들지 않도록 선택할 수 있습니까? 우리는 이런 식으로 우리의 응용 프로그램을 구축하기로 결정했습니다 (이유는 묻지 않습니다). 우리는 여러 소비자에게 PublishRequest를하고 있으며 단 한 명의 소비자 만 응답합니다. 다른 모든 것들은 건너 뛴 대기열을 생성합니다 (시간 초과 오류). 나는이 구조를

0열

1답변

MassTransit 소비자가 동일한 이벤트를 소비하는 순서를 지정하십시오.

동일한 유형의 이벤트를 사용하는 FirstConsumer 및 SecondConsumer 두 명의 소비자가 있습니다. 그러나 SecondConsumer의 작업은 부분적으로 FirstConsumer에 의해 수행되는 작업의 출력에 따라 달라집니다. SecondConsumer에 의해, 이벤트가 항상가 FirstConsumer에 의해 해당이 이루어집니다 이후 처음으

0열

1답변

읽기 작업을 위해 데이터베이스 쿼리를 수행 할 때 지침은 시간 제한 작업에 대한 대량 전송 요청/응답을 사용하여 수행해야합니다.

만들기 작업의 경우 메시지를 대기열에 저장하는 것이 좋습니다. 엔터티가 예상보다 오래 걸리고 다른 대기열이 가져옵니다. 그러나 시간 제한 인 읽기 작업 (3 초 이내에 UI로 돌아와야 함)의 경우 큐가 좋은 아이디어인지 완전히 명확하지 않습니다. http://masstransit-project.com/MassTransit/usage/request-respo

0열

2답변

masstransit deferred in sagas

대용량 전송에서 사가를 사용하여 여러 서비스에서 활동을 조율하는 방법을 조사 중입니다. 무용담의 수명은 짧습니다 - 모두 잘되면 2 초 미만입니다. 내 경우에는 클라이언트가 명령을 요청하고, 사가가 해당 명령을 처리하고, 메시지가 수신 될 때 일부 상태 변경을 거쳐 결국 첫 번째 명령에 응답하는 요청/응답 방식을 사용하고자합니다. 무용담을 시작한 시점에서

0열

1답변

메모리에서 Masstransit 소비자가 실행하기를 기다리는 테스트

그래서 메모리 내장 기능을 사용하여 대량 전송 테스트를 작성하려고했습니다. 나는 사람들이 접근하는 것이 소비자가 실행되기를 기다리는 것이 무엇인지 궁금해했다. 아래 예제에서 잠을 사용하거나 while 루프를 시도했지만 더 좋은 아이디어는 아닙니다. 기본적으로 소비자가 처형되었는지 확인하고 싶습니다. [Fact] public async Task SomeTe

0열

1답변

무언가에서 회람 쪽지를 어떻게 실행합니까?

우리는 워크 플로우를 모델링하기 위해 사가를 사용하고 있습니다. 이 워크 플로우는 이벤트가 오기를 대기하고 이벤트를 기반으로 일부 작업을 수행합니다. 어떤 경우에는 여러 작업 (하나의 체인으로 묶인 다음 방법)을 차례로 수행해야하지만 하나가 실패하면 전체 체인을 보완하기를 원합니다. 라우팅 전표가 적절하게 보이지만 그러한 회람 쪽지가 사가의 Then 메소드