A 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 {code} public void sendMessagesToPushNetwork(@Observes @Dequeue MessageHolderWithTokens msg) { {code} has to be created. |
|