String msgSel = new String ("consumer='"+user+"'");  //设置过滤器
                if (isDurable())                     //是否持久性订阅
                {
                    topicSubscriber = getTopicSession(true).createDurableSubscriber(getSubscribeTopic(), getDurableName(), msgSel, false);
                }
                else
                {
                    topicSubscriber = getTopicSession(true).createSubscriber(getSubscribeTopic(), msgSel, false);
                }
本小段程序的含义是选折出消息队列中消息属性consumer值等于变量user的消息
设置消息属性如下:
textMessage.setStringProperty("consumer", consumer);