Your code seems to be relying on logical events to reach you in order from the postgres server. That doesn't always happen, and if to that a client restart follows you effectivelly loose data. How do you deal with this?