}
long pid = msg.getProducerID();
ProducerUID puid = new ProducerUID(pid);
Producer p = Producer.getProducer(puid);
if (p != null)
p.addMsg(); // increment counter
// see if we need to resume flow
if (msg.getConsumerFlow()) {
pausedProducer = p;
if (pausedProducer == null) {
logger.log(Logger.INFO,"Internal Error: Unknown ProducerUID " + puid);