Filaharana JMS miaraka amin'ny mpanjifa marobe

Manana mpizara JBoss-6 miaraka amin'i HornetQ sy filaharana tokana aho:

Misy mpanjifa samihafa (amin'ny masinina samihafa) mifandray amin'ity filaharana ity, fa mpanjifa tokana ihany no mavitrika amin'ny fotoana iray. Raha hakatonako ity mpanjifa ity dia eo am-pelatanan'ny iray amin'ireo mpanjifa hafa avy hatrany ny hafatra.

Satria mandany fotoana ny fikirakirana ny hafatro dia tadiaviko ny mpanjifa marobe hiara-hamindra ny hafatr'izy ireo tsy manam-paharoa.

Tadidiko ny nitovizany teo aloha kinova JBoss izay niasa tsy nisy olana io fanamboarana io. Eto amin'ny Jboss-6 dia mandeha tsara ny rafitra fandefasan-kafatra - afa-tsy ilay olana voalaza etsy ambony. Ity fanontaniana ity dia mitovy amin'ny Azo atao ve ny mpanjifa marobe amin'ny hornetq? , saingy tsy mitovy amin'ny ahy ny tranga.

Vaovao farany 1 : Raha hakatoko (STRG + C) ny mpanjifa iray dia misy fotoana fohy (mandra-pahafantaran'ny mpizara ilay mpanjifa very) mandra-pahatongan'ny mpanjifa manaraka ny hafatra.

Vaovao farany 2 : Code Snippet

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();

Ary ny 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) {}
  }
}