/
vshmidt
/
masstransit
ОбзорДокументацияВойти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
ДокументацияПоддержка
Политика конфиденциальностиПользовательское соглашениеПолитика использования «cookies»Согласие субъекта персональных данных
2026 ©
masstransit/
.../MassTransit/Middleware/
..
CircuitBreaker

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
InMemoryOutbox

Fixed in-memory outbox telemetry to capture ExecutionContext, which should properly flow activity traces

год назад
Outbox

Massive file cleanup

2 года назад
Rescue

Added ExceptionHeaders to ExceptionReceiveContext so that additional transport headers can be specified (or existing headers replaced/removed) when moving messages to the error queue.

2 года назад
Timeout

Add the ability to delay execute of the next routing slip activity, as well as a new callback for setting variables, setting the delay.

год назад
CircuitBreakerFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
CompensateActivityFactoryFilter.cs

Cleanup using

4 года назад
CompensateActivityFilter.cs

Cleanup using

4 года назад
ConcurrencyLimitFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ConcurrencyLimiter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ConsumeConcurrencyLimitFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ConsumeContextConverterFactory.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ConsumeContextOutputMessageTypeFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
ConsumePipe.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
ConsumerMergePipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ConsumerMessageFilter.cs

Fixed #4692 - OperationCanceledException was for some reason not showing up in GetBaseException(), so checking for both now.

3 года назад
ConsumerMessageMergePipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ConsumerSplitFilter.cs

Massive file cleanup

2 года назад
ContextFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
CorrelatedSagaFilter.cs

Fixed #4692 - OperationCanceledException was for some reason not showing up in GetBaseException(), so checking for both now.

3 года назад
CorrelationIdMessageFilter.cs

Added configuration for Jaeger testing, to ensure that the open telemetry integration actually works.

5 лет назад
DeadLetterFilter.cs

Fixed #4867 - Changed Configure Topology Filter One Time Setup to use entirely new approach

3 года назад
DeadLetterTransportFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
DelaySendPipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
DelayedMessageRedeliveryContext.cs

Adding nullability to abstractions, and fixing warnings

4 года назад
DelayedMessageRedeliveryFilter.cs

Changed consume pipe so that simple ConsumeContext filters are PrePipe configured prior to the dispatch filter

5 лет назад
DelayedMessageSchedulerFilter.cs

Fixed #3832 (again) - this time, is more stain removing power (Azure Scheduled Message Cancel vs. Skip)

4 года назад
DeserializeFilter.cs

First pass at ActivitySource migration

5 лет назад
DiscardDeadLetterFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
DiscardErrorTransportFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
DynamicFilter.cs

Replace Array.Empty with collection expression

2 года назад
DynamicRouter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ErrorTransportFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ExecuteActivityFactoryFilter.cs

Cleanup using

4 года назад
ExecuteActivityFilter.cs

Cleanup using

4 года назад
FaultDeadLetterFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ForkFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
FutureRequestPipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
FutureResultPipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
GenerateFaultFilter.cs

Fixed #6045 - ReceiveFault called in places it shouldn't be called (should be Dispatcher only).

год назад
HandlerMessageFilter.cs

Fixed #4692 - OperationCanceledException was for some reason not showing up in GetBaseException(), so checking for both now.

3 года назад
IConcurrencyLimiter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IConsumeContextMessageTypeFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
IConsumerMessageFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IDynamicFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IDynamicRouter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IHashGenerator.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ILatestFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IOutboxContextFactory.cs

Working on an inbox/outbox implementation for Entity Framework Core, InMemory, and ultimately additional transaction-based storage engines

4 года назад
IOutputMessageTypePipeFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
IOutputPipeFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IPipeConnector.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
IPipeContextConverter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IPipeContextConverterFactory.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
IPipeRouter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ISagaMessageFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ITeeFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
InMemoryOutboxFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
InitiatedByOrOrchestratesSagaMessageFilter.cs

Refactoring telemetry

3 года назад
InitiatedBySagaMessageFilter.cs

Refactoring telemetry

3 года назад
InlineFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
InstanceMessageFilter.cs

Fixed #4692 - OperationCanceledException was for some reason not showing up in GetBaseException(), so checking for both now.

3 года назад
InterceptFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
InternalOutboxExtensions.cs

Massive file cleanup

2 года назад
JobConsumerMessageFilter.cs

Job Consumers - Reworked CancelJob so that it goes through the sagas, no longer creating a subscription on the instance. Also, made it so that jobs canceled when an instance was stopped are automatically rescheduled for the next available job consumer instance.

2 года назад
KeyAccessor.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
KeyFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
LatestFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
MessageSchedulerFilter.cs

Fixed #3832 (again) - this time, is more stain removing power (Azure Scheduled Message Cancel vs. Skip)

4 года назад
MessageSplitFilter.cs

Massive file cleanup

2 года назад
MessageTypeFilter.cs

