I'm still working on this. I've now converted my code to send the
message:
Messenger messenger = MessengerManager.get("topic");
if(messenger != null) {
Destination destination =
messenger.getDestination("pingTopic");
// now lets send a message
TextMessage message = messenger.createTextMessage("this
is some text");
messenger.send( destination, message );
}
And using the normal JMS API I can receive it:
pingTopic = (Topic) jndiContext.lookup("topic/pingTopic");
But when I try to use the subscriptions.xml:
<subscription messenger="topic" destination="topic/pingTopic">
<listener className="com.idtect.oemserver.message.EchoMDO"/>
</subscription>
I don't get any messages. I also tried:
<subscription messenger="topic" destination="pingTopic">
<listener className="com.idtect.oemserver.message.EchoMDO"/>
</subscription>
And that doesn't work either. What is the correct destination name?
Since I am sending to "pingTopic" I thought this would be what I
subscribe for. But when using the JMS API, I use "topic/pingTopic" for
the topic name. This is the part that's confusing to me. Any help
would be appreciated.
Michael
> -----Original Message-----
> From: Michael [mailto:[EMAIL PROTECTED]]
> Sent: Tuesday, August 27, 2002 11:48 AM
> To: [EMAIL PROTECTED]
> Subject: [Messenger] - Problem subscribing for JBossMQ topics
>
>
> I have installed the Messenger libraries and added them to my
> webapp. I copied the EchoMDO object and now I'm trying to
> have it received a topic but it is not receiving any
> messages. I have everything working without the Messenger
> library so I believe I have my JBossMQ configured correctly.
>
> I didn't change MessengerJBoss.xml except to rename it
> Messenger.xml. Is this OK?
>
> In subscriptions.xml I have:
>
> <subscription messenger="topic" destination="topic/pingTopic">
> <listener className="com.idtect.oemserver.message.EchoMDO"/>
> </subscription>
>
> And in my destinations-service.xml file for JBossMQ I have:
>
> <mbean code="org.jboss.mq.server.jmx.Topic"
> name="jboss.mq.destination:service=Topic,name=pingTopic">
> <depends
> optional-attribute-name="DestinationManager">jboss.mq:service=
Destinatio
> nManager</depends>
> <depends
> optional-attribute-name="SecurityManager">jboss.mq:service=Sec
> urityManag
> er</depends>
> <attribute name="SecurityConf">
> <security>
> <role name="guest" read="true" write="true"/>
> <role name="publisher" read="true" write="true"
> create="false"/>
> <role name="durpublisher" read="true" write="true"
> create="true"/>
> </security>
> </attribute>
> </mbean>
>
> I believe I have everything configured right but I'm not
> sure. Any help would be appreciated.
>
> Michael
>
>
> --
> To unsubscribe, e-mail:
> <mailto:commons-user-> [EMAIL PROTECTED]>
> For
> additional commands,
> e-mail: <mailto:[EMAIL PROTECTED]>
>
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
