Как получить тип сообщения очереди

На самом деле это не ответ на ваш вопрос, но я расскажу, как мы справляемся с той же ситуацией в нашем приложении.

В нашем приложении мы отправляем различные типы сообщений, как и вы, и обрабатываем эти сообщения в фоновом процессе.

Что мы делаем, так это включаем тип сообщения в само тело сообщения. Итак, наше сообщение обычно выглядит так:

        message: {
          type: 'Type Of Message',
          contents: {
            //Message contents
          }
        }

Одно ключевое отличие состоит в том, что все сообщения помещаются в одну очередь (вместо разных очередей в вашем случае). Получатель (фоновый процесс) просто опрашивает одну очередь, получает сообщение и соответственно определяет тип сообщения и обработчик вызова для этого сообщения.

Вы можете связать метаданные с каждой очередью. Поскольку вы упомянули, что используете одну очередь для каждого типа сообщения, вы можете поместить имя обработчика в метаданные для каждой очереди. Затем вы можете перечислить все очереди и получить метаданные для каждой очереди, которые сообщают вам, какой тип обработчика вы должны использовать. Вот быстрое консольное приложение, которое демонстрирует то, что, как я думаю, вы просите:

using System;
using System.Collections.Generic;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Queue; 

namespace QueueDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            //get a ref to our account.
            CloudStorageAccount storageAccount = CloudStorageAccount.Parse("UseDevelopmentStorage=true;");
            CloudQueueClient cloudQueueClient = storageAccount.CreateCloudQueueClient();

            //create our queues and add metadata showing what type of class each queue contains. 
            CloudQueue queue1 = cloudQueueClient.GetQueueReference("queue1"); 
            queue1.Metadata.Add("classtype", "classtype1");
            queue1.CreateIfNotExists();

            CloudQueue queue2 = cloudQueueClient.GetQueueReference("queue2");
            queue2.Metadata.Add("classtype", "classtype2");
            queue2.CreateIfNotExists();

            //enumerate our queues in a storage account and look at their metadata...
            QueueContinuationToken token = null;
            List<CloudQueue> cloudQueueList = new List<CloudQueue>();
            List<string> queueNames = new List<string>();

            do
            {
                QueueResultSegment segment = cloudQueueClient.ListQueuesSegmented(token);
                token = segment.ContinuationToken;
                cloudQueueList.AddRange(segment.Results);
            }
            while (token != null);

            try
            {
                foreach (CloudQueue cloudQ in cloudQueueList)
                {
                    //call this, or else your metadata won't be included for the queue. 
                    cloudQ.FetchAttributes(); 
                    Console.WriteLine("Cloud Queue name = {0}, class type = {1}", cloudQ.Name, cloudQ.Metadata["classtype"]);
                    queueNames.Add(cloudQ.Name);
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine("Exception thrown listing queues: " + ex.Message);
                throw;
            }

            //clean up after ourselves and delete queues. 
            foreach (string oneQueueName in queueNames)
            {
                CloudQueue cloudQueue = cloudQueueClient.GetQueueReference(oneQueueName);
                cloudQueue.DeleteIfExists();
            }
            Console.ReadKey(); 
        }
    }
}

Однако может быть проще создать подкласс QueueMessage, затем удалить каждое сообщение из очереди и определить, какой подкласс вы в данный момент просматриваете, а затем передать его соответствующему обработчику.