Details
-
Task
-
Resolution: Done
-
Major
-
None
-
None
-
None
-
GSoC Sprint 4: Kafka
Description
If we submit all push messages in a certain topic (see AGPUSH-2159) then instead of all processing in
send method, we can try to make the same with Kafka streams over the topic. So that after the processing each message can be sent to another topic depending on its variantType.
These topics will be something similar to the JMS queues:
@Resource(mappedName = "java:/queue/AdmPushMessageQueue") private Queue admPushMessageQueue; @Resource(mappedName = "java:/queue/APNsPushMessageQueue") private Queue apnsPushMessageQueue; @Resource(mappedName = "java:/queue/GCMPushMessageQueue") private Queue gcmPushMessageQueue; @Resource(mappedName = "java:/queue/MPNSPushMessageQueue") private Queue mpnsPushMessageQueue; @Resource(mappedName = "java:/queue/SimplePushMessageQueue") private Queue simplePushMessageQueue; @Resource(mappedName = "java:/queue/WNSPushMessageQueue") private Queue wnsPushMessageQueue;
