@@ -180,6 +180,7 @@ public CompletableFuture<Optional<LookupResult>> getBrokerServiceUrlAsync(TopicN
180
180
if (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )) {
181
181
return loadManager .get ().findBrokerServiceUrl (Optional .of (topic ), bundle );
182
182
} else {
183
+ // TODO: Add unit tests cover it.
183
184
return findBrokerServiceUrl (bundle , options );
184
185
}
185
186
});
@@ -272,6 +273,7 @@ private CompletableFuture<Optional<URL>> internalGetWebServiceUrl(Optional<Servi
272
273
273
274
return (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )
274
275
? loadManager .get ().findBrokerServiceUrl (topic , bundle ) :
276
+ // TODO: Add unit tests cover it.
275
277
findBrokerServiceUrl (bundle , options )).thenApply (lookupResult -> {
276
278
if (lookupResult .isPresent ()) {
277
279
try {
@@ -1039,6 +1041,7 @@ public CompletableFuture<Boolean> isServiceUnitOwnedAsync(ServiceUnitId suName)
1039
1041
if (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )) {
1040
1042
return loadManager .get ().checkOwnershipAsync (Optional .empty (), suName );
1041
1043
}
1044
+ // TODO: Add unit tests cover it.
1042
1045
return CompletableFuture .completedFuture (
1043
1046
ownershipCache .isNamespaceBundleOwned ((NamespaceBundle ) suName ));
1044
1047
}
@@ -1061,6 +1064,7 @@ public boolean isServiceUnitActive(TopicName topicName) {
1061
1064
}
1062
1065
1063
1066
public CompletableFuture <Boolean > isServiceUnitActiveAsync (TopicName topicName ) {
1067
+ // TODO: Add unit tests cover it.
1064
1068
if (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )) {
1065
1069
return getBundleAsync (topicName )
1066
1070
.thenCompose (bundle -> loadManager .get ().checkOwnershipAsync (Optional .of (topicName ), bundle ));
@@ -1078,6 +1082,7 @@ private boolean isNamespaceOwned(NamespaceName fqnn) throws Exception {
1078
1082
}
1079
1083
1080
1084
private CompletableFuture <Boolean > isNamespaceOwnedAsync (NamespaceName fqnn ) {
1085
+ // TODO: Add unit tests cover it.
1081
1086
if (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )) {
1082
1087
return getFullBundleAsync (fqnn )
1083
1088
.thenCompose (bundle -> loadManager .get ().checkOwnershipAsync (Optional .empty (), bundle ));
@@ -1087,6 +1092,7 @@ private CompletableFuture<Boolean> isNamespaceOwnedAsync(NamespaceName fqnn) {
1087
1092
}
1088
1093
1089
1094
private CompletableFuture <Boolean > isTopicOwnedAsync (TopicName topic ) {
1095
+ // TODO: Add unit tests cover it.
1090
1096
if (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )) {
1091
1097
return getBundleAsync (topic )
1092
1098
.thenCompose (bundle -> loadManager .get ().checkOwnershipAsync (Optional .of (topic ), bundle ));
@@ -1095,6 +1101,7 @@ private CompletableFuture<Boolean> isTopicOwnedAsync(TopicName topic) {
1095
1101
}
1096
1102
1097
1103
public CompletableFuture <Boolean > checkTopicOwnership (TopicName topicName ) {
1104
+ // TODO: Add unit tests cover it.
1098
1105
if (ExtensibleLoadManagerImpl .isLoadManagerExtensionEnabled (config )) {
1099
1106
return getBundleAsync (topicName )
1100
1107
.thenCompose (bundle -> loadManager .get ().checkOwnershipAsync (Optional .of (topicName ), bundle ));
0 commit comments