Bom dia,
Estou tentando implementar o exemplo do artigo:
JavaEE 6: contexto assíncrono das Servlets para o Ajax push
public void run() {
while (true) {
final String message = messages.take();
for (final AsyncContext ctx : clients) {
public void run() {
PrintWriter writer = ctx.getResponse().getWriter();
writer.println(message);
writer.flush();
}
}
}
}
se eu não fizer ctx.complete(), não consigo pegar no meu pooling a resposta, ou seja, não consigo obter a escrita do writer.println(message), porém se eu dou ctx.complete(), eu desconecto o cliente?, estou fazendo algo de errado?