topicexample1.java

精通Jboss——Ejb和Web Services开发精解的随书源代码

/**
 * Created on 2003-9-14
 */
package com.liuyang.jboss.message.jms.topic;

import javax.jms.Message;
import javax.jms.TextMessage;

/**
 * @author
 * <a href="mailto:[e-mail]">刘洋</a>
 */
public class TopicExample1 {

	public static void main(String[] args) throws Exception {
		TopicExample1Publisher publisher = new TopicExample1Publisher();
		publisher.connect();
		
		TopicExample1Subscriber subscriber1 = new TopicExample1Subscriber();
		subscriber1.connect();
		
		TopicExample1Subscriber subscriber2 = new TopicExample1Subscriber();
		subscriber2.connect();	
			
		TextMessage textmsg= publisher.session.createTextMessage();
		textmsg.setText("TopicExample1Publisher"+"发送了一次消息,"+"时间戳："+System.currentTimeMillis());		
		textmsg.setStringProperty("from","liuyang");
		publisher.Publish(textmsg);
		
		Message msg1 = subscriber1.Subscribe();
		if(msg1 instanceof TextMessage){
			System.out.println(((TextMessage)msg1).getText());
		}

		Message msg2 = subscriber2.Subscribe();
		if(msg2 instanceof TextMessage){
			System.out.println(((TextMessage)msg2).getText());
		}		
		publisher.disconnect();			
		subscriber1.disconnect();	
		subscriber2.disconnect();
	}
}