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.