Replace Array.Empty with collection expression

2 года назад
MethodConsumerMessageFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
MissingInstanceRedeliveryPipe.cs

Fixed #3807 - added ability to configure redelivery for completed/faulted events that arrive prior to the started event

4 года назад
MissingSagaPipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
Murmur3UnsafeHashGenerator.cs

Massive file cleanup

2 года назад
ObserverMessageFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ObservesSagaMessageFilter.cs

Refactoring telemetry

3 года назад
OrchestratesSagaMessageFilter.cs

Refactoring telemetry

3 года назад
OutboxConsumeContext.cs

Working on an inbox/outbox implementation for Entity Framework Core, InMemory, and ultimately additional transaction-based storage engines

4 года назад
OutboxConsumeFilter.cs

Fixed #3577 - wrong context used for consumer dependency injection when outbox is used.

4 года назад
OutboxConsumeOptions.cs

Fixed #3791 - Again, but this time with a new lock update strategy to ensure the InboxState is truly locked, avoiding inconsistency and duplicate messages on the broker.

4 года назад
OutboxMessageContext.cs

Added the supported message types to the outbox table (update your migrations for EF Core) and use the outbox message properties to initialize the send context.

3 года назад
OutboxMessagePipe.cs

Fixed #5595 - If an exception is thrown by the outbox when saving changes after a consumer completes, produce a typed Fault<T>

2 года назад
OutboxMessageSendPipe.cs

Fixed #5881 - transfer MT-* headers from outbox message to the SendContext so that the transport can use them.

год назад
OutboxSendContext.cs

Fixed #4070 - Transactional Outbox now properly shares the consume scope with send/publish so that scoped filters run in the same container scope as the consumer transaction.

4 года назад
OutputPipeFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
Partition.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
PartitionFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
Partitioner.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
PayloadFilter.cs

Refactored job service for container-based configuration and eliminated the need for service instance configuration. Added extensions for Cosmos, Redis, MongoDB, Azure Table, EF Core

3 года назад
PipeContextConverterFactory.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
PipeContextSourceBindFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
PipeRouter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
PublishMessageSchedulerFilter.cs

Fixed #3832 (again) - this time, is more stain removing power (Azure Scheduled Message Cancel vs. Skip)

4 года назад
QuerySagaFilter.cs

Fixed #4692 - OperationCanceledException was for some reason not showing up in GetBaseException(), so checking for both now.

3 года назад
RateLimitFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ReceiveEndpointDependencyFilter.cs

Use ReceiveEndpointDependencyFilter to manage dependencies. Add new AddDependency override

3 года назад
RedeliveryRetryFilter.cs

Fixed #5812 - Redelivery filter can now be properly stacked/chained/etc.

2 года назад
RequestIdFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
RequestIdTeeFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
RescueContextFactory.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
RescueFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
RethrowErrorTransportFilter.cs

Fixed #6045 - ReceiveFault called in places it shouldn't be called (should be Dispatcher only).

год назад
RetryBusObserver.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
RetryFilter.cs

Fixed #4867 - Changed Configure Topology Filter One Time Setup to use entirely new approach

3 года назад
SagaMergePipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
SagaMessageMergePipe.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
SagaMessageSplitFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
SagaSplitFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ScheduleMessageRedeliveryFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ScopeCompensateFilter.cs

Cleanup using

4 года назад
ScopeConsumeFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ScopeExecuteFilter.cs

Cleanup using

4 года назад
ScopeMessageFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
ScopedCompensateFilter.cs

Add generic scoped filter type to configuration JSON

3 года назад
ScopedConsumeFilter.cs

Add generic scoped filter type to configuration JSON

3 года назад
ScopedExecuteFilter.cs

Add generic scoped filter type to configuration JSON

3 года назад
ScopedFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
SendQuerySagaPipe.cs

Fixed #4333 - Change query-based saga dispatch to sequential vs parallel

3 года назад
SendSagaPipe.cs

Added configuration for Jaeger testing, to ensure that the open telemetry integration actually works.

5 лет назад
SetCorrelationIdFilter.cs

Cleanup using

4 года назад
SetPartitionKeyFilter.cs

Standardized the topology for partition key across service bus, event hub, and the SQL transport

2 года назад
SetRoutingKeyFilter.cs

Refactored RoutingKey send topology formatter into the main assembly (used by gRPC and RabbitMQ, also the Database Transport)

3 года назад
SetSerializerFilter.cs

Fixed #4240 - Added ability to specify message type specific serialization content type

3 года назад
StateMachineSagaMessageFilter.cs

Massive file cleanup

2 года назад
TeeFilter.cs

Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.

2 года назад
TimeoutFilter.cs

Updating cancellation token handling for consumers, sagas, and routing slip activities for consistent handling of consumer-generated OperationCanceledExceptions

3 года назад
TransactionFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
TransformFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад
TransportReadyFilter.cs

Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.

5 лет назад