Package org.apache.activemq.filter

Examples of org.apache.activemq.filter.MessageEvaluationContext

220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
        Message[] messages = destination.browse();
        CompositeType ct = factory.getCompositeType();
        TabularType tt = new TabularType("MessageList", "MessageList", ct, new String[] {"JMSMessageID"});
        TabularDataSupport rc = new TabularDataSupport(tt);

        MessageEvaluationContext ctx = new MessageEvaluationContext();
        ctx.setDestination(destination.getActiveMQDestination());
        BooleanExpression selectorExpression = selector == null ? null : new SelectorParser().parse(selector);

        for (int i = 0; i < messages.length; i++) {
            try {
                if (selectorExpression == null) {
                    rc.put(new CompositeDataSupport(ct, factory.getFields(messages[i])));
                } else {
                    ctx.setMessageReference(messages[i]);
                    if (selectorExpression.matches(ctx)) {
                        rc.put(new CompositeDataSupport(ct, factory.getFields(messages[i])));
                    }
                }
            } catch (Throwable e) {
View Full Code Here
58
59
60
61
62
63
64
    private final MessageEvaluationContext messageEvaluationContext;
    private boolean dontSendReponse;
    private boolean clientMaster = true;

    public ConnectionContext() {
      this.messageEvaluationContext = new MessageEvaluationContext();
    }
View Full Code Here
359
360
361
362
363
364
365
366
367
368
    }

    protected void assertSelector(Message message, String text, boolean expected) throws JMSException {
        BooleanExpression selector = new SelectorParser().parse(text);
        assertTrue("Created a valid selector", selector != null);
        MessageEvaluationContext context = new MessageEvaluationContext();
        context.setMessageReference((org.apache.activemq.command.Message)message);
        boolean value = selector.matches(context);
        assertEquals("Selector for: " + text, expected, value);
    }
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
        throw new RuntimeException("Not supported");
    }
   
       
    public synchronized boolean recoverMessage(Message message, boolean cached) throws Exception {
        MessageEvaluationContext messageEvaluationContext = new NonCachedMessageEvaluationContext();
        messageEvaluationContext.setMessageReference(message);
        if (this.subscription.matches(message, messageEvaluationContext)) {
            return super.recoverMessage(message, cached);
        }
        return false;
       
View Full Code Here
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
                info.setSubscribedDestination(subscription.getConsumerInfo().getDestination());
                // This destination might be a pattern
                topicStore.addSubsciption(info,subscription.getConsumerInfo().isRetroactive());
            }

            final MessageEvaluationContext msgContext = new NonCachedMessageEvaluationContext();
            msgContext.setDestination(destination);
            if (subscription.isRecoveryRequired()) {
                topicStore.recoverSubscription(clientId, subscriptionName, new MessageRecoveryListener() {
                    public boolean recoverMessage(Message message) throws Exception {
                        message.setRegionDestination(Topic.this);
                        try {
                            msgContext.setMessageReference(message);
                            if (subscription.matches(message, msgContext)) {
                                subscription.add(message);
                            }
                        } catch (IOException e) {
                           LOG.error("Failed to recover this message " + message);
View Full Code Here
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
   
    protected void dispatch(final ConnectionContext context, Message message) throws Exception {
        destinationStatistics.getMessages().increment();
        destinationStatistics.getEnqueues().increment();
        dispatchValve.increment();  
        MessageEvaluationContext msgContext = null;
        try {
            if (!subscriptionRecoveryPolicy.add(context, message)) {
                return;
            }
            synchronized (consumers) {
                if (consumers.isEmpty()) {
                    onMessageWithNoConsumers(context, message);
                    return;
                }
            }
            msgContext = context.getMessageEvaluationContext();
            msgContext.setDestination(destination);
            msgContext.setMessageReference(message);
            if (!dispatchPolicy.dispatch(message, msgContext, consumers)) {
                onMessageWithNoConsumers(context, message);
            } 
           
        } finally {
            dispatchValve.decrement();
            if(msgContext != null) {
                msgContext.clear();
            }
        }
    }
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
        return true;
    }

    public boolean addRecoveredMessage(ConnectionContext context, MessageReference message) throws Exception {
        boolean result = false;
        MessageEvaluationContext msgContext = context.getMessageEvaluationContext();
        try {
            msgContext.setDestination(message.getRegionDestination().getActiveMQDestination());
            msgContext.setMessageReference(message);
            result = matches(message, msgContext);
            if (result) {
                doAddRecoveredMessage(message);
            }

        } finally {
            msgContext.clear();
        }
        return result;
    }
View Full Code Here
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
    public boolean iterate() {
        synchronized(iteratingMutex) {
          RecoveryDispatch rd;
          while ((rd = getNextRecoveryDispatch()) != null) {
              try {
                  MessageEvaluationContext msgContext = new NonCachedMessageEvaluationContext();
                  msgContext.setDestination(destination);
     
                  for (QueueMessageReference node : rd.messages) {
                      if (!node.isDropped() && !node.isAcked() && (!node.isDropped() || rd.subscription.getConsumerInfo().isBrowser())) {
                          msgContext.setMessageReference(node);
                          if (rd.subscription.matches(node, msgContext)) {
                               // Log showing message dispatching
                               if (LOG.isDebugEnabled()) {
                                   LOG.debug(destination.getQualifiedName() + " - Recovery - Message pushed '" + node.hashCode() + " - " + node + "' to subscription: '" + rd.subscription + "'");
                               }
View Full Code Here
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
    protected MessageReferenceFilter createSelectorFilter(String selector) throws InvalidSelectorException {
        final BooleanExpression selectorExpression = new SelectorParser().parse(selector);

        return new MessageReferenceFilter() {
            public boolean evaluate(ConnectionContext context, MessageReference r) throws JMSException {
                MessageEvaluationContext messageEvaluationContext = context.getMessageEvaluationContext();

                messageEvaluationContext.setMessageReference(r);
                if (messageEvaluationContext.getDestination() == null) {
                    messageEvaluationContext.setDestination(getActiveMQDestination());
                }

                return selectorExpression.matches(messageEvaluationContext);
            }
        };
View Full Code Here
60
61
62
63
64
65
66
    private boolean dontSendReponse;
    private boolean clientMaster = true;
    private ConnectionState connectionState;

    public ConnectionContext() {
      this.messageEvaluationContext = new MessageEvaluationContext();
    }
View Full Code Here
TOP

Related Classes of org.apache.activemq.filter.MessageEvaluationContext

  • org.apache.activemq.broker.ConnectionContext
  • org.apache.activemq.broker.jmx.DestinationView
  • org.apache.activemq.broker.region.AbstractSubscription
  • org.apache.activemq.broker.region.cursors.TopicStorePrefetch
  • org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy
  • org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy
  • org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy
  • org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
  • org.apache.activemq.broker.region.policy.SimpleDispatchSelector
  • org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.