Adds robust pub/sub support by adding a producer/consumer filter.