(Azure) BrokeredMessage.GetBody<xxx>

Question

我正在尝试建立一个‘通用’的订阅者，我可以(再)在Azure ServiceBus上使用。

但是我被困在了下面；我的代码一旦去掉了不必要的部分，看起来就像这样。

Subscribing.Client.OnMessage((recdMessage =>
{
    var msgBody = recdMessage.GetBody<myClass>();
}, options);

我希望我的msgBody是已经序列化到消息体中的类型。实际上，如果myClass类似于TelephonyEventMessage，并且接收到的消息属于该类型，那么我的msgBody将是该类型的正确实例化/恢复消重的对象。但是尽管我可以使用recdMessage。ContentType以获取该消息中类的字符串名...我只是想不出我需要在上面的myClass中放什么。我现在已经到了知识的尽头，再多的搜索看起来都不像是我的答案。我是否需要为我的消息中可能存在的每种类型添加特定版本？

Answer 1

如果您希望使用多种不同的对象类型，则可以使用此选项从订阅接收消息：

public void ReceiveMessageFromSubscription<T>(string topicPath, string subscriptionName, Action<T> action)
{
    var client = SubscriptionClient.CreateFromConnectionString(ConnectionString, topicPath, subscriptionName);

    client.OnMessage((message) =>
    {
        try
        {
            _logger.Information("Processing message");
            action(message.GetBody<T>());
            message.Complete();
        }
        catch(Exception ex)
        {
            _logger.Error(ex, "Error processing message");
            message.Abandon();
        }
    } );
}

然后传入一个知道如何处理对象的方法，如下所示。您可能有许多这样的方法，它们都调用ReceiveMessageFromSubscription。

public void ProcessObject()
{
    _serviceBusService.ReceiveMessageFromSubscription<MyObject>(mytopic, mysubscription, _myobjectService.ProcessObject);
}