Skip to content

Commit

Permalink
eclipse-ditto#985 add missing javadoc, remove debug log statements
Browse files Browse the repository at this point in the history
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch.io>
  • Loading branch information
dguggemos committed Mar 30, 2021
1 parent 60095fa commit cc4d81d
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ abstract ActorRef startConsumerActor(boolean dryRun, Source source, ActorRef inb
MqttSpecificConfig specificConfig);

/**
* TODO
* @return the factory that creates new HiveMqttClients
*/
abstract HiveMqttClientFactory<Q, ?> getClientFactory();

Expand Down Expand Up @@ -460,7 +460,6 @@ protected CompletionStage<Status.Status> startPublisherActor() {

@Override
protected void doDisconnectClient(final Connection connection, @Nullable final ActorRef origin) {
logger.info("doDisconnectClient");
if (client != null) {
final CompletionStage<ClientDisconnected> disconnectFuture = getClient().disconnect()
.handle((aVoid, throwable) -> {
Expand All @@ -484,7 +483,6 @@ private static ClientDisconnected getClientDisconnected(@Nullable final ActorRef

@Override
protected void cleanupResourcesForConnection() {
logger.info("doDisconnectClient");
stopCommandConsumers(subscriptionHandler);
stopChildActor(publisherActor);
safelyDisconnectClient(client, "consumer");
Expand Down

0 comments on commit cc4d81d

Please sign in to comment.