Skip to content

Commit

Permalink
fix checkstyle issue
Browse files Browse the repository at this point in the history
  • Loading branch information
Technoboy- committed Jun 12, 2024
1 parent 9b49858 commit 9b2f122
Showing 1 changed file with 6 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
import io.netty.channel.EventLoopGroup;
import io.streamnative.pulsar.handlers.mqtt.MQTTCommonConfiguration;
import io.streamnative.pulsar.handlers.mqtt.utils.ConfigurationUtils;
import java.io.IOException;
import java.lang.reflect.Field;
import java.net.URI;
import java.net.URL;
Expand Down Expand Up @@ -460,14 +459,16 @@ public void reallyShutdown() {
private BookKeeperClientFactory mockBookKeeperClientFactory = new BookKeeperClientFactory() {

@Override
public CompletableFuture<BookKeeper> create(ServiceConfiguration conf, MetadataStoreExtended store, EventLoopGroup eventLoopGroup,
Optional<Class<? extends EnsemblePlacementPolicy>> ensemblePlacementPolicyClass,
Map<String, Object> ensemblePlacementPolicyProperties) {
public CompletableFuture<BookKeeper> create(ServiceConfiguration conf, MetadataStoreExtended store,
EventLoopGroup eventLoopGroup,
Optional<Class<? extends EnsemblePlacementPolicy>> ensemblePlacementPolicyClass,
Map<String, Object> ensemblePlacementPolicyProperties) {
return CompletableFuture.completedFuture(mockBookKeeper);
}

@Override
public CompletableFuture<BookKeeper> create(ServiceConfiguration conf, MetadataStoreExtended store, EventLoopGroup eventLoopGroup,
public CompletableFuture<BookKeeper> create(ServiceConfiguration conf, MetadataStoreExtended store,
EventLoopGroup eventLoopGroup,
Optional<Class<? extends EnsemblePlacementPolicy>> ensemblePlacementPolicyClass,
Map<String, Object> ensemblePlacementPolicyProperties, StatsLogger statsLogger) {
return CompletableFuture.completedFuture(mockBookKeeper);
Expand Down

0 comments on commit 9b2f122

Please sign in to comment.