activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AMQ-5550) Close of an AMQP consumer that failed to open because it was unauthorized causes exception in broker logs.
Date Thu, 29 Jan 2015 16:40:34 GMT
Timothy Bish created AMQ-5550:
---------------------------------

             Summary: Close of an AMQP consumer that failed to open because it was unauthorized
causes exception in broker logs.
                 Key: AMQ-5550
                 URL: https://issues.apache.org/jira/browse/AMQ-5550
             Project: ActiveMQ
          Issue Type: Bug
          Components: AMQP
    Affects Versions: 5.11.0
            Reporter: Timothy Bish
            Assignee: Timothy Bish
            Priority: Minor
             Fix For: 5.12.0


When an AMQP client creates a receiver link and the logged in user is not authorized on error
is sent to the client and the link is closed, this generates an event which causes us to try
and remove the consumer but that consumer was never registered so you see these sorts of things
in the logs:

{noformat}
java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:OfficePC-58049-1422548859782-1:3:1:0
	at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:691)
	at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:76)
	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)
	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)
	at org.apache.activemq.transport.amqp.AmqpTransportFilter.sendToActiveMQ(AmqpTransportFilter.java:114)
	at org.apache.activemq.transport.amqp.AmqpProtocolConverter.sendToActiveMQ(AmqpProtocolConverter.java:1486)
	at org.apache.activemq.transport.amqp.AmqpProtocolConverter$ConsumerContext.onClose(AmqpProtocolConverter.java:1017)
	at org.apache.activemq.transport.amqp.AmqpProtocolConverter.processLinkEvent(AmqpProtocolConverter.java:390)
	at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:331)
	at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:275)
	at org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:98)
	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
{noformat}

This would likely also happen for a sender link.

We need to track this state and not try and remove consumers or producers from the Broker
that not actually registered due to security or other errors.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message