We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b33e5e0 commit 17389feCopy full SHA for 17389fe
amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AmqpProtocolTestBase.java
@@ -138,7 +138,7 @@ private void mockPulsarService() throws PulsarServerException {
138
pulsarService = mock(PulsarService.class);
139
PulsarAdmin adminClient = mock(PulsarAdmin.class);
140
Namespaces namespaces = mock(Namespaces.class);
141
- ServiceConfiguration serviceConfiguration = mock(ServiceConfiguration.class);
+ ServiceConfiguration serviceConfiguration = spy(new ServiceConfiguration());
142
when(pulsarService.getAdminClient()).thenReturn(adminClient);
143
when(pulsarService.getAdminClient().namespaces()).thenReturn(namespaces);
144
when(pulsarService.getBrokerService()).then(new Answer<Object>() {
0 commit comments