Class RequestReceiver
Represents an endpoint that listens for requests for a given service contract when started, using the MassTransit transport.
Inheritance
Namespace: Copper.Remoting.MassTransit.Common.V1
Assembly: Copper.Remoting.MassTransit.Common.dll
Syntax
public class RequestReceiver : IRequestReceiver, IEndpoint
Constructors
View SourceRequestReceiver(IBusControlFactory, RequestReceiverSettings, IDispatchMessageFormatter, IOptions<ReceiveEndpointOptions>)
Initializes a new instance of the RequestReceiver class.
Declaration
public RequestReceiver(IBusControlFactory busControlFactory, RequestReceiverSettings requestReceiverSettings, IDispatchMessageFormatter dispatchMessageFormatter, IOptions<ReceiveEndpointOptions> receiveEndpointOptions)
Parameters
Type | Name | Description |
---|---|---|
IBusControlFactory | busControlFactory | The bus control factory. |
RequestReceiverSettings | requestReceiverSettings | The request receiver settings. |
IDispatchMessageFormatter | dispatchMessageFormatter | The dispatch message formatter. |
IOptions<ReceiveEndpointOptions> | receiveEndpointOptions | The receive endpoint options. |
Methods
View SourceRetrieveEndpointMetadata()
Retrieves the endpoint's metadata.
Declaration
public EndpointMetadata RetrieveEndpointMetadata()
Returns
Type | Description |
---|---|
EndpointMetadata | The endpoint's metadata. |
Start<TContract>(TContract)
Starts the endpoint, causing it to start listening for requests.
Declaration
public async Task<string> Start<TContract>(TContract instance)
where TContract : class
Parameters
Type | Name | Description |
---|---|---|
TContract | instance | The instance implementing the service contract. |
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task<System.String> | A System.Threading.Tasks.Task that represents outstanding operation. The result of the System.Threading.Tasks.Task is the endpoint System.String. |
Type Parameters
Name | Description |
---|---|
TContract | The service contract type. |
Stop()
Stops the endpoint, causing it to not receive any requests.
Declaration
public async Task Stop()
Returns
Type | Description |
---|---|
System.Threading.Tasks.Task | A System.Threading.Tasks.Task that represents outstanding operation. |