1 Reply Latest reply on Aug 24, 2007 10:47 AM by Adrian Brock

    Publish once but get 8 replicated message on the topic

    Theresa Field Newbie

      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