masstransit

0열

1답변

MassTransit에서 소비하는 모든 메시지를 기록하고 싶습니다. 수입 메시지를 처리하거나 구성을 사용하여 달성 할 수있는 세계적인 요격기를 구현할 수있는 방법이 있습니까? 나의 현재 설정은 다음과 같습니다 BusFactory = Bus.Factory.CreateUsingRabbitMq(cfg => { var host = cfg.Host(new

1열

1답변

어떻게 초기화해야합니까? CorrelationId at MassTransit

기본 제공 인터페이스 CorrelatedBy<TKey>을 사용하여 내 메시지를 추적하고 싶습니다. 그러나 저는 이해하지 못했습니다 : 예를 들어, 내 메시지 (생성자)의 생성자에서 직접 초기화해야합니까? ? public class RegisterCallback : IRegisterCallback { public RegisterCallback()

2열

1답변

C# 및 RabbitMQ를 사용하여 MassTransit v3에서 게시 전용 버스 구현

버스에 소비자가없는 C# 및 RabbitMQ를 사용하여 MassTransit v3에 게시 전용 버스를 구현하려고합니다. 개념은 메시지가 게시되고 대기열에 들어간 다음 개별 마이크로 서비스가 대기열에서 메시지를 소비합니다. this SO answer에서 메시지 수신 대기열을 지정해야합니다. 그러나 이것은 으로 표시되며 If you need to only se

0열

1답변

MassTransit 및 MaxConcurrentCalls가 예상대로 작동하지 않습니까?

저는 Azure Service Bus 위에서 실행되는 메시징 프레임 워크로 MassTransit을 사용하고 있습니다. 저는 WebJob 내부에서 MassTransit을 실행하고 있습니다. (중요하지 않다고 생각 하긴하지만) 이제는 MassTransit에서 동시에 여러 메시지를 처리하려고합니다. 이제는 개별적으로 메시지를 처리하고 있습니다. 처리하는 데 시간

1열

1답변

MassTransit 특정 큐에 게시

MassTransit 앱을 2.x에서 3.x로 성공적으로 업데이트하고 전송을 위해 RabbitMQ로 전환했습니다. 이전에 개발자가 MSMQ에서 작동 할 것이라고 생각한 일대 다 메시징을 제대로 수행하기 위해이 작업을 수행했지만 작동하지 않는 것으로 밝혀졌으며 3.x 및 RabbitMQ를 사용해야하는 설명서를 읽음으로써 명확 해졌습니다. . 내 응용 프로그램

0열

1답변

MassTransit에 RabbitMQ 필수 플래그가 지원됩니까?

메시지가 대기열로 전달되지 않으면 MassTransit을 사용하여 RabbitMQ 교환에 보낼 때 예외를 얻고 싶습니다. RabbitMQ 필수 플래그가 이런 식으로 사용될 수있는 것처럼 보이지만 MassTransit을 사용하여이를 설정하는 방법을 찾지 못했습니다. 지원됩니까? 내 코드 : var personSendEndpoint = busControl.Ge

0열

1답변

ConsumeContext에 사용자 정의 페이로드를 추가하는 방법은 무엇입니까?

나는이 public Task Consume(ConsumeContext<Message1> context) { context.GetOrAddPayload(() => new Payload()); return context.Publish(new Message2()); } 처럼 ConsumeContext에 사용자 정의 페이로드를 추가하고 M

1열

1답변

MassTransit을 사용하여 AzureServiceBus에서 토픽 만들기

AzureSerivceBus에서 생성 된 네임 스페이스가 있습니다. Azure API를 사용하여 직접 토픽을 생성하고 그것에 메시지를 전송할 수 있습니다. 이제 MassTransit을 추상화 레이어로 사용하여 Topics를 만들 수 있기를 바랍니다. 로컬 설치의 경우 RabbitMq을 사용하고 MassTransit은 좋은 추상화를 제공하기 때문입니다. 이제

0열

1답변

MassTransit 및 messageType 속성

rabbitmq/api를 사용하여 원격 호스트에서 rabbitmq로 메시지를 게시 할 수있는 사례가 있으며 게시 된 메시지 처리를 MassTransit 소비자에게 전달하고 싶습니다. 내가 알 수있는 바와 같이, MassTransit 소비자와 성공의 "최소한의 필요한 속성"처리 메시지는 다음과 같습니다 페이로드 : { 'messageId':'86fd

0열

1답변

MassTransit : 메시지 간 종속성

MassTransit with RabbitMQ 관련 질문. 2 개의 메시지 사이에 의존성을 만들어야합니다. 메시지 1이 완료된 후 1) 새로운 계약 만들기 2) 업데이트 ContractOptions 두 번째 메시지는 실행할 수 있습니다. 어떻게하면됩니까?