Warum so kompliziert? Doppelte Nachrichten könntest Du ausfiltern, indem Du eine Checksumme drauflegst, die bekommt ein extra Feld mit einem unique key und dann wird ein insert ignore gemacht, fertig.

--Rosti