Skip to content

Commit

Permalink
reduce logging when stashing WriteModels
Browse files Browse the repository at this point in the history
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
  • Loading branch information
thjaeckle committed Feb 23, 2022
1 parent b44ebcb commit eb34037
Showing 1 changed file with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,8 @@ final class ThingUpdater extends AbstractActorWithStashWithTimers {
private static final Duration BULK_RESULT_AWAITING_TIMEOUT = Duration.ofMinutes(2);
private static final Duration THING_DELETION_TIMEOUT = Duration.ofMinutes(5);

private static final DittoLogger LOGGER = DittoLoggerFactory.getLogger(ThingUpdater.class); // logger for "trace" statements
private static final DittoLogger LOGGER = DittoLoggerFactory.getLogger(ThingUpdater.class);
// logger for "trace" statements

private final DittoDiagnosticLoggingAdapter log;
private final ThingId thingId;
Expand Down Expand Up @@ -229,8 +230,9 @@ private Receive recoveredAwaitingBulkWriteResultBehavior() {
getContext().setReceiveTimeout(BULK_RESULT_AWAITING_TIMEOUT);
return ReceiveBuilder.create()
.match(AbstractWriteModel.class, writeModel -> {
log.info("Stashing received writeModel while being in 'recoveredAwaitingBulkWriteResultBehavior': {}",
writeModel);
log.debug("Stashing received writeModel while being in " +
"'recoveredAwaitingBulkWriteResultBehavior': <{}> with revision: <{}>",
writeModel.getClass().getSimpleName(), writeModel.getMetadata().getThingRevision());
stash();
})
.match(BulkWriteComplete.class, bulkWriteComplete -> {
Expand Down

0 comments on commit eb34037

Please sign in to comment.