Skip to content

Commit

Permalink
handle status runtime exception
Browse files Browse the repository at this point in the history
  • Loading branch information
Hellblazer committed Oct 25, 2023
1 parent d19ad6e commit 959d85d
Showing 1 changed file with 10 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -160,11 +160,16 @@ private void handle(Optional<Update> result, RingCommunications.Destination<Memb
return;
}
log.trace("Null gossip update with {} on: {}", destination.member().getId(), member.getId());
destination.link()
.update(ContextUpdate.newBuilder()
.setRing(destination.ring())
.setUpdate(processor.update(update))
.build());
try {
destination.link()
.update(ContextUpdate.newBuilder()
.setRing(destination.ring())
.setUpdate(processor.update(update))
.build());
} catch (StatusRuntimeException e) {
log.debug("gossiping[{}] failed with: {} with {} ring: {} on {}", context.getId(), e.getMessage(),
member.getId(), ring, link.getMember().getId(), member.getId(), e);
}
} finally {
if (timer != null) {
timer.stop();
Expand Down

0 comments on commit 959d85d

Please sign in to comment.