0
RabbitMQでMassTransitを使用したリクエストレスポンスパターンで、リクエストクライアントを作成しようとしています。私は2つの可能性を見たインターネット上でいくつかの研究行っているときしかし:CreateRequestClientとCreatePublishRequestClientの違い
CreateRequestClientとCreatePublishRequestClient
を誰かがそれらの2とするときにそれらを使用する方法との違い何を知っていますか?
は、方法については、以下を参照してください。
public static class RequestClientExtensions
{
public static IRequestClient<TRequest, TResponse> CreateRequestClient<TRequest, TResponse>(this IBus bus, Uri address, TimeSpan timeout, TimeSpan? ttl = null, Action<SendContext<TRequest>> callback = null) where TRequest : class where TResponse : class
{
return (IRequestClient<TRequest, TResponse>) new MessageRequestClient<TRequest, TResponse>(bus, address, timeout, ttl, callback);
}
public static IRequestClient<TRequest, TResponse> CreatePublishRequestClient<TRequest, TResponse>(this IBus bus, TimeSpan timeout, TimeSpan? ttl = null, Action<SendContext<TRequest>> callback = null) where TRequest : class where TResponse : class
{
return (IRequestClient<TRequest, TResponse>) new PublishRequestClient<TRequest, TResponse>(bus, timeout, ttl, callback);
}
}
この素晴らしい返信をありがとうございます。私は住所として渡さなければならないことも知っていますか?いくつかの例では、rabbitmq:// localhost/test/request_serviceを参照しています。しかし、私がこれを試すと、URLは認識されません。例では決して説明されていません。 – Ozkan
もう少し説明:私はどこに '/ test/request_service'のURLの部分を設定できるか知りたいです。これについては、インターネット上の多くの文書はありません。 – Ozkan
2つのサービスがあり、それぞれに依頼する場合、要求クライアントのアドレスは、要求を処理するサービスのアドレスです。これは '新しいUri(" rabbitmq:// servicebushost/second_service_queue ")のようなものです –