fix managed cursor container constructor in test (#1656)

Author: gaoran10

amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AmqpProtocolTestBase.java

@@ -38,7 +38,7 @@
 import lombok.extern.log4j.Log4j2;
 import org.apache.bookkeeper.common.util.OrderedExecutor;
 import org.apache.bookkeeper.mledger.ManagedLedger;
-import org.apache.bookkeeper.mledger.impl.ManagedCursorContainer;
+import org.apache.bookkeeper.mledger.impl.ManagedCursorContainerImpl;
 import org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl;
 import org.apache.pulsar.broker.PulsarServerException;
 import org.apache.pulsar.broker.PulsarService;
@@ -191,7 +191,7 @@ private void initMockAmqpTopicManager(){
         when(subscription.addConsumer(Mockito.any())).thenReturn(CompletableFuture.completedFuture(null));
         when(persistentTopic.getSubscriptions()).thenReturn(new ConcurrentHashMap<>());
         ManagedLedger managedLedger = mock(ManagedLedgerImpl.class);
-        when(managedLedger.getCursors()).thenReturn(new ManagedCursorContainer());
+        when(managedLedger.getCursors()).thenReturn(new ManagedCursorContainerImpl());
         when(persistentTopic.getManagedLedger()).thenReturn(managedLedger);
         when(persistentTopic.getBrokerService()).thenReturn(brokerService);
         CompletableFuture<Void> deleteCpm = new CompletableFuture<>();

amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/TopicNameTest.java

@@ -23,7 +23,7 @@
 import io.streamnative.pulsar.handlers.amqp.impl.PersistentQueue;
 import java.util.concurrent.Executors;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.bookkeeper.mledger.impl.ManagedCursorContainer;
+import org.apache.bookkeeper.mledger.impl.ManagedCursorContainerImpl;
 import org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl;
 import org.apache.pulsar.broker.service.BrokerService;
 import org.apache.pulsar.broker.service.persistent.PersistentTopic;
@@ -48,7 +48,7 @@ public void exchangeTopicNameValidate() {
         Mockito.when(exchangeTopic1.getName()).thenReturn(PersistentExchange.TOPIC_PREFIX + exchangeName);
         Mockito.when(exchangeTopic1.getManagedLedger()).thenReturn(managedLedger);
         Mockito.when(exchangeTopic1.getBrokerService()).thenReturn(brokerService);
-        Mockito.when(managedLedger.getCursors()).thenReturn(new ManagedCursorContainer());
+        Mockito.when(managedLedger.getCursors()).thenReturn(new ManagedCursorContainerImpl());
         try {
             new PersistentExchange(
                     exchangeName, exchangeType, exchangeTopic1, true, false, false, null,