@Test(invocationTimeOut = 500) public void testCorrectBackoffConfiguration() { final Backoff backoff = consumer.getConnectionHandler().backoff; ClientConfigurationData clientConfigurationData = new ClientConfigurationData(); Assert.assertEquals(backoff.getMax(), TimeUnit.NANOSECONDS.toMillis(clientConfigurationData.getMaxBackoffIntervalNanos())); Assert.assertEquals(backoff.next(), TimeUnit.NANOSECONDS.toMillis(clientConfigurationData.getInitialBackoffIntervalNanos())); }
public ConnectionHandler getConnectionHandler() { return connectionHandler; }
ConsumerImpl extends ConsumerBase<T> implements ConnectionHandler.Connection { public ConnectionHandler getConnectionHandler() { return connectionHandler; } }
ConsumerImpl extends ConsumerBase<T> implements ConnectionHandler.Connection { public ConnectionHandler getConnectionHandler() { return connectionHandler; } protected  ConsumerImpl(PulsarClientImpl client, String topic, ConsumerConfigurationData<T> conf,
            ExecutorService listenerExecutor, int partitionIndex, boolean hasParentConsumer,
            CompletableFuture<Consumer<T>> subscribeFuture, MessageId startMessageId,
            long startMessageRollbackDurationInSec, Schema<T> schema, ConsumerInterceptors<T> interceptors,
            boolean createTopicIfDoesNotExist); }
ConsumerImpl extends ConsumerBase<T> implements ConnectionHandler.Connection { public ConnectionHandler getConnectionHandler() { return connectionHandler; } protected  ConsumerImpl(PulsarClientImpl client, String topic, ConsumerConfigurationData<T> conf,
            ExecutorService listenerExecutor, int partitionIndex, boolean hasParentConsumer,
            CompletableFuture<Consumer<T>> subscribeFuture, MessageId startMessageId,
            long startMessageRollbackDurationInSec, Schema<T> schema, ConsumerInterceptors<T> interceptors,
            boolean createTopicIfDoesNotExist); ConnectionHandler getConnectionHandler(); UnAckedMessageTracker getUnAckedMessageTracker(); @Override CompletableFuture<Void> unsubscribeAsync(); @Override void negativeAcknowledge(MessageId messageId); @Override void connectionOpened(final ClientCnx cnx); @Override void connectionFailed(PulsarClientException exception); @Override CompletableFuture<Void> closeAsync(); @Override void pause(); @Override void resume(); @Override boolean isConnected(); @Override int getAvailablePermits(); @Override int numMessagesInQueue(); @Override void redeliverUnacknowledgedMessages(); @Override void redeliverUnacknowledgedMessages(Set<MessageId> messageIds); @Override void seek(MessageId messageId); @Override void seek(long timestamp); @Override CompletableFuture<Void> seekAsync(long timestamp); @Override CompletableFuture<Void> seekAsync(MessageId messageId); boolean hasMessageAvailable(); CompletableFuture<Boolean> hasMessageAvailableAsync(); @Override CompletableFuture<MessageId> getLastMessageIdAsync(); @Override ConsumerStats getStats(); @Override boolean hasReachedEndOfTopic(); @Override int hashCode(); @Override boolean equals(Object o); @VisibleForTesting ClientCnx getClientCnx(); String getTopicNameWithoutPartition(); }
ConsumerImpl extends ConsumerBase<T> implements ConnectionHandler.Connection { public ConnectionHandler getConnectionHandler() { return connectionHandler; } protected  ConsumerImpl(PulsarClientImpl client, String topic, ConsumerConfigurationData<T> conf,
            ExecutorService listenerExecutor, int partitionIndex, boolean hasParentConsumer,
            CompletableFuture<Consumer<T>> subscribeFuture, MessageId startMessageId,
            long startMessageRollbackDurationInSec, Schema<T> schema, ConsumerInterceptors<T> interceptors,
            boolean createTopicIfDoesNotExist); ConnectionHandler getConnectionHandler(); UnAckedMessageTracker getUnAckedMessageTracker(); @Override CompletableFuture<Void> unsubscribeAsync(); @Override void negativeAcknowledge(MessageId messageId); @Override void connectionOpened(final ClientCnx cnx); @Override void connectionFailed(PulsarClientException exception); @Override CompletableFuture<Void> closeAsync(); @Override void pause(); @Override void resume(); @Override boolean isConnected(); @Override int getAvailablePermits(); @Override int numMessagesInQueue(); @Override void redeliverUnacknowledgedMessages(); @Override void redeliverUnacknowledgedMessages(Set<MessageId> messageIds); @Override void seek(MessageId messageId); @Override void seek(long timestamp); @Override CompletableFuture<Void> seekAsync(long timestamp); @Override CompletableFuture<Void> seekAsync(MessageId messageId); boolean hasMessageAvailable(); CompletableFuture<Boolean> hasMessageAvailableAsync(); @Override CompletableFuture<MessageId> getLastMessageIdAsync(); @Override ConsumerStats getStats(); @Override boolean hasReachedEndOfTopic(); @Override int hashCode(); @Override boolean equals(Object o); @VisibleForTesting ClientCnx getClientCnx(); String getTopicNameWithoutPartition();  }