File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
tests/src/test/java/io/streamnative/pulsar/handlers/mqtt/base Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -404,8 +404,8 @@ protected PulsarService doStartBroker(ServiceConfiguration conf) throws Exceptio
404404 protected void setupBrokerMocks (PulsarService pulsar ) throws Exception {
405405 // Override default providers with mocked ones
406406 doReturn (mockBookKeeperClientFactory ).when (pulsar ).newBookKeeperClientFactory ();
407- doReturn (new ZKMetadataStore (mockZooKeeper )).when (pulsar ).createLocalMetadataStore (any ());
408- doReturn (new ZKMetadataStore (mockZooKeeper )).when (pulsar ).createConfigurationMetadataStore (any ());
407+ doReturn (new ZKMetadataStore (mockZooKeeper )).when (pulsar ).createLocalMetadataStore (any (), any () );
408+ doReturn (new ZKMetadataStore (mockZooKeeper )).when (pulsar ).createConfigurationMetadataStore (any (), any () );
409409
410410 Supplier <NamespaceService > namespaceServiceSupplier = () -> spy (new NamespaceService (pulsar ));
411411 doReturn (namespaceServiceSupplier ).when (pulsar ).getNamespaceServiceProvider ();
You can’t perform that action at this time.
0 commit comments