Hi all, I am using Flink with Bahir's Apache ActiveMQ connector. However it's quite dated and poses many limitations, most notably the source supports only ByteMessages, does not support parallelism and has a bug that is only fixed in a snapshot version.
So I started implementing my own SourceFunction (still with parallelism of only 1) based on AMQSource. I want it to support Flink's checkpointing and make it work with ActiveMQ acks. AMQSource uses ordinary HashMap to store Messages to be acked in the broker and this is where my question arises. Is the HashMap safe to use here? Please correct me if I'm wrong, but my understanding is that /run/ method is executed in one thread and /acknowledgeIDs/ in another so there is a possibility of thread race (even if we assume all the message ids are unique). Also, do you know of any ActiveMQ specific (or JMS in general), more up-to-date connectors I could use which do not have the issues mentioned above? Thanks, Oskar -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
