2016-06-27 14 views

Antwort

0

Nach den Abschnitten Create partitioned topics & Create a Topic, können Sie einen partitionierten Thema über Sie den Code unten oder mit REST API mit Resource Management erstellen.

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

Weitere Details finden Sie in den javadocs für die Klassen TopicInfo & PartitionPolicy.

Für Messaging mit JMS mit Partitionen für Themen, können Sie versuchen, den Artikel How to use Service Bus topics and subscriptions zu beziehen, um den Java-Code mit Partitionsschlüssel mit den Klassen BrokeredMessage zu schreiben, siehe Code unten.

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

Ich hoffe, es hilft.