Skip to content

Commit 8386ad0

Browse files
committed
log unexpected messages in httpsink
1 parent 2ad6766 commit 8386ad0

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/main/java/com/arpnetworking/tsdcore/sinks/HttpSinkActor.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -236,6 +236,14 @@ public Receive createReceive() {
236236
_waiting = false;
237237
dispatchPending();
238238
})
239+
.matchAny(message -> {
240+
LOGGER.error()
241+
.setMessage("Unexpected message")
242+
.addData("message", message)
243+
.addContext("actor", self())
244+
.addContext("sink", _sink)
245+
.log();
246+
})
239247
.build();
240248
}
241249

0 commit comments

Comments
 (0)