1 Reply Latest reply on Oct 25, 2010 12:46 AM by chandras sekhar

    Issues with org.hornetq.api.core.Interceptor to intercept the Topic subscription

    chandras sekhar Newbie


          I have observed few issues with org.hornetq.api.core.Interceptor to intercept the Topic subscriptions.

      I am trying to monitor the new connections to the topic.

      If I intercept the packet for ‘SessionCreateConsumerMessage’ object, getFilterString to get the Message selector data is always null.

      And getQueueName() doesn’t return topic name properly.


      I think this is a bug.

      Sample is:



      public class SimpleInterceptor implements Interceptor



         public boolean intercept(final Packet packet, final RemotingConnection connection) throws HornetQException




            if(packet instanceof SessionCreateConsumerMessage)


                   SessionCreateConsumerMessage consumerCreateMessage = (SessionCreateConsumerMessage)packet;

                   System.out.println("-----"+conMessage.getFilterString());----This is always null.

                             System.out.println("-----"+conMessage.getQueueName());      }



            return true;




      It returns the Queue name e4f6557a-8893-4c65-b5b3-1233566559d0



      I have attached the samples.