Message not removed from ActiveMQ queue

[ankit.vernekar]

Hi folks,

           I have a servicemix file poller running.It has a JMS file component that puts a xml file on the activemq queue.I implemented a listener to receive this xml from the queue.The listener retrieves the xml successfully but the message does not get deleted from the queue once the xml is read.The implementation for listener is as follows

public void start()

     {

          System.out.println("Inside start.");

          try

          {

          conFac=new ActiveMQConnectionFactory();

          con=conFac.createConnection();          

          session=con.createSession(false, Session.AUTO_ACKNOWLEDGE);

          con.start();

          Destination destination = new ActiveMQQueue("PaymentsXML");          

          consumer=session.createConsumer(destination);

          consumer.setMessageListener(this);          

          System.out.println("start ended");          

          }

          catch(Exception e)

          {

               System.out.println(e.getMessage());

          }

     }

public void onMessage(Message msg)

     {

          System.out.println("On Message on");

          try {

               TextMessage tmsg=(TextMessage)msg;

               String output=tmsg.getText();

               Transformer t=new Transformer();

               String result=t.XMLtoXML(output);

               System.out.println("---Output---");

               System.out.println(result);

               System.out.println("---xxxxxx---");

               PrintWriter pr=new PrintWriter("C:
Documents and Settings
PMC
Desktop
output.xml");

               pr.write(result);

               pr.close();               

          } catch (Exception e) {

               System.out.println(e.getMessage());

          }

}

onMessage methods reads the message from the queue.By default the message should get deleted from the queue once read.

Am I going wrong somewhere? if so please help

Versions used

ActiveMQ 5.2.0

JDK 1.6

Windows XP

Regards,

Ankit Vernekar

[stlewis]

Can you post the broker log so we can see if there's any indication of a problem in there?  The code looks okay, have you tried maybe seeing if the activemq example consumer behaves the same way?  It should be possible to connect the example consumer to your queue without too much hassle.

[ankit.vernekar]

Could not find any log file for activemq.There is a log file for the servicemix though.Any suggesstion what i can do?

[stlewis]

Activemq writes it's log file in the "data" directory, usually created in the present working directory from where the broker is started.  You may want to edit the log4j.properties file for the broker as well and turn up the logging to DEBUG to get more information, I'm sure the log will help figure out what's going on here.