2

我在 Rebus 中有这个简单的 Saga：

public void MySaga : Saga<MySagaData>
    IAmInitiatedBy<Event1>
    IHandleMessages<Event2>
{
        private IBus bus;
        private ILog logger;

        public MySaga(IBus bus, ILog logger)
        {
            if (bus == null) throw new ArgumentNullException("bus");
            if (logger == null) throw new ArgumentNullException("logger");

            this.bus = bus;
            this.logger = logger;
        }

        protected override void CorrelateMessages(ICorrelationConfig<MySagaData> config)
        {

            config.Correlate<Event>(m => m.MyObjectId.Id, s => s.Id);
            config.Correlate<Event>(m => m.MyObjectId.Id, s => s.Id);
        }

    public Task Handle(Event1 message)
    {
        return Task.Run(() =>
        {
            this.Data.Id = message.MyObjectId.Id;
            this.Data.State = MyEnumSagaData.Step1;
            var cmd = new ResponseCommandToEvent1(message.MyObjectId);
            bus.Send(cmd);
        });
    }

    public Task Handle(Event2 message)
    {
        return Task.Run(() =>
        {
            this.Data.State = MyEnumSagaData.Step2;
            var cmd = new ResponseCommandToEvent2(message.MyObjectId);
            bus.Send(cmd);
        });
    }
}

并且感谢善良的 mookid8000，我可以使用 FakeBus 和 SagaFixture 测试传奇：

[TestInitialize]
public void TestInitialize()
{
    var log = new Mock<ILog>();
    bus = new FakeBus();
    fixture = SagaFixture.For<MySaga>(() => new MySaga(bus, log.Object));
    idTest = new MyObjectId(Guid.Parse("1B2E7286-97E5-4978-B5B0-D288D71AD670"));
}

[TestMethod]
public void TestIAmInitiatedBy()
{
    evt = new Event1(idTest);
    fixture.Deliver(evt);
    var testableFixture = fixture.Data.OfType<MySagaData>().First();
    Assert.AreEqual(MyEnumSagaData.Step1, testableFixture.State);
    // ... more asserts
}

[TestMethod]
public void TestIHandleMessages()
{
    evt = new Event2(idTest);
    fixture.Deliver(evt);
    var testableFixture = fixture.Data.OfType<MySagaData>().First();
    Assert.AreEqual(MyEnumSagaData.Step2, testableFixture.State);
    // ... more asserts
}

[TestCleanup]
public void TestCleanup()
{
    fixture.Dispose();
    bus.Dispose();
}

检查的第一个测试方法IAmInitiatedBy正确执行并且没有抛出错误，而第二个测试失败。它看起来像一个相关问题，因为fixture.Data不包含任何元素，并且fixture.LogEvents包含作为最后一个元素的此错误：找不到消息 Event2/b91d161b-eb1b-419d-9576-2c13cd9d9c51 的现有传奇数据。

这个 GUID 是什么？与我在单元测试中定义的完全不同吗？有任何想法吗？我要测试的内容是否合法（因为我使用的是内存总线）？

4

1 回答 1

2

这条线很糟糕：this.Data.Id = message.MyObjectId.Id. 如果您Data.Id在覆盖之前检查了 的值，您会注意到该属性已经有一个值。

您无需分配 saga ID - Rebus 会这样做。而且您应该不理会该属性:)

关于您的错误 - 当 Rebus 想要记录有关特定消息的信息时，它会记录类型和消息 ID的短名称，即自动分配的rbs2-msg-id标头的值。换句话说：m.MyObjectId.Id你看到的不是属性的值，而是消息 ID。

由于每次测试运行都会重新初始化 saga 夹具，并且您只Event2向它传递一个（不允许启动新实例），因此不会命中 saga。

于 2016-03-15T22:57:31.467 回答