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

Update KillSwitch.cs to activate StartedKillSwitchState when connecte… (#6009)

год назад
Contexts

Use StopTimeout, if specified, when stopping receive endpoints to avoid hanging indefinitely.

2 года назад
Fabric

Fixed warnings

год назад
AddressEqualityComparer.cs

Massive file cleanup

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

Fixing #1611 - reduced headers on Amazon SQS, added ability to conditionally pass headers to the transport.

7 лет назад
BaseHost.cs

Fixed bus start/stop issue with receive endpoint collection not actually stopping the bus after being restarted.

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

Fixed #5159 - Duplicate delivery logic when redelivery faulted messages should now work properly.

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

Use StopTimeout, if specified, when stopping receive endpoints to avoid hanging indefinitely.

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

Replace Array.Empty with collection expression

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

Fixed #5712 - Moved bus transport configuration check to the bus depot to throw an exception when trying to start the bus when no bus has been configured.

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

CheckHealth moved to IBusControl - still supporting IBusHealth for legacy but not used by any internal components.

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

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

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

Reduce async/await usage for DisposeAsync

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

Fixed #3565 - changed it so that RequestId is no longer copied to messages published/sent by a request consumer

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

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

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

Use StopTimeout, if specified, when stopping receive endpoints to avoid hanging indefinitely.

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

Support for dispatching byte[]/string to a receive endpoint, easily, using an IReceiveEndpointDispatcher<T> - any guess where this is heading?

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

Enable configuration to not include the message type namespace in the entity name for all transports (topics/exchanges)

год назад
DelegatePartitionKeyFormatter.cs

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

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

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

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

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

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

Cleanup using

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

Additional fixes for #3286 - leaked exception types and failure to retry the connection exception.

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

Related to #4016 - split out send retry policy for Azure Service Bus (for now) to recycle the receive transport when entities are deleted.

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

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

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

Fixed #3146 - ISubscriptionEndpointConnector is now properly registered for multi-bus instances, either using the raw interface or via Bind<TBus,ISEC...>

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

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

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

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

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

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

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

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

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

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

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

Fixed bus start/stop issue with receive endpoint collection not actually stopping the bus after being restarted.

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

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

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

Cleanup using

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

Added lock context handlers to deal with duplicate message deliveries from the transport.

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

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

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

Fixed #3737 - Rider endpoints were not included in health checks

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

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

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

Code cleanup. Remove copyrights

6 лет назад
ITransportSendEndpoint.cs

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

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

Support for dispatching byte[]/string to a receive endpoint, easily, using an IReceiveEndpointDispatcher<T> - any guess where this is heading?

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

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

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

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

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

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

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

Fixed #3146 - ISubscriptionEndpointConnector is now properly registered for multi-bus instances, either using the raw interface or via Bind<TBus,ISEC...>

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

Fixed #5159 - Duplicate delivery logic when redelivery faulted messages should now work properly.

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

Added test validating that publish observer is called by request client for published requests

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

Fixed bus start/stop issue with receive endpoint collection not actually stopping the bus after being restarted.

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

Fixed bus start/stop issue with receive endpoint collection not actually stopping the bus after being restarted.

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

Added lock context handlers to deal with duplicate message deliveries from the transport.

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

Cleanup using

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

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

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

Massive file cleanup

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

Working on #1576 - Added mediator, which enabled message dispatch to a receive pipe, entirely in-memory, no transport and no serialization. Also added common receive pipe dispatcher to try up transport logic.

6 лет назад
ReceivePipeDispatcher.cs

Refactoring telemetry

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

An OperationCanceledException (typically happens when the consumer stop times out) should not cause the receive transport to exit.

год назад
ReceiveTransportHandle.cs

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

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

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

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

Fixed #3737 - Rider endpoints were not included in health checks

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

Cleanup using

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

Cleaned up leftover container abstractions that were no longer useful

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

Reduce async/await usage for DisposeAsync

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

Massive file cleanup

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

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

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

Code cleanup. Remove copyrights

6 лет назад
SendEndpointProvider.cs

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

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

Cleaned up leftover container abstractions that were no longer useful

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

Refactoring telemetry

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

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

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

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

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

Added context-based methods for connecting subscription endpoints

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

Minor fixes, removed unused methods, warnings

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

Changed send transports to use a separate Stopping token so that they aren't stopped until all receive transports are stopped, to prevent race conditions on messages sent/published by consumers.

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

Use ReceiveEndpointDependencyFilter to manage dependencies. Add new AddDependency override

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

Working on #1576 - Added mediator, which enabled message dispatch to a receive pipe, entirely in-memory, no transport and no serialization. Also added common receive pipe dispatcher to try up transport logic.

6 лет назад