Bug fix ReplyTo werkte niet op static queues
This commit is contained in:
parent
50bcd26d40
commit
cf53a1e6b1
@ -47,7 +47,7 @@ namespace Tapeti.Config
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public interface IDynamicQueueBinding : IBinding
|
public interface IBuildBinding : IBinding
|
||||||
{
|
{
|
||||||
void SetQueueName(string queueName);
|
void SetQueueName(string queueName);
|
||||||
}
|
}
|
||||||
|
@ -83,11 +83,17 @@ namespace Tapeti.Connection
|
|||||||
channel.QueueBind(dynamicQueue.QueueName, exchange, routingKey);
|
channel.QueueBind(dynamicQueue.QueueName, exchange, routingKey);
|
||||||
}
|
}
|
||||||
|
|
||||||
(binding as IDynamicQueueBinding)?.SetQueueName(dynamicQueue.QueueName);
|
(binding as IBuildBinding)?.SetQueueName(dynamicQueue.QueueName);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
{
|
||||||
channel.QueueDeclarePassive(queue.Name);
|
channel.QueueDeclarePassive(queue.Name);
|
||||||
|
foreach (var binding in queue.Bindings)
|
||||||
|
{
|
||||||
|
(binding as IBuildBinding)?.SetQueueName(queue.Name);
|
||||||
|
}
|
||||||
|
}
|
||||||
}).Unwrap();
|
}).Unwrap();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -392,7 +392,7 @@ namespace Tapeti
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
protected class Binding : IDynamicQueueBinding
|
protected class Binding : IBuildBinding
|
||||||
{
|
{
|
||||||
public Type Controller { get; set; }
|
public Type Controller { get; set; }
|
||||||
public MethodInfo Method { get; set; }
|
public MethodInfo Method { get; set; }
|
||||||
|
Loading…
Reference in New Issue
Block a user