Interface IClientFactory
- Namespace
- MassTransit
- Assembly
- MassTransit.Abstractions.dll
The client factory is used to create request clients
public interface IClientFactory
Properties
Context
ClientFactoryContext Context { get; }
Property Value
Methods
CreateRequestClient<T>(ConsumeContext, RequestTimeout)
Create a request client for the specified message type
IRequestClient<T> CreateRequestClient<T>(ConsumeContext consumeContext, RequestTimeout timeout = default) where T : class
Parameters
consumeContext
ConsumeContextThe consumeContext currently being processed
timeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequestClient<T>(ConsumeContext, Uri, RequestTimeout)
Create a request client, using the specified service address
IRequestClient<T> CreateRequestClient<T>(ConsumeContext consumeContext, Uri destinationAddress, RequestTimeout timeout = default) where T : class
Parameters
consumeContext
ConsumeContextThe consumeContext currently being processed
destinationAddress
UriThe destination service address
timeout
RequestTimeoutThe default timeout for requests
Returns
Type Parameters
T
CreateRequestClient<T>(RequestTimeout)
Create a request client for the specified message type
IRequestClient<T> CreateRequestClient<T>(RequestTimeout timeout = default) where T : class
Parameters
timeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequestClient<T>(Uri, RequestTimeout)
Create a request client, using the specified service address
IRequestClient<T> CreateRequestClient<T>(Uri destinationAddress, RequestTimeout timeout = default) where T : class
Parameters
destinationAddress
UriThe destination service address
timeout
RequestTimeoutThe default timeout for requests
Returns
Type Parameters
T
CreateRequest<T>(ConsumeContext, object, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(ConsumeContext consumeContext, object values, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
consumeContext
ConsumeContextThe consumeContext currently being processed
values
objectThe values to initialize the message
cancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(ConsumeContext, Uri, object, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(ConsumeContext consumeContext, Uri destinationAddress, object values, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
consumeContext
ConsumeContextThe consumeContext currently being processed
destinationAddress
UriThe destination service address
values
objectThe values to initialize the message
cancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(ConsumeContext, Uri, T, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(ConsumeContext consumeContext, Uri destinationAddress, T message, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
consumeContext
ConsumeContextThe consumeContext currently being processed
destinationAddress
UriThe destination service address
message
TcancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(ConsumeContext, T, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(ConsumeContext consumeContext, T message, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
consumeContext
ConsumeContextThe consumeContext currently being processed
message
TcancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(object, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(object values, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
values
objectThe values to initialize the message
cancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(Uri, object, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(Uri destinationAddress, object values, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
destinationAddress
UriThe destination service address
values
objectThe values to initialize the message
cancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(Uri, T, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(Uri destinationAddress, T message, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
destinationAddress
UriThe destination service address
message
TcancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type
CreateRequest<T>(T, CancellationToken, RequestTimeout)
Create a request, using the message specified. If a destinationAddress for the message cannot be found, the message will be published.
RequestHandle<T> CreateRequest<T>(T message, CancellationToken cancellationToken = default, RequestTimeout timeout = default) where T : class
Parameters
message
TcancellationToken
CancellationTokentimeout
RequestTimeout
Returns
Type Parameters
T
The message type