- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
在以前的 (<=0.84.0) 版本的 Rebus 中可以在 TransactionScope 中发送消息,并且只有在范围完成时才发送
using (var scope = new TransactionScope())
{
var ctx = new AmbientTransactionContext();
sender.Send(recipient.InputQueue, msg, ctx);
scope.Complete();
}
是否有可能在 Rebus2 中实现相同的行为
最佳答案
正如您正确发现的那样,Rebus 版本 >= 0.90.0 不会自动加入环境事务。
(更新:自 2016 年 9 月 9 日起,可以实现所需的行为 - 有关详细信息,请参阅此答案的末尾)
然而,这并不意味着 Rebus 无法加入事务 - 它只是使用自己的环境事务机制(不依赖于 System.Transactions
,并且当 Rebus 移植到 . NET 核心)。
您可以使用 Rebus 的 DefaultTransactionContext
并通过此 AmbientRebusTransactionContext
“使其成为环境”:
/// <summary>
/// Rebus ambient transaction scope helper
/// </summary>
public class AmbientRebusTransactionContext : IDisposable
{
readonly DefaultTransactionContext _transactionContext = new DefaultTransactionContext();
public AmbientRebusTransactionContext()
{
if (AmbientTransactionContext.Current != null)
{
throw new InvalidOperationException("Cannot start a Rebus transaction because one was already active!");
}
AmbientTransactionContext.Current = _transactionContext;
}
public Task Complete()
{
return _transactionContext.Complete();
}
public void Dispose()
{
AmbientTransactionContext.Current = null;
}
}
然后你可以像这样使用它:
using(var tx = new AmbientRebusTransactionContext())
{
await bus.Send(new Message());
await tx.Complete();
}
或者,如果您在 Web 应用程序中使用它,我建议您将它包装在 OWIN 中间件中,如下所示:
app.Use(async (context, next) =>
{
using (var transactionContext = new AmbientRebusTransactionContext())
{
await next();
await transactionContext.Complete();
}
});
更新:从 Rebus 0.99.16 开始,支持以下内容(通过 Rebus.TransactionScope
包):
using (var scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
scope.EnlistRebus(); //< enlist Rebus in ambient .NET tx
await _bus.SendLocal("hallå i stuen!1");
scope.Complete();
}
关于servicebus - Rebus 在事务范围内发送,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33943265/
我有一个 Web 应用程序,它使用 Rebus 和 Azure 服务总线队列作为传输。 它配置了 Simple Injector 容器。 在应用程序处理期间,我想阻止 rebus 接受新消息并检查目前
我想通过上下文 A 引发的事件集成两个限界上下文并使用来自上下文 B 的事件。我怎么想避免编译时间依赖性,所以上下文 B 不必包含上下文 A 的 dll/库。(至少我不希望每次新事件类型获取时都需要更
我有一个运行良好的输入队列。有时一条消息会进入错误队列。现在我希望能够检查这些消息,如果我知道这条特定消息会通过,可能会再次将它们转发到输入队列。 如何开始检查错误队列?有什么最佳实践吗?我不能只执行
我正在使用 top-shelf 和 rebus 编写一个“多 worker ”应用程序。 我的想法是使用 MyWorker1Namespace - MyWorker1Namespace.Message
是否可以以编程方式或通过 UI 将错误消息从错误队列移动到其原始队列? 更新 关于下面代码的问题: 1 以下代码是否适用于发布者或订阅者或两者? 下面的代码: Configure.With(acti
使用 时出错阿祖尔服务巴士 , 如果我使用 MSMQ 排队然后没有错误,所以请建议代码有什么问题或任何缺少的配置? 注:下面的 Rebus 初始化代码是在 web 应用程序下运行的:
假设我有一个 saga 数据,其中包含具有以下值之一的状态: JustWaiting, AwatingPrepareDrink, WaitingForPayment 我也有不同的消息要处理,但只想在状
我在以下一般情况下使用 Rebus,对于 WCF 或 WebAPI 来说很自然。有两个微服务,在它们的程序集中具有相同的 DTO 集,用于交换集成事件。 DTO 类类似,但它们驻留在具有不同 .Net
我正在研究 Rebus 并将其与 Azure 服务总线一起使用。将它与 regalure Queues 一起使用很容易,但是当我想改用 Topic 时,我无法让它工作。 这里有没有完成设置并将其与主题
我有一个 Rebus Servicebus 控制台应用程序在我的测试环境中作为 Windows 服务运行。服务总线是这样创建的: Bus = Configure.With(adapter)
当我发送由 AutoMapper.Mapper.DynamicMap() 创建的实例时,我遇到了一个错误,其中 Rebus 似乎想要确定 DynamicMap 返回的代理类型的端点。此实例将包含 T
我有一个 Rebus 总线设置,只有一个工作人员,最大并行度为 1,可以“顺序”处理消息。如果处理程序失败,或出于特定业务原因,我希望总线实例立即停止处理消息。 我尝试使用 Rebus.Event 包
在 Rebus 中,是否有一种方法可以按顺序处理消息来控制消息的处理?即第一个处理,然后删除然后第二个处理等 最佳答案 是的 - 也不是 :) 首先,我只想说,你最好尽你所能设计你的系统,使其能够容忍
我最近一直在与 Rebus 合作,到目前为止,它一直很棒。 一个值得关注的领域是,当我们有数千或数十万条消息正在处理并且依赖服务(如数据库或 RabbitMQ)出现故障时。 在这种情况下,我们不需要错
尝试延迟在单向客户端上发送消息时,以下异常背后的基本原理是什么: System.InvalidOperationException “不能将自己用作超时管理器,因为我们是单向客户端” 最佳答案 单向客
有没有办法指定为特定异常重试消息的等待时间? 例如。如果对象处于 SomethingInProgress 状态,则抛出 SomethignInProgressException 并且我希望消息在 40
我正在浏览示例并阅读文档,但我仍然不确定如何为我的场景配置 rebus(或者使用总线很合适)。 我有一个任务生产者要做,比如说 ImportOrder 和CalculateOrderPrice 我想转
我想知道 Rebus Service Bus 是否可以处理以下用例: 为将来的日期排队消息 如果有一条消息 ProcessInvoice 的上下文类似于 Customer Id: 1000,我们是否可
我正在尝试使用 CQRS/ES 架构设置 WebApp。 我已经定义了一个模型实体,带有创建和编辑命令/事件。 命令由相关的 Saga 处理。 事件被保存到一个 mongo 事件存储,这是立即一致的存
当配置为单向客户端(RabbitMq 和 Azure)时,我在使用 rebus 发送消息(而不是发布)时遇到错误,因为队列必须存在。 如果在发送消息之前不存在队列,OneWayClient 有没有办法
我是一名优秀的程序员,十分优秀!