13 Replies Latest reply on Sep 11, 2014 2:33 PM by jbertram

    Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE

    kts92tln8

      I'm trying to access server attributes Using Management Via Core API (http://docs.jboss.org/hornetq/2.4.0.Final/docs/user-manual/html/management.html#d0e6934),

      however I dont see following in the hornetq-configuration.xml, may be its default if not provided --

       

        <management-address>jms.queue.hornetq.management</management-address>

       

      I added a user "hqadmin" with "admin, guest" role in hornetq-users.xml as described below.

      and added security-setting

       

           <security-setting match="jms.queue.hornetq.management">

              <permission type="manage" roles="admin"/>

           </security-setting>

       

      when I try to access "jms.queue.hornetq.management" using user hqadmin and passwd I get following

       

      Exception in thread "main" HornetQSecurityException[errorType=SECURITY_EXCEPTION message=HQ119032: User: hqadmin doesnt have permission=CREATE_NON_DURABLE_QUEUE on address {2}]

              at org.hornetq.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:390)

              at org.hornetq.core.client.impl.ClientSessionImpl.internalCreateQueue(ClientSessionImpl.java:2056)

              at org.hornetq.core.client.impl.ClientSessionImpl.createTemporaryQueue(ClientSessionImpl.java:370)

              at org.hornetq.core.client.impl.DelegatingSession.createTemporaryQueue(DelegatingSession.java:327)

              at org.hornetq.api.core.client.ClientRequestor.<init>(ClientRequestor.java:57)

              at my.hornetq.client.CoreMessagingProxy.<init>(CoreMessagingProxy.java:23)

              at my.hornetq.client.Stats$1.<init>(Stats.java:65)

       

      hornetq server is hosted remotely then client (not localhost)

       

      following is code

       

      public CoreMessagingProxy(final ClientSession session,  final String resourceName) throws Exception

      {

          this.session = session;

          this.resourceName = resourceName;

          requestor = new ClientRequestor(session,

                  HornetQDefaultConfiguration.getDefaultManagementAddress());

      }

       

      public ClientRequestor(final ClientSession session, final SimpleString requestAddress) throws Exception

      {

        queueSession = session;

       

        requestProducer = queueSession.createProducer(requestAddress);

        replyQueue = new SimpleString(requestAddress + "." + UUID.randomUUID().toString());

        queueSession.createTemporaryQueue(replyQueue, replyQueue);  // <-- this fails

        replyConsumer = queueSession.createConsumer(replyQueue);

      }

       

       

      $cat hornetq-users.xml

      <configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

                  xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd">

         <!-- the default user.  this is used where username is null-->

         <defaultuser name="guest" password="guest">

            <role name="guest"/>

        </defaultuser>

        <user name="hqadmin" password="myfakepasswd">

            <role name="admin, guest"/>

        </user>

      </configuration>

       

       

      $cat hornetq-configuration.xml

      <configuration xmlns="urn:hornetq"

                     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

                     xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd">

       

         <paging-directory>${data.dir:../data}/paging</paging-directory>

       

         <bindings-directory>${data.dir:../data}/bindings</bindings-directory>

       

         <journal-directory>${data.dir:../data}/journal</journal-directory>

       

         <journal-min-files>10</journal-min-files>

       

         <large-messages-directory>${data.dir:../data}/large-messages</large-messages-directory>

       

         <connectors>

          <!-- here I pass -Dhornetq.remoting.netty.host=myhost.com in run.sh -->

            <connector name="netty">

               <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>

               <param key="host"  value="${hornetq.remoting.netty.host:localhost}"/>

               <param key="port"  value="${hornetq.remoting.netty.port:5445}"/>

            </connector>

       

            <connector name="netty-throughput">

               <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>

               <param key="host"  value="${hornetq.remoting.netty.host:localhost}"/>

               <param key="port"  value="${hornetq.remoting.netty.batch.port:5455}"/>

               <param key="batch-delay" value="50"/>

            </connector>

         </connectors>

       

         <acceptors>

            <acceptor name="netty">

               <factory-class>org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory</factory-class>

               <param key="host"  value="${hornetq.remoting.netty.host:localhost}"/>

               <param key="port"  value="${hornetq.remoting.netty.port:5445}"/>

            </acceptor>

       

            <acceptor name="netty-throughput">

               <factory-class>org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory</factory-class>

               <param key="host"  value="${hornetq.remoting.netty.host:localhost}"/>

               <param key="port"  value="${hornetq.remoting.netty.batch.port:5455}"/>

               <param key="batch-delay" value="50"/>

               <param key="direct-deliver" value="false"/>

            </acceptor>

         </acceptors>

       

         <security-settings>

            <security-setting match="#">

               <permission type="createNonDurableQueue" roles="admin, guest"/>

               <permission type="deleteNonDurableQueue" roles="admin, guest"/>

               <permission type="consume" roles="admin, guest"/>

               <permission type="send" roles="admin, guest"/>

           </security-setting>

           <security-setting match="jms.queue.hornetq.management">

              <permission type="manage" roles="admin"/>

           </security-setting>

        </security-settings>

       

         <address-settings>

            <!--default for catch all-->

            <address-setting match="#">

               <dead-letter-address>jms.queue.DLQ</dead-letter-address>

               <expiry-address>jms.queue.ExpiryQueue</expiry-address>

               <redelivery-delay>0</redelivery-delay>

               <max-size-bytes>10485760</max-size-bytes>

               <message-counter-history-day-limit>10</message-counter-history-day-limit>

               <address-full-policy>BLOCK</address-full-policy>

            </address-setting>

         </address-settings>

       

      </configuration>

       

      Thanks

        • 1. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
          jbertram

          I believe your problem is that you simply haven't granted the proper permissions on the appropriate address(es) (just as the error message indicates).  My guess here is that you've assumed the "createNonDurableQueue" permission from the general "#" security-setting will apply to the more specific "jms.queue.hornetq.management" security-setting, but that's not how security-setting logic works.  As the documentation states:

          Note that settings are not inherited from the former block. All the settings will be taken from the more specific matching block, so for the address 'globalqueues.europe.orders.plastics' the only permissions that exist are send and consume for the role europe-users. The permissions createDurableQueue, deleteDurableQueue, createNonDurableQueue, deleteNonDurableQueue are not inherited from the other security-setting block.

           

          By not inheriting permissions, it allows you to effectively deny permissions in more specific security-setting blocks by simply not specifying them. Otherwise it would not be possible to deny permissions in sub-groups of addresses.

          • 2. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
            kts92tln8

            as always, thanks for the reply.

             

            on the server side log I saw following

             

            10:58:51,894 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822

             

            so i added following in the hornetq-configuration.xml

             

               <security-settings>

                  <security-setting match="#">

                     <permission type="createNonDurableQueue" roles="guest"/>

                     <permission type="deleteNonDurableQueue" roles="guest"/>

                     <permission type="consume" roles="guest"/>

                     <permission type="send" roles="guest"/>

                 </security-setting>

                 <security-setting match="jms.queue.hornetq.management.#">

                    <permission type="manage" roles="admin"/>

                    <permission type="createNonDurableQueue" roles="admin"/>

                    <permission type="deleteNonDurableQueue" roles="admin"/>

                    <permission type="consume" roles="admin"/>

                    <permission type="send" roles="admin"/>

                 </security-setting>

              </security-settings>

             

            and also

            hornetq-users.xml

            =================

            <configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

                        xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd">

               <!-- the default user.  this is used where username is null-->

               <defaultuser name="guest" password="guest">

                  <role name="guest"/>

              </defaultuser>

              <user name="hqadmin" password="gy1C6tbGETP">

                  <role name="admin, guest"/>

              </user>

            </configuration>

             

             

            I still get following exceptions

             

             

            on client side

            ==============

            Exception in thread "main" HornetQSecurityException[errorType=SECURITY_EXCEPTION message=HQ119032: User: hqadmin doesnt have permission=CREATE_NON_DURABLE_QUEUE on address {2}]

                    at org.hornetq.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:390)

                    at org.hornetq.core.client.impl.ClientSessionImpl.internalCreateQueue(ClientSessionImpl.java:2056)

                    at org.hornetq.core.client.impl.ClientSessionImpl.createTemporaryQueue(ClientSessionImpl.java:370)

                    at org.hornetq.core.client.impl.DelegatingSession.createTemporaryQueue(DelegatingSession.java:327)

                    at org.hornetq.api.core.client.ClientRequestor.<init>(ClientRequestor.java:57)

             

             

            in server logs

            ==============

             

            10:58:51,894 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822

            10:58:51,895 TRACE [org.hornetq.core.server] Sending Notification = Notification[uid=null, type=SECURITY_PERMISSION_VIOLATION, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_Address=jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]], notificationEnabled=true messagingServerControl=org.hornetq.core.management.impl.HornetQServerControlImpl@1e4f430f

            10:58:51,897 TRACE [org.hornetq.core.server] Receiving notification : Notification[uid=null, type=SECURITY_PERMISSION_VIOLATION, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_Address=jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]] on server HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8

            10:58:51,908 DEBUG [org.hornetq.core.server] Couldn't find any bindings for address=hornetq.notifications on message=ServerMessage[messageID=128,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410278331905, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]]@67220521

            10:58:51,910 TRACE [org.hornetq.core.server] Message after routed=ServerMessage[messageID=128,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410278331905, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]]@67220521

            10:58:51,912 DEBUG [org.hornetq.core.server] Message ServerMessage[messageID=128,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410278331905, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management.5df96c38-9b63-4d25-9476-365fd99fc822, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]]@67220521 is not going anywhere as it didn't have a binding on address:hornetq.notifications

            10:58:51,943 DEBUG [org.hornetq.core.server] Sending exception to client: HornetQSecurityException[errorType=SECURITY_EXCEPTION message=HQ119032: User: hqadmin doesnt have permission=CREATE_NON_DURABLE_QUEUE on address {2}]

                    at org.hornetq.core.security.impl.SecurityStoreImpl.check(SecurityStoreImpl.java:192) [hornetq-server.jar:]

                    at org.hornetq.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:436) [hornetq-server.jar:]

                    at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:239) [hornetq-server.jar:]

                    at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:633) [hornetq-core-client.jar:]

                    at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:547) [hornetq-core-client.jar:]

                    at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:523) [hornetq-core-client.jar:]

                    at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:635) [hornetq-server.jar:]

                    at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.channelRead(HornetQChannelHandler.java:74) [hornetq-core-client.jar:]

                    at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                    at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:153) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:122) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:485) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:452) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:346) [netty.jar:4.0.13.Final]

                    at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty.jar:4.0.13.Final]

                    at java.lang.Thread.run(Thread.java:744) [rt.jar:1.7.0_51]

            • 3. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
              jbertram

              Couple of questions:

              • What version of HornetQ are you using?
              • Is the error message really printing "{2}" instead of the actual name of the address?
              • Can you provide me with a reproducible test case?  I've tried to reproduce your problem here, but it works as expected in my tests.
              • 4. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                kts92tln8

                following is client code

                 

                    public class HornetQServerControlUsingCoreTest

                    {

                        public static void main(String[] args) throws Exception

                        {

                            String host = "dev2.example.com";

                            int port = 5445;

                            String user = "hqadmin";

                            String password = "gUBwRIHnh4ETD4q";

                 

                            String transportConfigName = "mytest.hornetq.client.transportConfig";

                            String connectorFactoryClassName = "org.hornetq.core.remoting.impl.netty.NettyConnectorFactory";

                 

                            Map<String, Object> params = new HashMap<String, Object>();

                            params.put(TransportConstants.HOST_PROP_NAME, host);

                            params.put(TransportConstants.PORT_PROP_NAME, port);

                 

                            TransportConfiguration transportConfig = new TransportConfiguration(

                                    connectorFactoryClassName, params, transportConfigName);

                 

                            ServerLocator locator = null;

                            ClientSession session = null;

                            try

                            {

                 

                                locator = HornetQClient.createServerLocatorWithoutHA(transportConfig);

                                ClientSessionFactory sessionFactory = locator.createSessionFactory();

                 

                                boolean xa = false, autoCommitSends = true, autoCommitAcks = true;

                                boolean preAcknowledge = HornetQClient.DEFAULT_PRE_ACKNOWLEDGE;

                                int ackBatchSize = HornetQClient.DEFAULT_ACK_BATCH_SIZE;

                 

                                session = sessionFactory.createSession(user, password, xa, autoCommitSends,

                                        autoCommitAcks, preAcknowledge, ackBatchSize);

                               

                                String resourceName = ResourceNames.CORE_SERVER;

                                String attributeName = "queueNames";

                                Object qnames = retrieveAttributeValue(session, resourceName, attributeName);

                               

                                System.out.println(qnames);

                            }

                            finally

                            {

                                if (locator != null)

                                    locator.close();

                                if (session != null)

                                    session.close();

                            }

                        }

                 

                        static Object retrieveAttributeValue(ClientSession session, String resourceName,

                                String attributeName) throws Exception

                        {

                            ClientRequestor requestor = new ClientRequestor(session,

                                    HornetQDefaultConfiguration.getDefaultManagementAddress());

                            ClientMessage m = session.createMessage(false);

                            ManagementHelper.putAttribute(m, resourceName, attributeName);

                            ClientMessage reply;

                            try

                            {

                                reply = requestor.request(m);

                                Object result = ManagementHelper.getResult(reply);

                                return result;

                            }

                            catch (Exception e)

                            {

                                throw new IllegalStateException(e);

                            }

                            finally

                            {

                                requestor.close();

                            }

                        }

                 

                    }

                 

                to run

                 

                  set hornetq_lib=C:/redhat/jboss/hornetq/hornetq-2.4.0.Final/lib

                  java.exe -ea -cp %hornetq_lib%/hornetq-commons.jar;%hornetq_lib%/jboss-mc.jar;%hornetq_lib%/hornetq-core-client.jar;%hornetq_lib%/netty.jar;build HornetQServerControlUsingCoreTest

                 

                 

                client side

                ===========

                 

                  Exception in thread "main" HornetQSecurityException[errorType=SECURITY_EXCEPTION message=HQ119032: User: hqadmin doesnt have permission=CREATE_NON_DURABLE_QUEUE on address {2}]

                          at org.hornetq.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:390)

                          at org.hornetq.core.client.impl.ClientSessionImpl.internalCreateQueue(ClientSessionImpl.java:2056)

                          at org.hornetq.core.client.impl.ClientSessionImpl.createTemporaryQueue(ClientSessionImpl.java:370)

                          at org.hornetq.core.client.impl.DelegatingSession.createTemporaryQueue(DelegatingSession.java:327)

                          at org.hornetq.api.core.client.ClientRequestor.<init>(ClientRequestor.java:57)

                          at HornetQServerControlUsingCoreTest.retrieveAttributeValue(HornetQServerControlUsingCoreTest.java:70)

                          at HornetQServerControlUsingCoreTest.main(HornetQServerControlUsingCoreTest.java:54)

                 

                server side

                ===========

                  hornetq-2.4.0.Final

                 

                11:22:56,608 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management.4403a132-bf5c-4809-9750-5d6d19b0d062

                11:22:56,609 TRACE [org.hornetq.core.server] Sending Notification = Notification[uid=null, type=SECURITY_PERMISSION_VIOLATION, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_Address=jms.queue.hornetq.management.4403a132-bf5c-4809-9750-5d6d19b0d062, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]], notificationEnabled=true messagingServerControl=org.hornetq.core.management.impl.HornetQServerControlImpl@1f74e74b

                11:22:56,611 TRACE [org.hornetq.core.server] Receiving notification : Notification[uid=null, type=SECURITY_PERMISSION_VIOLATION, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_Address=jms.queue.hornetq.management.4403a132-bf5c-4809-9750-5d6d19b0d062, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]] on server HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8

                11:22:56,623 DEBUG [org.hornetq.core.server] Couldn't find any bindings for address=hornetq.notifications on message=ServerMessage[messageID=133,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410366176621, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management.4403a132-bf5c-4809-9750-5d6d19b0d062, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]]@188695837

                11:22:56,625 TRACE [org.hornetq.core.server] Message after routed=ServerMessage[messageID=133,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410366176621, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management.4403a132-bf5c-4809-9750-5d6d19b0d062, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]]@188695837

                11:22:56,627 DEBUG [org.hornetq.core.server] Message ServerMessage[messageID=133,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410366176621, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management.4403a132-bf5c-4809-9750-5d6d19b0d062, _HQ_CheckType=CREATE_NON_DURABLE_QUEUE}]]@188695837 is not going anywhere as it didn't have a binding on address:hornetq.notifications

                11:22:56,659 DEBUG [org.hornetq.core.server] Sending exception to client: HornetQSecurityException[errorType=SECURITY_EXCEPTION message=HQ119032: User: hqadmin doesnt have permission=CREATE_NON_DURABLE_QUEUE on address {2}]

                    at org.hornetq.core.security.impl.SecurityStoreImpl.check(SecurityStoreImpl.java:192) [hornetq-server.jar:]

                    at org.hornetq.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:436) [hornetq-server.jar:]

                    at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:239) [hornetq-server.jar:]

                    at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:633) [hornetq-core-client.jar:]

                    at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:547) [hornetq-core-client.jar:]

                    at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:523) [hornetq-core-client.jar:]

                    at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:635) [hornetq-server.jar:]

                    at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.channelRead(HornetQChannelHandler.java:74) [hornetq-core-client.jar:]

                    at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                    at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:153) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                    at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:122) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:485) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:452) [netty.jar:4.0.13.Final]

                    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:346) [netty.jar:4.0.13.Final]

                    at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty.jar:4.0.13.Final]

                    at java.lang.Thread.run(Thread.java:744) [rt.jar:1.7.0_51]

                 

                I do have server logs, I can send it if needed, I just dont know how to attach it in a reply.

                 

                Thanks for you help

                • 5. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                  jbertram

                  Looking back over your configuration I just noticed this problem in your hornetq-users.xml:

                   

                    <role name="admin, guest"/>

                   

                  The "name" here will be taken in full as the name of the role (i.e. "admin, guest").  You can't put multiple, comma-delimited roles here.  To have multiple roles simply use, e.g.:

                   

                    <role name="admin"/>

                    <role name="guest"/>

                   

                  Fix that and see how it goes from there.

                  • 6. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                    jbertram

                    By the way, this is documented here.

                    • 7. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                      kts92tln8

                      this time i got

                        HQ119032: User: hqadmin doesnt have permission=MANAGE on address {2}

                      for jms.queue.hornetq.management

                       

                        10:41:03,009 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management

                       

                      and client threads hangs on

                       

                        Name: main

                        State: TIMED_WAITING on org.hornetq.core.client.impl.ClientConsumerImpl@1d54d9a

                        Total blocked: 2  Total waited: 7

                       

                        Stack trace:

                        java.lang.Object.wait(Native Method)

                        org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:259)

                        org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:397)

                        org.hornetq.api.core.client.ClientRequestor.request(ClientRequestor.java:95)

                        org.hornetq.api.core.client.ClientRequestor.request(ClientRequestor.java:79)

                        HornetQServerControlUsingCoreTest.retrieveAttributeValue(HornetQServerControlUsingCoreTest.java:77)

                        HornetQServerControlUsingCoreTest.main(HornetQServerControlUsingCoreTest.java:54)

                       

                      following is config,

                      • shouldnt jms.queue.hornetq.management.# provide access to jms.queue.hornetq.management too ?

                       

                      ../config/stand\-alone/non\-clustered/hornetq\-configuration.xml

                        

                         <security-settings>

                            <security-setting match="#">

                               <permission type="createNonDurableQueue" roles="guest"/>

                               <permission type="deleteNonDurableQueue" roles="guest"/>

                               <permission type="consume" roles="guest"/>

                               <permission type="send" roles="guest"/>

                           </security-setting>

                           <security-setting match="jms.queue.hornetq.management.#">

                              <permission type="manage" roles="admin"/>

                              <permission type="createNonDurableQueue" roles="admin"/>

                              <permission type="deleteNonDurableQueue" roles="admin"/>

                              <permission type="consume" roles="admin"/>

                              <permission type="send" roles="admin"/>

                           </security-setting>

                        </security-settings>

                       

                       

                      ../config/stand\-alone/non\-clustered/hornetq\-users.xml

                       

                        <configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

                                    xsi:schemaLocation="urn:hornetq /schema/hornetq-users.xsd">

                           <!-- the default user.  this is used where username is null-->

                           <defaultuser name="guest" password="guest">

                              <role name="guest"/>

                          </defaultuser>

                          <user name="hqadmin" password="gUBwRIHnh4ETD4q">

                              <role name="admin"/>

                              <role name="guest"/>

                          </user>

                        </configuration>

                       

                      server side logs

                      ================

                       

                      10:41:03,009 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management

                      10:41:03,009 TRACE [org.hornetq.core.server] Sending Notification = Notification[uid=null, type=SECURITY_PERMISSION_VIOLATION, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_Address=jms.queue.hornetq.management, _HQ_CheckType=MANAGE}]], notificationEnabled=true messagingServerControl=org.hornetq.core.management.impl.HornetQServerControlImpl@5d2572b8

                      10:41:03,011 TRACE [org.hornetq.core.server] Receiving notification : Notification[uid=null, type=SECURITY_PERMISSION_VIOLATION, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_Address=jms.queue.hornetq.management, _HQ_CheckType=MANAGE}]] on server HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8

                      10:41:03,012 DEBUG [org.hornetq.core.server] Couldn't find any bindings for address=hornetq.notifications on message=ServerMessage[messageID=159,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410450063012, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management, _HQ_CheckType=MANAGE}]]@418447922

                      10:41:03,014 TRACE [org.hornetq.core.server] Message after routed=ServerMessage[messageID=159,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410450063012, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management, _HQ_CheckType=MANAGE}]]@418447922

                      10:41:03,016 DEBUG [org.hornetq.core.server] Message ServerMessage[messageID=159,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410450063012, _HQ_NotifType=SECURITY_PERMISSION_VIOLATION, _HQ_Address=jms.queue.hornetq.management, _HQ_CheckType=MANAGE}]]@418447922 is not going anywhere as it didn't have a binding on address:hornetq.notifications

                      10:41:03,050 ERROR [org.hornetq.core.server] HQ224016: Caught exception: HornetQSecurityException[errorType=SECURITY_EXCEPTION message=HQ119032: User: hqadmin doesnt have permission=MANAGE on address {2}]

                              at org.hornetq.core.security.impl.SecurityStoreImpl.check(SecurityStoreImpl.java:192) [hornetq-server.jar:]

                              at org.hornetq.core.server.impl.ServerSessionImpl.handleManagementMessage(ServerSessionImpl.java:1596) [hornetq-server.jar:]

                              at org.hornetq.core.server.impl.ServerSessionImpl.send(ServerSessionImpl.java:1363) [hornetq-server.jar:]

                              at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:471) [hornetq-server.jar:]

                              at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:633) [hornetq-core-client.jar:]

                              at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:547) [hornetq-core-client.jar:]

                              at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:523) [hornetq-core-client.jar:]

                              at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:635) [hornetq-server.jar:]

                              at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.channelRead(HornetQChannelHandler.java:74) [hornetq-core-client.jar:]

                              at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                              at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                              at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:153) [netty.jar:4.0.13.Final]

                              at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                              at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                              at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty.jar:4.0.13.Final]

                              at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:122) [netty.jar:4.0.13.Final]

                              at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:485) [netty.jar:4.0.13.Final]

                              at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:452) [netty.jar:4.0.13.Final]

                              at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:346) [netty.jar:4.0.13.Final]

                              at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty.jar:4.0.13.Final]

                              at java.lang.Thread.run(Thread.java:744) [rt.jar:1.7.0_51]

                      • 8. Re: Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                        jbertram
                        • shouldnt jms.queue.hornetq.management.# provide access to jms.queue.hornetq.management too ?

                        No.

                         

                        As the documentation states:

                        The '#' character signifies "any sequence of words". Words are delimited by the '.' character.

                        • 9. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                          jbertram

                          It might be useful for you to read this bit of documentation as well about the wild-card syntax.

                          • 10. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                            kts92tln8

                            from here

                            http://docs.jboss.org/hornetq/2.4.0.Final/docs/user-manual/html/wildcard-syntax.html

                             

                            So the wildcard 'news.europe.#' would match 'news.europe', 'news.europe.sport', 'news.europe.politics', and 'news.europe.politics.regional' but would not match 'news.usa', 'news.usa.sport' nor 'entertainment'.

                            • 11. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                              jbertram

                              Based on the regular expression that's generated from the "match" input in the code it looks like the documentation is wrong.  That said, what the documentation describes may be the preferable behavior.  I'll need to talk it over with the other developers to reach a consensus.  For now, though, you'll have to add a specific match for the "jms.queue.hornetq.management".

                              • 12. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                                kts92tln8

                                thanks

                                after updating

                                     <security-setting match="jms.queue.hornetq.#">

                                        <permission type="manage" roles="admin"/>

                                        <permission type="createNonDurableQueue" roles="admin"/>

                                        <permission type="deleteNonDurableQueue" roles="admin"/>

                                        <permission type="consume" roles="admin"/>

                                        <permission type="send" roles="admin"/>

                                     </security-setting>

                                 

                                I got no security error, but client thread was stuck and never returned.

                                 

                                    "main" prio=6 tid=0x0187d400 nid=0x1e3c in Object.wait() [0x0190f000]

                                       java.lang.Thread.State: TIMED_WAITING (on object monitor)

                                            at java.lang.Object.wait(Native Method)

                                            - waiting on <0x23b34870> (a org.hornetq.core.client.impl.ClientConsumerImpl)

                                            at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:259)

                                            - locked <0x23b34870> (a org.hornetq.core.client.impl.ClientConsumerImpl)

                                            at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:397)

                                            at org.hornetq.api.core.client.ClientRequestor.request(ClientRequestor.java:95)

                                            at org.hornetq.api.core.client.ClientRequestor.request(ClientRequestor.java:79)

                                            at HornetQServerControlUsingCoreTest.retrieveAttributeValue(HornetQServerControlUsingCoreTest.java:77)

                                            at HornetQServerControlUsingCoreTest.main(HornetQServerControlUsingCoreTest.java:54)

                                 

                                following is complete threaddump

                                 

                                    Full thread dump Java HotSpot(TM) Client VM (24.51-b03 mixed mode, sharing):

                                 

                                        "Thread-2 (HornetQ-client-global-scheduled-threads-19758338)" daemon prio=6 tid=0x03f57c00 nid=0x1f20 waiting on condition [0x0442f000]

                                           java.lang.Thread.State: WAITING (parking)

                                                at sun.misc.Unsafe.park(Native Method)

                                                - parking to wait for  <0x28fc6278> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)

                                                at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)

                                                at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)

                                                at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1085)

                                                at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807)

                                                at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)

                                                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)

                                                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

                                                at java.lang.Thread.run(Thread.java:744)

                                 

                                        "Thread-0 (HornetQ-client-global-threads-29203939)" daemon prio=6 tid=0x03f3e400 nid=0x1e98 waiting on condition [0x0481f000]

                                           java.lang.Thread.State: TIMED_WAITING (parking)

                                                at sun.misc.Unsafe.park(Native Method)

                                                - parking to wait for  <0x28fcca48> (a java.util.concurrent.SynchronousQueue$TransferStack)

                                                at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)

                                                at java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)

                                                at java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)

                                                at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)

                                                at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)

                                                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)

                                                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

                                                at java.lang.Thread.run(Thread.java:744)

                                 

                                        "Thread-1 (HornetQ-client-global-scheduled-threads-19758338)" daemon prio=6 tid=0x03f35800 nid=0x2b20 waiting on condition [0x04b1f000]

                                           java.lang.Thread.State: TIMED_WAITING (parking)

                                                at sun.misc.Unsafe.park(Native Method)

                                                - parking to wait for  <0x28fc6278> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)

                                                at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)

                                                at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2082)

                                                at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1090)

                                                at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807)

                                                at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)

                                                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)

                                                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

                                                at java.lang.Thread.run(Thread.java:744)

                                 

                                        "Thread-0 (HornetQ-client-global-scheduled-threads-19758338)" daemon prio=6 tid=0x03f35000 nid=0x1b34 waiting on condition [0x0461f000]

                                           java.lang.Thread.State: WAITING (parking)

                                                at sun.misc.Unsafe.park(Native Method)

                                                - parking to wait for  <0x28fc6278> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)

                                                at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)

                                                at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)

                                                at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1085)

                                                at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:807)

                                                at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)

                                                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)

                                                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

                                                at java.lang.Thread.run(Thread.java:744)

                                 

                                        "Thread-0 (HornetQ-client-netty-threads-29059689)" daemon prio=6 tid=0x03eecc00 nid=0x16f4 runnable [0x049df000]

                                           java.lang.Thread.State: RUNNABLE

                                                at sun.nio.ch.WindowsSelectorImpl$SubSelector.poll0(Native Method)

                                                at sun.nio.ch.WindowsSelectorImpl$SubSelector.poll(WindowsSelectorImpl.java:296)

                                                at sun.nio.ch.WindowsSelectorImpl$SubSelector.access$400(WindowsSelectorImpl.java:278)

                                                at sun.nio.ch.WindowsSelectorImpl.doSelect(WindowsSelectorImpl.java:159)

                                                at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:87)

                                                - locked <0x23dc3130> (a io.netty.channel.nio.SelectedSelectionKeySet)

                                                - locked <0x23dc3150> (a java.util.Collections$UnmodifiableSet)

                                                - locked <0x23dc30b8> (a sun.nio.ch.WindowsSelectorImpl)

                                                at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:98)

                                                at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:596)

                                                at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:306)

                                                at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)

                                                at java.lang.Thread.run(Thread.java:744)

                                 

                                        "Service Thread" daemon prio=6 tid=0x01811000 nid=0x7a0 runnable [0x00000000]

                                           java.lang.Thread.State: RUNNABLE

                                 

                                        "C1 CompilerThread0" daemon prio=10 tid=0x0180c000 nid=0x2d08 waiting on condition [0x00000000]

                                           java.lang.Thread.State: RUNNABLE

                                 

                                        "Attach Listener" daemon prio=10 tid=0x0180ac00 nid=0x2a90 runnable [0x00000000]

                                           java.lang.Thread.State: RUNNABLE

                                 

                                        "Signal Dispatcher" daemon prio=10 tid=0x0180a000 nid=0x2b94 waiting on condition [0x00000000]

                                           java.lang.Thread.State: RUNNABLE

                                 

                                        "Finalizer" daemon prio=8 tid=0x01799800 nid=0x2c48 in Object.wait() [0x03aaf000]

                                           java.lang.Thread.State: WAITING (on object monitor)

                                                at java.lang.Object.wait(Native Method)

                                                - waiting on <0x28f64768> (a java.lang.ref.ReferenceQueue$Lock)

                                                at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)

                                                - locked <0x28f64768> (a java.lang.ref.ReferenceQueue$Lock)

                                                at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151)

                                                at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:189)

                                 

                                        "Reference Handler" daemon prio=10 tid=0x01798000 nid=0xaf4 in Object.wait() [0x03c5f000]

                                           java.lang.Thread.State: WAITING (on object monitor)

                                                at java.lang.Object.wait(Native Method)

                                                - waiting on <0x28f647f0> (a java.lang.ref.Reference$Lock)

                                                at java.lang.Object.wait(Object.java:503)

                                                at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133)

                                                - locked <0x28f647f0> (a java.lang.ref.Reference$Lock)

                                 

                                        "main" prio=6 tid=0x0187d400 nid=0x1e3c in Object.wait() [0x0190f000]

                                           java.lang.Thread.State: TIMED_WAITING (on object monitor)

                                                at java.lang.Object.wait(Native Method)

                                                - waiting on <0x23b34870> (a org.hornetq.core.client.impl.ClientConsumerImpl)

                                                at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:259)

                                                - locked <0x23b34870> (a org.hornetq.core.client.impl.ClientConsumerImpl)

                                                at org.hornetq.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:397)

                                                at org.hornetq.api.core.client.ClientRequestor.request(ClientRequestor.java:95)

                                                at org.hornetq.api.core.client.ClientRequestor.request(ClientRequestor.java:79)

                                                at HornetQServerControlUsingCoreTest.retrieveAttributeValue(HornetQServerControlUsingCoreTest.java:77)

                                                at HornetQServerControlUsingCoreTest.main(HornetQServerControlUsingCoreTest.java:54)

                                 

                                        "VM Thread" prio=10 tid=0x01796800 nid=0x1e0c runnable

                                 

                                        "VM Periodic Task Thread" prio=10 tid=0x01823000 nid=0x29fc waiting on condition

                                 

                                        JNI global references: 133

                                 

                                        Heap

                                         def new generation   total 4928K, used 2886K [0x23970000, 0x23ec0000, 0x28ec0000)

                                          eden space 4416K,  53% used [0x23970000, 0x23bc1a20, 0x23dc0000)

                                          from space 512K, 100% used [0x23dc0000, 0x23e40000, 0x23e40000)

                                          to   space 512K,   0% used [0x23e40000, 0x23e40000, 0x23ec0000)

                                         tenured generation   total 10944K, used 2136K [0x28ec0000, 0x29970000, 0x33970000)

                                           the space 10944K,  19% used [0x28ec0000, 0x290d6098, 0x290d6200, 0x29970000)

                                         compacting perm gen  total 12288K, used 3001K [0x33970000, 0x34570000, 0x37970000)

                                           the space 12288K,  24% used [0x33970000, 0x33c5e400, 0x33c5e400, 0x34570000)

                                            ro space 10240K,  44% used [0x37970000, 0x37de7e30, 0x37de8000, 0x38370000)

                                            rw space 12288K,  52% used [0x38370000, 0x389beb58, 0x389bec00, 0x38f70000)

                                 

                                ===========

                                server logs

                                ===========

                                 

                                      12:47:05,058 TRACE [org.hornetq.core.server] Connection created org.hornetq.core.remoting.impl.netty.NettyServerConnection@3716ad20[local= /135.31.237.85:5445, remote=/10.45.73.228:53572]

                                      12:47:05,064 TRACE [org.hornetq.core.client] handling packet PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000]

                                      12:47:05,065 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000] on channeID=0

                                      12:47:05,088 TRACE [org.hornetq.core.client] Writing buffer for channelID=0

                                      12:47:05,090 TRACE [org.hornetq.core.client] handling packet PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000]

                                      12:47:05,090 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000] on channeID=0

                                      12:47:05,091 TRACE [org.hornetq.core.client] Writing buffer for channelID=0

                                      12:47:05,095 TRACE [org.hornetq.core.client] handling packet SubscribeClusterTopologyUpdatesMessage [clusterConnection=false, toString()=PACKET(SubscribeClusterTopologyUpdatesMessageV2)[type=113, channelID=0, packetObject=SubscribeClusterTopologyUpdatesMessageV2]]

                                      12:47:05,102 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(ClusterTopologyChangeMessage_V2)[type=114, channelID=0, packetObject=ClusterTopologyChangeMessage_V2] on channeID=0

                                      12:47:05,122 TRACE [org.hornetq.core.client] Writing buffer for channelID=0

                                      12:47:05,184 TRACE [org.hornetq.utils] Reading string with utfSize=36

                                      12:47:05,185 TRACE [org.hornetq.utils] Reading string with utfSize=13

                                      12:47:05,185 TRACE [org.hornetq.core.client] handling packet PACKET(CreateSessionMessage)[type=30, channelID=1, packetObject=CreateSessionMessage]

                                      12:47:05,198 TRACE [org.hornetq.journal] appendAddRecord::id=172, userRecordType=24, usedFile = JournalFileImpl: (hornetq-bindings-1.bindings id = 1, recordID = 1)

                                      12:47:05,204 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(CreateSessionResponseMessage)[type=31, channelID=1, packetObject=CreateSessionResponseMessage] on channeID=1

                                      12:47:05,205 TRACE [org.hornetq.core.client] Writing buffer for channelID=1

                                      12:47:05,284 TRACE [org.hornetq.core.client] handling packet PACKET(SessionRequestProducerCreditsMessage)[type=79, channelID=10, packetObject=SessionRequestProducerCreditsMessage]

                                      12:47:05,287 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(SessionProducerCreditsMessage)[type=80, channelID=10, packetObject=SessionProducerCreditsMessage] on channeID=10

                                      12:47:05,288 TRACE [org.hornetq.core.client] Writing buffer for channelID=10

                                      12:47:05,291 TRACE [org.hornetq.core.client] handling packet PACKET(CreateQueueMessage)[type=34, channelID=10, packetObject=CreateQueueMessage, address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queueName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, filterString=null, durable=false, temporary=true]

                                      12:47:05,293 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348

                                      12:47:05,294 DEBUG [org.hornetq.core.server] jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348 creating subscription 173 with filter null: java.lang.Exception: trace

                                        at org.hornetq.core.paging.cursor.impl.PageCursorProviderImpl.createSubscription(PageCursorProviderImpl.java:97) [hornetq-server.jar:]

                                        at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:1915) [hornetq-server.jar:]

                                        at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:1116) [hornetq-server.jar:]

                                        at org.hornetq.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:439) [hornetq-server.jar:]

                                        at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:239) [hornetq-server.jar:]

                                        at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:633) [hornetq-core-client.jar:]

                                        at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:547) [hornetq-core-client.jar:]

                                        at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:523) [hornetq-core-client.jar:]

                                        at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:635) [hornetq-server.jar:]

                                        at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.channelRead(HornetQChannelHandler.java:74) [hornetq-core-client.jar:]

                                        at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                                        at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:153) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:122) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:485) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:452) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:346) [netty.jar:4.0.13.Final]

                                        at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty.jar:4.0.13.Final]

                                        at java.lang.Thread.run(Thread.java:744) [rt.jar:1.7.0_51]

                                 

                                      12:47:05,304 DEBUG [org.hornetq.core.server] Adding binding LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8] with address = jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348: java.lang.Exception: trace

                                        at org.hornetq.core.postoffice.impl.SimpleAddressManager.addBinding(SimpleAddressManager.java:68) [hornetq-server.jar:]

                                        at org.hornetq.core.postoffice.impl.WildcardAddressManager.addBinding(WildcardAddressManager.java:96) [hornetq-server.jar:]

                                        at org.hornetq.core.postoffice.impl.PostOfficeImpl.addBinding(PostOfficeImpl.java:453) [hornetq-server.jar:]

                                        at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:1942) [hornetq-server.jar:]

                                        at org.hornetq.core.server.impl.HornetQServerImpl.createQueue(HornetQServerImpl.java:1116) [hornetq-server.jar:]

                                        at org.hornetq.core.server.impl.ServerSessionImpl.createQueue(ServerSessionImpl.java:439) [hornetq-server.jar:]

                                        at org.hornetq.core.protocol.core.ServerSessionPacketHandler.handlePacket(ServerSessionPacketHandler.java:239) [hornetq-server.jar:]

                                        at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:633) [hornetq-core-client.jar:]

                                        at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:547) [hornetq-core-client.jar:]

                                        at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:523) [hornetq-core-client.jar:]

                                        at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:635) [hornetq-server.jar:]

                                        at org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.channelRead(HornetQChannelHandler.java:74) [hornetq-core-client.jar:]

                                        at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                                        at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:153) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:338) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:324) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:785) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:122) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:485) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:452) [netty.jar:4.0.13.Final]

                                        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:346) [netty.jar:4.0.13.Final]

                                        at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101) [netty.jar:4.0.13.Final]

                                        at java.lang.Thread.run(Thread.java:744) [rt.jar:1.7.0_51]

                                 

                                      12:47:05,317 TRACE [org.hornetq.core.server] addBinding(LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8]) being called

                                      12:47:05,319 TRACE [org.hornetq.core.server] Adding binding LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8] into BindingsImpl [name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348] bindingTable:

                                      ***************************************

                                      routingNameBindingMap:

                                      key=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, value=[LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8]]

                                 

                                      RoutingNamePositions:

                                      EMPTY!

                                 

                                      BindingsMap:

                                      Key=173, value=LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8]

                                 

                                      ExclusiveBindings:

                                      EMPTY!

                                      #####################################################

                                 

                                      12:47:05,326 DEBUG [org.hornetq.core.server] ClusterCommunication::Sending notification for addBinding LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8] from server HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8

                                      12:47:05,328 TRACE [org.hornetq.core.server] Sending Notification = Notification[uid=a4c9b1d4-39db-11e4-841c-efa637ea8be2, type=BINDING_ADDED, properties=TypedProperties[{_HQ_Binding_ID=173, _HQ_Binding_Type=0, _HQ_Distance=0, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348}]], notificationEnabled=true messagingServerControl=org.hornetq.core.management.impl.HornetQServerControlImpl@48b4e8e2

                                      12:47:05,331 TRACE [org.hornetq.core.server] Receiving notification : Notification[uid=a4c9b1d4-39db-11e4-841c-efa637ea8be2, type=BINDING_ADDED, properties=TypedProperties[{_HQ_Binding_ID=173, _HQ_Binding_Type=0, _HQ_Distance=0, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348}]] on server HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8

                                      12:47:05,343 DEBUG [org.hornetq.core.server] Couldn't find any bindings for address=hornetq.notifications on message=ServerMessage[messageID=174,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1410457625340, _HQ_Binding_Type=0, _HQ_Binding_ID=173, _HQ_Distance=0, _HQ_NotifType=BINDING_ADDED, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, foobar=a4c9b1d4-39db-11e4-841c-efa637ea8be2}]]@1997287614

                                      12:47:05,345 TRACE [org.hornetq.core.server] Message after routed=ServerMessage[messageID=174,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1410457625340, _HQ_Binding_Type=0, _HQ_Binding_ID=173, _HQ_Distance=0, _HQ_NotifType=BINDING_ADDED, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, foobar=a4c9b1d4-39db-11e4-841c-efa637ea8be2}]]@1997287614

                                      12:47:05,348 DEBUG [org.hornetq.core.server] Message ServerMessage[messageID=174,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_NotifTimestamp=1410457625340, _HQ_Binding_Type=0, _HQ_Binding_ID=173, _HQ_Distance=0, _HQ_NotifType=BINDING_ADDED, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, foobar=a4c9b1d4-39db-11e4-841c-efa637ea8be2}]]@1997287614 is not going anywhere as it didn't have a binding on address:hornetq.notifications

                                      12:47:05,351 FINER [javax.management.mbeanserver]  name = org.hornetq:module=Core,type=Address,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,352 FINER [javax.management.misc] Building MBeanInfo for org.hornetq.core.management.impl.AddressControlImpl

                                      12:47:05,353 FINER [javax.management.mbeanserver] ObjectName = org.hornetq:module=Core,type=Address,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,354 FINER [javax.management.mbeanserver] name = org.hornetq:module=Core,type=Address,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,354 FINER [javax.management.mbeanserver] Send create notification of object org.hornetq:module=Core,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",type=Address

                                      12:47:05,355 FINER [javax.management.mbeanserver] JMX.mbean.registered org.hornetq:module=Core,type=Address,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,356 DEBUG [org.hornetq.core.server] registered address org.hornetq:module=Core,type=Address,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,357 FINER [javax.management.mbeanserver]  name = org.hornetq:module=Core,type=Queue,address="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,358 FINER [javax.management.misc] Building MBeanInfo for org.hornetq.core.management.impl.QueueControlImpl

                                      12:47:05,370 FINER [javax.management.mbeanserver] ObjectName = org.hornetq:module=Core,type=Queue,address="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,370 FINER [javax.management.mbeanserver] name = org.hornetq:module=Core,type=Queue,address="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,371 FINER [javax.management.mbeanserver] Send create notification of object org.hornetq:address="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",module=Core,name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",type=Queue

                                      12:47:05,372 FINER [javax.management.mbeanserver] JMX.mbean.registered org.hornetq:module=Core,type=Queue,address="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,373 DEBUG [org.hornetq.core.server] registered queue org.hornetq:module=Core,type=Queue,address="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348",name="jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348"

                                      12:47:05,375 DEBUG [org.hornetq.core.server] Queue jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348 created on address jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348 with filter=null temporary = true durable=false on session user=hqadmin, connection=RemotingConnectionImpl [clientID=null, nodeID=c801236e-3524-11e4-9092-a3cffa68f5c8, transportConnection=org.hornetq.core.remoting.impl.netty.NettyServerConnection@3716ad20[local= /135.31.237.85:5445, remote=/10.45.73.228:53572]]

                                      12:47:05,378 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(NullResponseMessage)[type=21, channelID=10, packetObject=NullResponseMessage] on channeID=10

                                      12:47:05,379 TRACE [org.hornetq.core.client] Writing buffer for channelID=10

                                      12:47:05,686 TRACE [org.hornetq.core.client] handling packet PACKET(SessionCreateConsumerMessage)[type=40, channelID=10, packetObject=SessionCreateConsumerMessage, queueName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, filterString=null]

                                      12:47:05,687 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348

                                      12:47:05,693 DEBUG [org.hornetq.core.server] QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44 adding consumer ServerConsumerImpl [id=0, filter=null, binding=LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8]]

                                      12:47:05,697 DEBUG [org.hornetq.core.server] Session with user=hqadmin, connection=RemotingConnectionImpl [clientID=null, nodeID=c801236e-3524-11e4-9092-a3cffa68f5c8, transportConnection=org.hornetq.core.remoting.impl.netty.NettyServerConnection@3716ad20[local= /135.31.237.85:5445, remote=/10.45.73.228:53572]] created a consumer on queue jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, filter = null

                                      12:47:05,698 TRACE [org.hornetq.core.server] Sending Notification = Notification[uid=null, type=CONSUMER_CREATED, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_SessionName=7ca8b6b7-39db-11e4-9e4c-771b5c78becb, _HQ_Distance=0, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ConsumerCount=1, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_RemoteAddress=/10.45.73.228:53572}]], notificationEnabled=true messagingServerControl=org.hornetq.core.management.impl.HornetQServerControlImpl@48b4e8e2

                                      12:47:05,701 TRACE [org.hornetq.core.server] Receiving notification : Notification[uid=null, type=CONSUMER_CREATED, properties=TypedProperties[{_HQ_User=hqadmin, _HQ_SessionName=7ca8b6b7-39db-11e4-9e4c-771b5c78becb, _HQ_Distance=0, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ConsumerCount=1, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_RemoteAddress=/10.45.73.228:53572}]] on server HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8

                                      12:47:05,704 DEBUG [org.hornetq.core.server] Couldn't find any bindings for address=hornetq.notifications on message=ServerMessage[messageID=175,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410457625703, _HQ_Distance=0, _HQ_SessionName=7ca8b6b7-39db-11e4-9e4c-771b5c78becb, _HQ_NotifType=CONSUMER_CREATED, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ConsumerCount=1, _HQ_RemoteAddress=/10.45.73.228:53572}]]@1029873850

                                      12:47:05,706 TRACE [org.hornetq.core.server] Message after routed=ServerMessage[messageID=175,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410457625703, _HQ_Distance=0, _HQ_SessionName=7ca8b6b7-39db-11e4-9e4c-771b5c78becb, _HQ_NotifType=CONSUMER_CREATED, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ConsumerCount=1, _HQ_RemoteAddress=/10.45.73.228:53572}]]@1029873850

                                      12:47:05,709 DEBUG [org.hornetq.core.server] Message ServerMessage[messageID=175,durable=true,userID=null,priority=0, bodySize=512,expiration=0, durable=true, address=hornetq.notifications,properties=TypedProperties[{_HQ_User=hqadmin, _HQ_NotifTimestamp=1410457625703, _HQ_Distance=0, _HQ_SessionName=7ca8b6b7-39db-11e4-9e4c-771b5c78becb, _HQ_NotifType=CONSUMER_CREATED, _HQ_Address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ClusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8, _HQ_RoutingName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, _HQ_ConsumerCount=1, _HQ_RemoteAddress=/10.45.73.228:53572}]]@1029873850 is not going anywhere as it didn't have a binding on address:hornetq.notifications

                                      12:47:05,716 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(SessionQueueQueryResponseMessage)[type=46, channelID=10, packetObject=SessionQueueQueryResponseMessage] on channeID=10

                                      12:47:05,716 TRACE [org.hornetq.core.client] Writing buffer for channelID=10

                                      12:47:05,784 TRACE [org.hornetq.core.client] handling packet PACKET(SessionConsumerFlowCreditMessage)[type=70, channelID=10, packetObject=SessionConsumerFlowCreditMessage, consumerID=0, credits=1048576]

                                      12:47:05,785 DEBUG [org.hornetq.core.server] ServerConsumerImpl [id=0, filter=null, binding=LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8]]::FlowControl::Received 1048576 credits, previous value = 0 currentValue = 1048576

                                      12:47:05,787 TRACE [org.hornetq.core.server] ServerConsumerImpl [id=0, filter=null, binding=LocalQueueBinding [address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, queue=QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44, filter=null, name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, clusterName=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348c801236e-3524-11e4-9092-a3cffa68f5c8]]::calling promptDelivery from receiving credits

                                      12:47:05,790 DEBUG [org.hornetq.core.server] QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44 doing deliver. messageReferences=0

                                      12:47:05,806 TRACE [org.hornetq.core.client] handling packet PACKET(SessionSendMessage)[type=71, channelID=10, packetObject=SessionSendMessage]

                                      12:47:05,806 TRACE [org.hornetq.core.server] send(message=ServerMessage[messageID=176,durable=false,userID=null,priority=4, bodySize=393,expiration=0, durable=false, address=jms.queue.hornetq.management,properties=TypedProperties[{_HQ_Attribute=queueNames, _HQ_ResourceName=core.server, JMSReplyTo=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348}]]@1576002061, direct=true) being called

                                      12:47:05,808 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management

                                      12:47:05,809 DEBUG [org.hornetq.core.server] handling management message for core.server

                                      12:47:05,818 TRACE [org.hornetq.core.server] checking access permissions to jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348

                                      12:47:05,819 TRACE [org.hornetq.core.server] Routing message ServerMessage[messageID=177,durable=false,userID=null,priority=0, bodySize=512,expiration=0, durable=false, address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348,properties=TypedProperties[{_HQ_OperationSucceeded=true}]]@1450832391 on binding=BindingsImpl [name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348]

                                      12:47:05,821 TRACE [org.hornetq.core.server] Message after routed=ServerMessage[messageID=177,durable=false,userID=null,priority=0, bodySize=512,expiration=0, durable=false, address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348,properties=TypedProperties[{_HQ_OperationSucceeded=true}]]@1450832391

                                      12:47:05,826 DEBUG [org.hornetq.core.server] QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44 doing deliver. messageReferences=0

                                      12:47:05,829 TRACE [org.hornetq.core.server] Queue jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348 is delivering reference Reference[177]:NON-RELIABLE:ServerMessage[messageID=177,durable=false,userID=null,priority=0, bodySize=512,expiration=0, durable=false, address=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348,properties=TypedProperties[{_HQ_OperationSucceeded=true}]]@1450832391

                                      12:47:05,831 DEBUG [org.hornetq.core.server] QueueImpl[name=jms.queue.hornetq.management.2974aac1-acb6-4a48-a6ea-8e6355901348, postOffice=PostOfficeImpl [server=HornetQServerImpl::serverUUID=c801236e-3524-11e4-9092-a3cffa68f5c8]]@70b4cc44::All the consumers were busy, giving up now

                                      12:47:26,884 DEBUG [org.hornetq.core.server] Cannot expire from jms.queue.ExpiryQueue into jms.queue.ExpiryQueue

                                      12:47:35,034 TRACE [org.hornetq.core.client] handling packet PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000]

                                      12:47:35,035 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000] on channeID=0

                                      12:47:35,036 TRACE [org.hornetq.core.client] Writing buffer for channelID=0

                                      12:47:56,886 DEBUG [org.hornetq.core.server] Cannot expire from jms.queue.ExpiryQueue into jms.queue.ExpiryQueue

                                      12:48:05,037 TRACE [org.hornetq.core.client] handling packet PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000]

                                      12:48:05,038 TRACE [org.hornetq.core.client] Sending packet nonblocking PACKET(Ping)[type=10, channelID=0, packetObject=Ping, connectionTTL=60000] on channeID=0

                                      12:48:05,039 TRACE [org.hornetq.core.client] Writing buffer for channelID=0

                                • 13. Re: Using Management Via Core API fails with doesnt have permission=CREATE_NON_DURABLE_QUEUE
                                  jbertram

                                  I think that's a bug in your code.  Try calling org.hornetq.api.core.client.ClientSession#start on the session you're giving to the ClientRequestor.

                                  1 of 1 people found this helpful