activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andreas Ländle (JIRA) <jira+amq...@apache.org>
Subject [jira] Created: (AMQNET-237) NMS/Stomp: MessageProducer.Send(message) ignores exceptions occurring on broker because the destination is invalid.
Date Mon, 22 Feb 2010 11:02:40 GMT
NMS/Stomp: MessageProducer.Send(message) ignores exceptions occurring on broker because the
destination is invalid.
-------------------------------------------------------------------------------------------------------------------

                 Key: AMQNET-237
                 URL: https://issues.apache.org/activemq/browse/AMQNET-237
             Project: ActiveMQ .Net
          Issue Type: Improvement
          Components: ActiveMQ, NMS
    Affects Versions: 1.2.0
         Environment: Win7, ActiveMq 5.3.0, Apache.NMS & Apache.NMS.Stomp 1.2.0.
            Reporter: Andreas Ländle
            Assignee: Jim Gomes
            Priority: Minor


If i send a message to an inexistent destination (and i don't have rights to create the destination)
the attached exceptions is raised on the broker.
Unfortunately i didn't see the exception on the client side.
The call to MessageProducer.Send(message) returns without any exception. Is this behavior
intended?
How should i determine if the message was accepted by the server? Shouldn't i get some notification
on client side? Am i doing something wrong? Was i missing some events i could register to
get notified of such problems? If so please excuse this issue.
Please let me know if you need more information. 
Thanks in advance,
Andreas Ländle

The following error occurs on the broker (ActiveMq 5.3.0).
Async error occurred: java.lang.SecurityException: User <user> is not authorized to
create: queue://<invalid_queue> | org.apache.activemq.broker.TransportConnection.Service
| ActiveMQ Transport: tcp:///192.168.150.5:51909
java.lang.SecurityException: User <user> is not authorized to create: queue://<invalid_queue>
	at org.apache.activemq.security.AuthorizationBroker.addDestination(AuthorizationBroker.java:69)
	at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:149)
	at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:425)
	at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
	at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
	at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
	at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
	at org.apache.activemq.broker.UserIDBroker.send(UserIDBroker.java:39)
	at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
	at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
	at org.apache.activemq.security.AuthorizationBroker.send(AuthorizationBroker.java:181)
	at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:133)
	at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:443)
	at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:631)
	at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:297)
	at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:175)
	at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
	at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:78)
	at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:135)
	at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:247)
	at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:173)
	at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:67)
	at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
	at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
	at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
	at java.lang.Thread.run(Unknown Source)

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message