2015-02-11 4 views

ответ

1

Попробуйте это:

public class WorkerRole : RoleEntryPoint 
{ 
    ManualResetEvent CompletedEvent = new ManualResetEvent(false); 
    SubscriptionClient Client1 = SubscriptionClient.CreateFromConnectionString("your conn str", "TestTopic1", "HighMessages"); 
    SubscriptionClient Client2 = SubscriptionClient.CreateFromConnectionString("your conn str", "TestTopic2", "HighMessages"); 

    public override void Run() 
    { 

     Client1.OnMessage((receivedMessage1) => 
     { 
      var messageFromTopic1 = receivedMessage1.GetBody<string>(); 
      //Do stuff 
     }); 

     Client2.OnMessage((receivedMessage2) => 
     { 
      var messageFromTopic2 = receivedMessage2.GetBody<string>(); 
      //Do stuff 
     }); 

     CompletedEvent.WaitOne(); 
    } 

    public override void OnStop() 
    { 
     //Also close your clients here (Client1.Close(), ...) 
     CompletedEvent.Set(); 
     base.OnStop(); 
    } 
} 

Я пропустил OnStart метод для краткости.