[jira] Commented: (AMQNET-237) NMS/Stomp: MessageProducer.Send(message) ignores exceptions occurring on broker because the destination is invalid.

["Timothy Bish (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/activemq/browse/AMQNET-237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=57761#action_57761 ] 

Timothy Bish commented on AMQNET-237:
-------------------------------------

Can you add some more info to this, your broker config and a sample app showing how your use case would be good.

> 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.