169170171172173174175176177178179
channel.configure(ctx); channel.start(); Transaction tx = channel.getTransaction(); tx.begin(); int i = 0; while(channel.take() != null) { i++; } tx.commit(); tx.close(); channel.stop();