Instead of sending a push message by submitting a task to {code} notificationRouter.submit(pushApplication, message); {code} Create a Kafka producer that will send the info to a new topic.
See [send method|https://github.com/aerogear/aerogear-unifiedpush-server/blob/master/jaxrs/src/main/java/org/jboss/aerogear/unifiedpush/rest/sender/PushNotificationSenderEndpoint.java#L108] |
|