diff --git a/adsbus/incoming.c b/adsbus/incoming.c
index ae094e3..c50116f 100644
--- a/adsbus/incoming.c
+++ b/adsbus/incoming.c
@@ -106,6 +106,7 @@ static void incoming_listen(struct incoming *incoming) {
 	}
 
 	incoming->attempt = 0;
+	incoming->peer.event_handler = incoming_handler;
 	peer_epoll_add((struct peer *) incoming, EPOLLIN);
 }