Azure Service Bus BrokeredMessage已被使用？

Question

我遇到Azure Service总线的间歇性问题.偶尔,在总线上放置一条消息会导致以下异常:

TYPE:InvalidOperationException

消息:由于已经消耗了代理消息"723eab13dab34351a78bb687d0923b89",因此无法执行操作.请使用新的BrokeredMessage实例进行操作.

堆栈跟踪

at Microsoft.ServiceBus.Messaging.MessagingUtilities.ValidateAndSetConsumedMessages(IEnumerable`1 messages)
at Microsoft.ServiceBus.Messaging.MessageSender.Send(TrackingContext trackingContext, IEnumerable`1 messages, TimeSpan timeout)
at Microsoft.Practices.TransientFaultHandling.RetryPolicy.<>c__DisplayClass1.<ExecuteAction>b__0()
at Microsoft.Practices.TransientFaultHandling.RetryPolicy.ExecuteAction[TResult](Func`1 func)
at IQ.IR.Core.ServiceBus.AzureBus`1.Enqueue(T message) in c:\BuildAgent\work\cc0c51104c02a4e9\IQ.IR.Core\ServiceBus\AzureBus.cs:line 69
...Rest of stacktrace snipped as it's within my app

AzureBus的违规代码是:

public void Enqueue(T message)
{
    using (var brokeredMessage = new BrokeredMessage(message) { Label = message.GetType().FullName, TimeToLive = _timeToLive })
    {
        _retryPolicy.ExecuteAction(() => _sender.Send(brokeredMessage));
    }
}

传入T消息的地方是

[Serializable]
public class ValidationMessage
{
    public string ValidationToken { get; set;}
}

_retryPolicy是一个

RetryPolicy<ServiceBusTransientErrorDetectionStrategy>

_timeToLive是12小时的时间跨度

有任何想法吗？

Answer 1

该错误表示该消息已"已发送"但该过程中发生错误.遗憾的是,通过检查消息并没有简单的方法来了解这一点,并且消息不能再被重新使用,因为它被认为是消耗的.我们正在进行一些改进,例如允许您查询此类消息的状态并抛出MessagingException而不是InvalidOperation.最后,克隆消息的能力将有助于使这种故障更容易恢复.

Answer 2

....并继续Abhishek的回答:现在你需要为每次重试构建一个新的BrokeredMessage,所以你的重试策略范围需要更高一级.请记住,如果你输入一个流,我们将在代理消息中原样使用该流并将其直接拉到线上,因此您需要提前复制流以进行重试循环.