masstransit

0열

1답변

Entity Framework 및 MySQL을 사용한 MassTransit Saga 지속성

MassTransit (RabbitMQ 사용) 및 Automatonymous를 사용하여 Saga를 개발 중입니다. 내 저장소 엔진으로 EntityFramework를 사용하고 데이터베이스로 MySQL을 사용하고 있습니다. EF와 MySQL의 결합은 사가를 실행하고 데이터베이스에 상태를 저장하려고 할 때마다 예외를 던지고 있습니다. 이 문제는 this 샘플 응

0열

1답변

트랜잭션 스코프에서 서비스 버스 하늘색 호출 방법

서비스 버스 하늘색에서 MassTransit.Publish를 호출 할 때 호출이 TransactionScope에 있기 때문에 예외가 있습니다. The feature 'Transaction' is not supported with the current configuration 트랜잭션 모드에서 트랜잭션 모드없이 버스에서 메시지를 보내는 방법은? 나는 버스

1열

2답변

Quartz 작업 교착 상태에서 Masstransit IRequestClient.Request 호출

Masstransit IRequestClient.Request 메서드 호출을 통해 비즈니스 서비스를 호출하는 보고서가 있습니다. 이 보고서가 UI (ASP.NET MVC 컨트롤러)에서 빌드 된 경우 모든 것이 작동하지만 동일한 보고서가 Quartz .net 작업 메서드 호출에서 빌드되는 경우 결코 반환되지 않습니다. //client is an instanc

0열

1답변

MassTransit - 다중 소비자 설정에서 동시에 처리되는 메시지 제한

현재 RabbitMQ를 사용하여 웹 응용 프로그램에서 비동기 메시지를 처리하는 단일 Windows 서비스가 있습니다. 이 서비스는 메시지에서 엔터티 ID를 사용하여 처리해야하는 엔터티를 조회합니다. 이 메시지는 현재 내부 조치 로그에 의해 이미 제공 되었기 때문에 엔티티에 수행해야하는 작업을 나타내지 않습니다. 여러 경쟁 환경으로 이동하는 것을 돕기 위해

0열

1답변

Consume 메소드에서 수신 된 메시지 다운 캐스트

Consumer (및 버스)의 양을 제한하기 위해 Consumer()/Queue에서 일부 처리를 그룹화하려고합니다. 하지만 소비자의 메시지를 올바른 개체로 전송할 때 문제가 발생합니다. 두 종류의 요청 유형을 처리해야하는 Consumer가 하나 있다고 가정합니다. 두 가지 하위 요청 유형은 기본 유형에서 파생되며 파생 유형으로 메시지를 보내고 Consume

0열

1답변

대량 전송을 위해 다시 시도를 구성 할 때 처리 할 예외

대량 전송 소비자에서 UseScheduledRedelivery를 구성 할 때. 무엇을 처리해야하는지에 대한 모범 사례는 무엇입니까? 예외적 인 과충전이 처리됩니까? proberbly 복구 할 수있는 예외 목록이 있습니까?

1열

1답변

RabbitMq 소비자가 소비하지 않음

public class RequestConsumer : IConsumer<StartFlowCommand>, IConsumer<List<StartAndNextCommand>> { readonly IWorkFlowHandler _flowHandler; public RequestConsumer(IContainer contai

1열

1답변

Masstransit 오류 대기열이 소모되었지만 여전히 비어 있지 않습니다.

Mastransit 3.5.0을 RabbitMq과 함께 사용하고 있습니다. 큐 소비자가 예외를 throw하면 기본적으로 MoveExceptionToTransportFilter가 처리하고 _error 큐로 이동합니다. _error 대기열에 대해 별도의 소비자가 있습니다. Consume (ConsumeContext> context) 오류 동작은 다소 다릅니다.

1열

1답변

MassTransit 및 RabbitMQ로 다양한 명령 유형을 보내는 방법은 무엇입니까?

저는 메시지 브로커를 사용하는 초보자입니다. 우리는 여러 개의 서브 서비스가있는 발권 서비스를 가지고 있습니다. 수퍼바이저 서비스는 웹 API의 도움을 받아 요청을 받고 하위 서비스로 보냅니다. 모든 요청에는 명령 유형 (예 : 예약, 환불, 가용성 등)을 검색하는 데 사용되는 헤더가 있습니다. json을 사용하여 객체를 직렬화합니다. 이제 Supervis

0열

1답변

MassTransit 요청/응답 대화를 통한 가입자 확장

웹 프로젝트에서 사용하기 위해 Masstransit/RabbitMq를 사용하여 엔터프라이즈 서비스 버스를 구현했습니다. 나는 RPC를 MQ보다 Request/Response 패턴을 사용하여 MQ를 수행한다. 다른 유형의 메시지를 처리하는 버스에 여러 ReceiveEndpoint를 생성합니다. ESB는 사용자 정의 구성 파일을 사용하여 다중 버스를 생성하기