activenq之消息筛选

String filter = "sign = 'golang'";      
MessageConsumer messageConsumer = session.createConsumer(destination,filter);

    public boolean matches(MessageReference node, MessageEvaluationContext context) throws IOException {
         ConsumerId targetConsumerId = node.getTargetConsumerId();
         if (targetConsumerId != null) {
             if (!targetConsumerId.equals(info.getConsumerId())) {
                 return false;
             }
         }
         try {
             return (selectorExpression == null || 
selectorExpression.matches(context)) && this.context.isAllowedToConsume(node);
         } catch (JMSException e) {
             LOG.info("Selector failed to evaluate: " + e.getMessage(), e);
             return false;
         }
     }