JMS 깊이 파악 (9): Selector

본문
http://blog.csdn.net/iamfafa/article/details/6265290
앞의 예 에서 메 시 지 를 만 드 는 소비자 들 이 사용 하 는 것 은:
sesssion.createConsumer(destination)
또 다른 방식 도 제공 했다.
sesssion.createConsumer(destination, selector)
이 selector 는 메 시 지 를 걸 러 내 는 문자열 입 니 다.특정 메시지 만 받 을 수 있 는 소비 자 를 만 드 는 방식 이다.Selector 의 형식 은 SQL - 92 와 유사 한 문법 입 니 다.메시지 헤더 정보 와 속성 을 비교 할 수 있 습 니 다.
다음 예 에서 두 소비 자 를 만 들 고 같은 Queue 를 공동으로 감청 하지만 그들의 Selector 는 다르다. 그리고 하나의 메시지 생산 자 를 만들어 여러 메 시 지 를 보낸다.

import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

public class JMSSelectorTest {

	public static void main(String[] args) throws Exception {
		ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
		Connection connection = factory.createConnection();
		connection.start();
		Queue queue = new ActiveMQQueue("testQueue");
		Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
		MessageConsumer comsumerA = session.createConsumer(queue, "receiver = 'A'");
		comsumerA.setMessageListener(new MessageListener() {
			public void onMessage(Message m) {
				try {
					System.out.println("ConsumerA get " + ((TextMessage) m).getText());
				} catch (JMSException e1) {
				}
			}
		});
		MessageConsumer comsumerB = session.createConsumer(queue, "receiver = 'B'");
		comsumerB.setMessageListener(new MessageListener() {
			public void onMessage(Message m) {
				try {
					System.out.println("ConsumerB get " + ((TextMessage) m).getText());
				} catch (JMSException e) {
				}
			}
		});
		MessageProducer producer = session.createProducer(queue);
		for (int i = 0; i < 10; i++) {
			String receiver = (i % 3 == 0 ? "A" : "B");
			TextMessage message = session.createTextMessage("Message" + i + ", receiver:" + receiver);
			message.setStringProperty("receiver", receiver);
			producer.send(message);
		}
	}
}

결 과 는 다음 과 같다.
ConsumerA get Message0, receiver:A
ConsumerB get Message1, receiver:B
ConsumerB get Message2, receiver:B
ConsumerA get Message3, receiver:A
ConsumerB get Message4, receiver:B
ConsumerB get Message5, receiver:B
ConsumerA get Message6, receiver:A
ConsumerB get Message7, receiver:B
ConsumerB get Message8, receiver:B
ConsumerA get Message9, receiver:A
소비자 들 이 관심 있 는 소식 만 가 져 간 다 는 것 을 알 수 있다.