ila do @MS com vários consumidores
Eu tenho um servidor JBoss-6 com HornetQ e uma única fila:
<queue name="my.queue">
<entry name="/queue/test"/>
</queue>
Há consumidores diferentes (em máquinas diferentes) conectados a essa fila, mas apenas umsolteir consumidor está ativo por vez. Se eu desligar esse consumidor, as mensagens serão processadas imediatamente por um dos outros consumidore
Como minhas mensagens têm um processamento demorado, desejo que vários consumidores processem suas mensagens exclusivas simultaneament
Lembro-me de um similar nas versões anteriores do JBoss, onde essa configuração funcionava sem problemas. Aqui no Jboss-6, o sistema de mensagens está funcionando bem - exceto o problema descrito acima. Esta pergunta é semelhante a São possíveis vários clientes clientes no hornet, mas o cenário não é semelhante ao me
Update 1: Se eu fechar (STRG + C) um consumidor, o tempo limite será curto (até que o servidor reconheça o consumidor perdido) até que o próximo consumidor receba a mensage
Update 2: Fragmento de códig
VoidListener ml = new VoidListener();
QueueConnectionFactory qcf = (QueueConnectionFactory)
ctx.lookup("ConnectionFactory");
QueueConnection conn = qcf.createQueueConnection();
Queue queue = (Queue) ctx.lookup(queueName);
QueueSession session = conn.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);
QueueReceiver recv = session.createReceiver(queue,"");
recv.setMessageListener(ml);
conn.start();
E o MessageListerner:
public class OlVoidListener implements MessageListener
{
public void onMessage(Message msg)
{
counter++;
logger.debug("Message ("+counter+") received");
try {Thread.sleep(15*1000);} catch (InterruptedException e) {}
}
}