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); } } }