Hi,
I looked around and found some sample code to publish to a JBoss topic...
public static boolean publish(String xml) throws Exception
| {
| log.info("Creating jndi context - alternatively use a
jndi.properties");
| Properties properties = new Properties();
| properties.put(Context.INITIAL_CONTEXT_FACTORY,
"org.jnp.interfaces.NamingContextFactory");
| properties.put(Context.URL_PKG_PREFIXES, "org.jnp.interfaces");
| properties.put(Context.PROVIDER_URL, "jnp://myserver:1099");
| InitialContext ctx = new InitialContext(properties);
|
| Topic topic = (Topic) ctx.lookup("topic/myTopic");
| TopicConnectionFactory tcf = (TopicConnectionFactory)
ctx.lookup("ConnectionFactory");
| TopicConnection tc = tcf.createTopicConnection("user","pwd");
| try
| {
| TopicSession ts = tc.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
| TopicPublisher publisher = ts.createPublisher(topic);
| TextMessage message = ts.createTextMessage(xml);
|
| publisher.send(message);
| publisher.close();
| tc.close();
| return true;
| }
| catch(Exception e){
| log.error("Exception thrown trying to send to topic", e);
| return false;
| }
| finally
| {
| tc.close();
| }
| }
If I disable the subscriber to the topic and look in the JMS_MESSAGES table (HA
JMS is configured), I find 8 duplicated messages. There is no looping and only
a single subscriber has been configured. Since this is the first tested topic
other than the samples that come already installed, this is the only custom
configuration so far. I set up the topic in the *-service.xml file as
follows...
<mbean code="org.jboss.mq.server.jmx.Topic"
| name="jboss.mq.destination:service=Topic,name=myTopic">
| <depends
optional-attribute-name="DestinationManager">jboss.mq:service=DestinationManager</depends>
| <depends
optional-attribute-name="SecurityManager">jboss.mq:service=SecurityManager</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 am not sure what could be causing the superfluous messages. Is there a known
issue with publishing to topics? I am using JBoss 4.0.2 and JDK 1.5.
Thanks in advance!
Theresa
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4071422#4071422
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4071422
_______________________________________________
jboss-user mailing list
jboss-user@lists.jboss.org
https://lists.jboss.org/mailman/listinfo/jboss-user
