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.
[send method| https://github.com/ aerogear /aerogear -unifiedpush-server/ blob/master/ jaxrs/src/main/java/org/jboss/aerogear/unifiedpush/rest/sender/PushNotificationSenderEndpoint.java #L108 ] |
|