Currently the MessageHolderWithTokensConsumer fires an event when a record is consumed which invokes the NotificationDispatcher#sendMessagesToPushNetwork method. This this can be replaced with a Kafka consumer (or multuple consumers that send directly to push Servers as APNS/GCM)
with the bussiness logic of

 public void sendMessagesToPushNetwork(@Observes @Dequeue MessageHolderWithTokens msg) {