[jboss-user] [JBoss Messaging] - Connection not authorized to addMessages to destination

[MThoresen]

Newbee here.  Doing a simple wholesaler and retaler jms example.

1) wholesaler creates a temporarytopic and subscribes to it.
2) when wholesaler publishes a message, it sets the message's JMSReplyTo to the temporaryTopic.

3) When retailer receives a message from wholesaler, it does some stuff and then based on calculations, it will publish a message to the message.getJMSReplyTo().  Here is the basic code snipets..

wholesaler:
            hotDealsTopic = (Topic) jndi.lookup("topic/Hot Deals");
            publisher = pubSession.createPublisher(hotDealsTopic);

            buyOrdersTopic = subSession.createTemporaryTopic();

            subscriber = subSession.createSubscriber(buyOrdersTopic);
            subscriber.setMessageListener(this);

when publishing:
            StreamMessage message = pubSession.createStreamMessage();
            message.writeString(dealDesc);
            message.writeString(itemDesc);
            message.writeFloat(oldPrice);
            message.writeFloat(newPrice);

            message.setStringProperty("Username", username);
            message.setStringProperty("Itemdesc", itemDesc);

            message.setJMSReplyTo(buyOrdersTopic);

            publisher.publish(message, DeliveryMode.PERSISTENT, Message.DEFAULT_PRIORITY,1800000);


Retailer: on Receive and process:

                TextMessage textMsg = session.createTextMessage();

                textMsg.setText(count + " " + itemDesc);

                Topic buyTopic = (Topic) message.getJMSReplyTo();
                publisher = session.createPublisher(buyTopic);

                textMsg.setJMSCorrelationID("DurableRetailer");

                publisher.publish(textMsg, DeliveryMode.PERSISTENT, Message.DEFAULT_PRIORITY, 1800000);


JMSSecurityException:
avax.jms.JMSSecurityException: Connection not authorized to addMessages to destination: JMS_TT5
	at org.jboss.mq.security.ServerSecurityInterceptor.addMessage(ServerSecurityInterceptor.java:167)
	at org.jboss.mq.server.TracingInterceptor.addMessage(TracingInterceptor.java:226)
	at org.jboss.mq.server.JMSServerInvoker.addMessage(JMSServerInvoker.java:112)
	at org.jboss.mq.il.uil2.ServerSocketManagerHandler.handleMsg(ServerSocketManagerHandler.java:111)
	at org.jboss.mq.il.uil2.SocketManager$ReadTask.handleMsg(SocketManager.java:395)
	at org.jboss.mq.il.uil2.msgs.BaseMsg.run(BaseMsg.java:398)
	at EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(PooledExecutor.java:732)
	at java.lang.Thread.run(Thread.java:595)







View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4031325#4031325

Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4031325