public void sendMsgToTopic(String message){ String topicName = queueName; if (topicName == null) { logger.error("Must specify topic name"); } try{ TopicConnectionFactory factory = new TibjmsTopicConnectionFactory(serverUrl); TopicConnection connection = factory.createTopicConnection(userName, password); TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); Topic topic = session.createTopic(topicName); TopicPublisher publisher =session.createPublisher(topic); TextMessage textMessage = session.createTextMessage(); textMessage.setText(message); //publisher.publish(textMessage); logger.debug("Message has been successfully sent to "+topicName); logger.debug("Message Content is "+textMessage.getText()); }catch(JMSException exp){ exp.printStackTrace(); } } /** * * @param message */ public void sendMsgToQueue(String message) { if (queueName == null) { logger.error("Must specify queue name"); } try { QueueConnectionFactory factory = new TibjmsQueueConnectionFactory(serverUrl); QueueConnection connection = factory.createQueueConnection(userName, password); QueueSession session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE); logger.info("The URL of queue server is "+serverUrl); logger.info("The queue Name is "+queueName); Queue queue = session.createQueue(queueName); QueueSender sender = session.createSender(queue); // set message to queue TextMessage textMessage = session.createTextMessage(); textMessage.setText(message); //sender.send(textMessage); logger.debug("Message has been successfully sent to "+queueName); logger.debug("Message Content is "+textMessage.getText()); connection.close(); } catch (JMSException e) { e.printStackTrace(); System.exit(0); } }