Oğuzhan Soykan

CorrelationId/CausationId implementation

6

Ideas are; ``` Request using(AspnetCore Middleware (Generates CorrelationId)) { Captured by CommandContextAccessor.CorrelationId Set Command.CorrelationId with MediatR pipeline hook Set EventMetadata.CausationId AppendToStream } ```

Currently, the order for pipeline behaviors is the registration order to the mediator. But, in most of the cases order matters. So, it would be great to define the order...

## Option-1, sectioned ```kotlin val mediator = mediator { pipelineBehaviours { MeasurePipelineBehaviour() } notificationHandlers { register() } queryHandlers { register() } commandHandlers { register() } } ``` ## Option-2, without...

Hi, I would like to capture what is consumed and published from an application, and I want the application to go through a Kafka proxy. Does this source code (without...

Arranging code-base for multi-platform support? ```[tasklist] ### Tasks - [ ] kediatr-core as multi-platform - [ ] kediatr-koin as kmp ```

Improve WithDsl

1

Options can be defined better for example: From: ```kotlin wiremock { WireMockSystemOptions( port = 9090, removeStubAfterRequestMatched = true, afterRequest = { e, _, _ -> logger.info(e.request.toString()) }, ) } ```...

I thought the problem in on KafkaReceiver but it is the default polling timeout was too low (100ms). When I changed it, it worked. So we have extra tests 😄...