masstransit

-1열

1답변

Rebus를 사용하여 MassTransit에서 만든 Azure Service Bus 주제와 어떻게 상호 작용할 수 있습니까?

저는 MassTransit을 통해 일부 Azure 서비스 버스 주제CompanyName.SystemName.Messages.SomethingGotUpdated에 메시지를 게시하는 기존 시스템을 보유하고 있습니다. Rebus를 사용하여 특정 주제에 대한 구독자로 새 시스템을 구성한 다음 모든 메시지를 적절한 IHandleMessages<SomethingGot

2열

1답변

예외가 발생하면 사가를 마무리 함

나는 사가를 만들었으며 활동을 수행하는 동안 예외를 처리하는 방법을 궁금해하고있었습니다. 이상적으로, 어떤 경우에는 그 사가 인스턴스를 죽이고 싶습니다. 바로 .Catch()입니다. 이 스레드를 우연히 발견했습니다 : Understanding "Finalize" in MassTransit, 내 현재 접근 방식이 약간 다릅니다. .Catch()에서 나는 Fa

0열

1답변

Azure 서비스 버스에서 동일한 유형의 메시지가 여러 개 있습니다.

Azure 서비스 버스 기능을 사용하려고합니다. 응용 프로그램을 다른 환경 (dev, test, staging 등)에 배포했습니다. 내가 본 것에서 버스 당 하나의 메시지 유형 만 가질 수 있습니까? 각 환경을 지원하려면 서비스 버스의 개별 인스턴스가 필요합니까? Masstransit을 사용하고 있으며 표준 버전의 서비스가 필요하기 때문에 매월 인스턴스마다

0열

1답변

MassTransit에서 원시 메시지를 가져 오는 방법이 있습니까?

나는 일반 인수가 IEvent 인 소비자가 있습니다. 이 유형은 모든 메시지에 대한 기본 인터페이스이며 IEvent의 하위 인터페이스에는 몇 가지 다른 속성이 있습니다. 난 IEvent 범위 대신 중첩 형식의 모든 속성을 가진 원시 메시지에 액세스 할 수 싶습니다. RMQ admin 대시 보드를 통해 이러한 속성을 볼 수 있으며이를 배치하는 방법이 있어야한

0열

1답변

Masstransit ReceiveFrom 메소드 및 소비자 행동에 혼동 됨

한 쪽에서 일부 메시지를 보내고 다른 응용 프로그램에서 수신하는 RabbitMq가있는 대기열을 만들고 싶습니다. I'am는 다음 코드를 사용하여 이렇게 : return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch=

1열

1답변

Masstransit/RabbitMQ에서 대기열을 구성하는 방법은 무엇입니까?

메시지를 소비하는 모범 사례를 알고 싶습니다. MassTransit 문서를 읽었으며 이에 대해 조사했지만 어떤 결론에 도달하지는 않습니다. 게시 메시지 인 api (버스 인스턴스 호스팅)가 하나 있습니다. 이 API는 마이크로 서비스 (구매, 판매 등을위한 메시지)가 아니기 때문에 다양합니다. 소비자/대기열을 어떻게 구성해야합니까? 큐 유형에 대해 하나의

0열

1답변

RabbitMQ 다시 요청을 보내는

내가 다른 서비스 간 메시징을위한 masstransit와 RabbitMq을 사용하고는, 우리가 다음과 같은 시나리오가 있다고 가정 해 봅시다 : 먼저 서비스를 전송하여 두 번째 서비스에서 특정 정보에 대한 요청을 요청. 두 번째 서비스는 데이터베이스의 정보를 찾고 발견 된 정보가 포함 된 개체로 응답합니다. 데이터베이스에서 사용할 수있는 정보가없는 경우 두

2열

2답변

MassTransit 및 RabbitMq 호스트 방법

우리는 아래의 아키텍처와 같이 작업하고 있지만 대기열 및 버스를 사용하여 서로 이야기 할 수있는 일부 마이크로 온 서비스를 제공합니다. 이제 MassTransit과 RabbitMq을 호스팅해야하는 곳과 혼동을 겪었습니다. 또한 ASP.NET Core 프로젝트 자체가 있어야합니까? 그렇다면 내가 무엇을 할 것인가? 버스 출발? 대기열을 만드시겠습니까? 나는

0열

1답변

서비스 사이의 메시징 이벤트 대 명령

서비스 간의 메시징에 사용되는 여러 가지 방법을 이해하려고합니다. 사용자가 제품 생성을 요청했다는 것을 다른 사람에게 알리는 첫 번째 서비스가 필요한 시나리오가 있고 두 번째 서비스에서이 메시지를 받고 제품을 만든 다음 첫 번째 서비스에 대해 제품이 생성되었습니다. 첫 번째 서비스가 특정 서비스를 처리해야하고 피드백을 기다릴 것이므로 요청/응답과 함께 명령

0열

1답변

InMemoryTestFixture를 사용하여 대중 교통 소비자 테스트

다양한 콘텐츠로 소비자 메시지를 보낼 수있는 MassTransit 소비자 주변에서 테스트를하고 싶습니다. 소비자가 "작업하고"메시지를 릴레이하는 메시지의 내용을 기반으로합니다. 내가 가지고있는 문제는 두 가지 테스트를 실행할 때, 별도의 테스트 픽스처에서 두 번째 테스트를 방해하는 것으로 보입니다. 그러나 개별적으로 실행하면 각 테스트가 성공적으로 실행됩니