masstransit

3열

1답변

많은 스레드를 회전시키는 응용 프로그램이 있습니다. 각 스레드는 masstransit/rabbitmq를 통해 동일한 메시지 유형을 제출합니다. IBus의 한 인스턴스를 저장하기 위해 싱글 톤을 만들었습니다. 응용 프로그램은 구성에 엔드 포인트가 없도록 메시지 만 공개합니다. 싱글 톤 메시지 버스는 게시 할 때 올바른 작업일까요? 필자는 끊임없이 메시지를 게

0열

1답변

CQRSLite 및 MassTransit 통합

저는 현재 CQRSLite 프레임 워크와 함께 MassTransit을 버스 구현으로 사용하는 방법을 알고 있습니다. 문제, 내가 현재 가지고있어 것을 어떻게 제대로처럼 핸들러에 메시지를 라우팅 (명령 및 이벤트)을 위해 MassTransit 측에서 소비자를 등록하려면이 public class InventoryCommandHandlers : ICommandH

1열

1답변

Masstransit - 멀티 테넌트 지원을위한 반복적 인 메시지 스케줄링

다중 테넌트 애플리케이션에 Masstransit scheduling API를 사용하고 싶습니다. 세입자 당 반복되는 메시지를 보내야합니다. var schedule1 = new MySchedule("1 * * * * ?", "Tenant 1"); var schedule2 = new MySchedule("6 * * * * ?", "Tenant 2"); e

2열

1답변

MassTransit 및 서비스 패브릭 스테이트 풀 서비스?

저는 RabbitMQ와 함께 MassTransit을 사용하여 Service Fabric에서 실행되는 서비스에 Stateful 서비스로 메시지를 게시하는 웹 사이트의 데모를 제안하려고했습니다. IBusControl bus = BusConfigurator.ConfigureBus(); Uri sendToUri = new Uri($"{RabbitMqConstan

0열

1답변

진단 정보를 RabbitMQ에 로깅

현재 Nlog를 사용하여 진단 유형 메시지를 저장하고 있습니다. 이 메시지를 메시지 대기열 (RabbitMQ with Masstransit)에 로깅하는 것을 고려 중이며 이러한 메시지는 분석을 위해 데이터베이스로 소비 될 수 있습니다. 게시/내 PC에 메시지를 기록하는 현재 속도는 다음과 같습니다 - Nlog : 40ms로 petapoco를 통해 는 SQL

0열

1답변

CreateQueues and Exchanges - MassTransit

나는 RabbitMQ와 함께 massTransit을 사용하고 있습니다. massTransit으로 메시지를 게시하면 내 메시지 유형에 대한 교환이 생성됩니다. 그리고 masstransit 소비자는 대기열과 교환을위한 바인딩을 만듭니다. 좋습니다. massTransit을보기 전에 나는 rabbitMQ의 api를 사용하여 대기열, 교환 및 바인딩을 만들었습니다.

0열

1답변

MassTransit 동일한 프로세스에서 실행중인 두 개의 다른 응용 프로그램에 대한 메모리 설정에서

두 응용 프로그램 각각에 대해 AppDomain을 작성하여 동일한 프로세스에서 실행되는 두 개의 서로 다른 응용 프로그램이 있습니다. 응용 프로그램 1에 대한 버스 설정은 다음과 같습니다 : 나는 응용 프로그램 2 프로그램 1에서 메시지를 보낼 때 builder.Register(c => { var inMemoryTransportC

0열

1답변

Masstransit에서 데드 레터 메시지 큐 구성

요청/응답 패턴이있는 Masstransit을 사용 중입니다. 사용 가능한 경우 데드 레터 메시지 큐 이름 및이 큐와 관련된 다른 구성을 지정하려고합니다. UseDeadLetterQueue 확장 메소드가 있음을 알 수 있습니다. IPipeConfigurator 유형으로 설정해야하지만 유형은 ReceiveEndpoint 메소드에서 IRabbitMqReceive

0열

1답변

요청/응답에 대해 MassTransit 오류 소비자가 호출되지 않음

요청/응답 패턴과 관련하여 MassTransit 3+에서 예외를 처리하는 가장 좋은 방법은 무엇입니까? docs here은 ResponseAddress가 메시지에 존재하면 오류 메시지가 해당 주소로 보내지지만 한 소비자는 해당 주소에서 메시지를 어떻게 받습니까? Bus.Request에 대한 ResponseAddress는 자동 생성 된 MassTransit

0열

1답변

.NET 응용 프로그램에서 응답이없는 RabbitMQ 검색 및 처리

최근에 우리 토끼 클러스터에 인위적으로 높은 부하가 주어져서 API 중 하나가 응답하지 않는 중단이있었습니다. 모노 (.NET)로 쓰레드가 부족하고 API 요청이 실패한 곳입니다. 이것이 다시는 일어나지는 않을지라도, 우리는 이것을 막기 위해 약간의 보호를하고 싶습니다. 이상적으로 우리는 bus.Publish()에 대한 호출 시간을 정해진 시간 후에 타임