От: | purser | ||
Дата: | 25.06.18 10:04 | ||
Оценка: |
@Override
public void run() {
// TODO Auto-generated method stub
while (true) {
Product product= null;
try {
product= getQueue().take();
logger.info("Consuming product "+product.toString());
consume(product);
} catch (Exception e) {
// TODO Auto-generated catch block
if (null!=product)
product.setProcessingError(true);
e.printStackTrace();
} finally {
product= null;
}
}
}