facing while using pub sub in with activemq

[Shireen mirza <mi...@gmail.com>]

I am using below code to create publisher  and  and every creating it
whenever a ineed to add message in topic but some it will through
exception    so please how resolve this problem

j


















*avax.jms.InvalidClientIDException: Broker: localhost - Client:
AthenaPublisher already connected from tcp://127.0.0.1:44448
<http://127.0.0.1:44448>        at
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:247)
      at
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:227)
      at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)
      at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:119)
      at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)
      at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)
      at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)
      at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:843)
      at
org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:77)
      at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)
      at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)
      at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)
      at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
      at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)
      at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)
      at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
      at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)
      at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)
      at java.lang.Thread.run(Thread.java:748)*



*# code*
@Override
public void createConnection(String publisherName, String TopicName) {
try {
// ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://"
// + ip + ":" + port);
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"tcp://" + ip + ":" + port );
// create a Connection
connection = connectionFactory.createConnection();

connection.setClientID(publisherName);
// PooledConnectionFactory pf = new
PooledConnectionFactory(connectionFactory);
// pf.setMaxConnections(1000);
// create a Session
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// create the Topic to which messages will be sent
Topic topic = session.createTopic(TopicName);

// create a MessageProducer for sending messages
messageProducer = session.createProducer(topic);

} catch (Exception e) {
e.printStackTrace();
PantheonLogger.log(getModuleAuthor(), getModuleName(), e.getMessage(),
LogSeverity.error);
}
}
}