trol.html for more info");
> }
>
> // The usage manager could have delayed us by the time
> // we unblock the message could have expired..
> if (message.isExpired()) {
> if (LOG.isDebugEnab
ll);
return;
}
}
}
}
doMessageSend(producerExchange, message);
if (sendProducerAck) {
ProducerAck ack = new ProducerAck(producerInfo.getProducerId(),
message.getSize());
context.getConnection().dispatchAsync(ack);
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Producer-Window-Size-tp4668547.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ll);
return;
}
}
}
}
doMessageSend(producerExchange, message);
if (sendProducerAck) {
ProducerAck ack = new ProducerAck(producerInfo.getProducerId(),
message.getSize());
context.getConnection().dispatchAsync(ack);
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Producer-Window-Size-tp4668546.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ll);
return;
}
}
}
}
doMessageSend(producerExchange, message);
if (sendProducerAck) {
ProducerAck ack = new ProducerAck(producerInfo.getProducerId(),
message.getSize());
context.getConnection().dispatchAsync(ack);
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Producer-Window-Size-tp4668545.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
