同样的过程订阅在Rebus中是不可能的

我想在同一个进程/ AppDomain中使用Rebus作为内部总线。同样的过程订阅在Rebus中是不可能的

我已经修改了Pub/Sub sample，并增加了SameProcessHandler：

class SameProcessHandler : IHandleMessages<string> 
{ 
    public void Handle(string message) 
    { 
     Console.WriteLine("Same Process: {0}", message); 
    } 
}

新增公交车启动后，订阅：

Configure.With(adapter) 
    .Logging(l => l.ColoredConsole(minLevel: LogLevel.Warn)) 
    .Transport(t => t.UseMsmqAndGetInputQueueNameFromAppConfig()) 
    .Subscriptions(s => s.StoreInXmlFile(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "rebus_subscriptions.xml"))) 
    .CreateBus() 
    .Start(); 

adapter.Bus.Subscribe<string>();

最后添加的目标队列（不知道它是需要）：

<rebus inputQueue="pubsubsample.publisher.input" 
    errorQueue="pubsubsample.publisher.error" 
    workers="1" maxRetries="5"> 
    <endpoints> 
    <!-- brute force ownership - all core .NET types are owned by our publisher :) --> 
    <add messages="mscorlib" endpoint="pubsubsample.publisher.input"/> 
    </endpoints> 
</rebus>

但我得到错误“Rebus目前没有配置wi一个端点映射机制“，我应该在订阅时指定一个目的地或更改配置。我宁愿使用配置，但如何？

来源

2013-03-16 Lybecker

看来你需要指定卤面可以查找端点映射又名消息所有权在你的app.config：

.MessageOwnership(o => o.FromRebusConfigurationSection())

实际上，我认为错误消息解释了这一点，如果我没有记错，它甚至提供必要的C＃和XML，可以解决这种情况;）

来源

2013-03-16 09:41:27 mookid8000

谢谢......我是......盲目:) – Lybecker 2013-03-16 11:06:58

同样的过程订阅在Rebus中是不可能的

回答

相关问题