gistfile1.txt

   private class MyOutgoingInterceptor2 implements Interceptor
   {
      public boolean intercept(final Packet packet, final RemotingConnection connection) throws HornetQException
      {
         if (packet.getType() == PacketImpl.SESS_RECEIVE_MSG)
         {
            SessionReceiveMessage msg = (SessionReceiveMessage) packet;
            if (msg.getMessage().containsProperty(ClientConsumerImpl.FORCED_DELIVERY_MESSAGE))
            {
               return true;
            }
            else
            {
               return false;
            }
         }

         return true;
      }

   }