Uploaded image for project: 'AeroGear'
  1. AeroGear
  2. AEROGEAR-6648

Use Kafka Streams for processing of push messages

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Done
    • Icon: Major Major
    • None
    • None
    • None

      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;

            Unassigned Unassigned
            polina.n.koleva Polina Koleva (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: