diff --git a/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AmqpProtocolTestBase.java b/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AmqpProtocolTestBase.java index 401fe3d8..06eea126 100644 --- a/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AmqpProtocolTestBase.java +++ b/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AmqpProtocolTestBase.java @@ -138,7 +138,7 @@ private void mockPulsarService() throws PulsarServerException { pulsarService = mock(PulsarService.class); PulsarAdmin adminClient = mock(PulsarAdmin.class); Namespaces namespaces = mock(Namespaces.class); - ServiceConfiguration serviceConfiguration = mock(ServiceConfiguration.class); + ServiceConfiguration serviceConfiguration = spy(new ServiceConfiguration()); when(pulsarService.getAdminClient()).thenReturn(adminClient); when(pulsarService.getAdminClient().namespaces()).thenReturn(namespaces); when(pulsarService.getBrokerService()).then(new Answer() {