2016-06-27 40 views

回答

0

按照章節Create partitioned topics & Create a Topic,您可以通過添加下面的代碼或使用REST API與資源管理創建一個分區的話題。

ServiceBusContract service = ServiceBusService.create(config); 
TopicInfo topicInfo = new TopicInfo("TestTopic"); 
// Enable partitioning for topic 
topicInfo.setPartitioningPolicy(PartitioningPolicy.MESSAGE_PARTITIONING); 

更多詳細信息,請參閱Javadoc文檔類TopicInfo & PartitionPolicy

對於使用JMS與主題分區進行消息傳遞,可以嘗試參考文章How to use Service Bus topics and subscriptions以使用類BrokeredMessage編寫分區密鑰的java代碼,請參閱下面的代碼。

BrokeredMessage message = new BrokeredMessage("MyMessage"); 
message.setPartitionKey("<partitionKey>"); 
service.sendTopicMessage("TestTopic", message); 

希望它有幫助。