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.
