[
https://issues.apache.org/activemq/browse/AMQNET-237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=57780#action_57780
]
Timothy Bish commented on AMQNET-237:
-------------------------------------
The reason you don't see any error is that the Stomp client sends messages
asynchronously whenever possible so even thought the stomp client does indeed
receive an error response we discard it since we can't correlate it with an
request. You can work around this by setting the connection's alwaysSyncSend
property to true, or sending the message with persistence turned on should do
the trick.
> 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
> Attachments: activemq.xml
>
>
> 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.
