rename function in sample code for Service Bus Starter (#36)
This commit is contained in:
Родитель
7f9216658a
Коммит
692f78b3cb
|
@ -37,7 +37,7 @@ public class ServiceBusSampleApplication implements CommandLineRunner {
|
||||||
receiveQueueMessage();
|
receiveQueueMessage();
|
||||||
|
|
||||||
sendTopicMessage();
|
sendTopicMessage();
|
||||||
receiveTopicMessage();
|
receiveSubscriptionMessage();
|
||||||
}
|
}
|
||||||
|
|
||||||
// NOTE: Please be noted that below are the minimum code for demonstrating the usage of autowired clients.
|
// NOTE: Please be noted that below are the minimum code for demonstrating the usage of autowired clients.
|
||||||
|
@ -65,7 +65,7 @@ public class ServiceBusSampleApplication implements CommandLineRunner {
|
||||||
topicClient.close();
|
topicClient.close();
|
||||||
}
|
}
|
||||||
|
|
||||||
private void receiveTopicMessage() throws ServiceBusException, InterruptedException {
|
private void receiveSubscriptionMessage() throws ServiceBusException, InterruptedException {
|
||||||
subscriptionClient.registerMessageHandler(new MessageHandler(), new MessageHandlerOptions());
|
subscriptionClient.registerMessageHandler(new MessageHandler(), new MessageHandlerOptions());
|
||||||
|
|
||||||
Thread.sleep(5 * 1000);
|
Thread.sleep(5 * 1000);
|
||||||
|
|
Загрузка…
Ссылка в новой задаче