Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- protected void doGet(HttpServletRequest request, HttpServletResponse response) {
- try {
- Context context = new InitialContext();
- TopicConnectionFactory tfactory = (TopicConnectionFactory) context.lookup("jms/MyConnectionFactory");
- TopicConnection tconnection = tfactory.createTopicConnection();
- TopicSession tsession = tconnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
- TopicPublisher publisher = tsession.createPublisher((Topic) context.lookup("jms/MyTopic"));
- for(int i = 0 ; i < 100 ; i++){
- TextMessage message = tsession.createTextMessage();
- message.setText("My message");
- publisher.publish(message);
- }
- context.close();
- tconnection.close();
- response.setContentType("text/html");
- response.getWriter().println("Messages sent");
- } catch (Exception e) {
- e.printStackTrace();
- }
Advertisement
Add Comment
Please, Sign In to add comment