Package org.mule.routing.filters

Examples of org.mule.routing.filters.WildcardFilter

28
29
30
31
32
33
34
35
36
37
38
39
    @Override
    protected void doSetUp() throws Exception
    {
        strategy = new DefaultSystemExceptionStrategy(muleContext, true);
        strategy.setCommitTxFilter(new WildcardFilter("java.io.*"));
        strategy.setRollbackTxFilter(new WildcardFilter("org.mule.*, javax.*"));

        initialiseObject(strategy);
        tx = new TestTransaction(muleContext);
        TransactionCoordination.getInstance().bindTransaction(tx);
    }
View Full Code Here
773
774
775
776
777
778
779
780
            return (ObjectFilter) ClassUtils.instanciateClass(getSubscriptionFilter(), pattern);
        }
        catch (Exception e)
        {
            exceptionListener.exceptionThrown(e);
            return new WildcardFilter(pattern);
        }
    }
View Full Code Here
25
26
27
28
29
30
31
32
    private WildcardFilter subscriptionFilter;

    Sender(ListenerSubscriptionPair pair)
    {
        this.pair = pair;
        subscriptionFilter = new WildcardFilter(pair.getSubscription());
        subscriptionFilter.setCaseSensitive(false);
    }
View Full Code Here
50
51
52
53
54
55
56
57
58
    protected void doSetUp() throws Exception
    {
        super.doSetUp();
       
        // Set SystemExceptionStrategy to redeliver messages (this can only be configured programatically for now)
        ((DefaultSystemExceptionStrategy) muleContext.getExceptionListener()).setRollbackTxFilter(new WildcardFilter("*"));

        qr = jdbcConnector.getQueryRunner();
    }
View Full Code Here
64
65
66
67
68
69
70
        updateFilter();
    }

    private void updateFilter()
    {
        filter = new WildcardFilter(StringUtils.join(ignoredMethods, ','));
    }
View Full Code Here
69
70
71
72
73
74
75
76
    {
        super();
        setMuleContext(muleContext);
        if (rollbackByDefault)
        {
            setRollbackTxFilter(new WildcardFilter("*"));
        }
    }
View Full Code Here
43
44
45
46
47
48
49
    protected void doSetUp() throws Exception
    {
        super.doSetUp();
       
        // Set SystemExceptionStrategy to redeliver messages (this can only be configured programatically for now)
        ((DefaultSystemExceptionStrategy) muleContext.getExceptionListener()).setRollbackTxFilter(new WildcardFilter("*"));
    }
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
207
        // otherwise check each one against a wildcard match
        for (Iterator iterator = receivers.values().iterator(); iterator.hasNext();)
        {
            receiver = (MessageReceiver)iterator.next();
            String filterAddress = receiver.getEndpointURI().getAddress();
            WildcardFilter filter = new WildcardFilter(filterAddress);
            if (filter.accept(endpointUri.getAddress()))
            {
                InboundEndpoint endpoint = receiver.getEndpoint();
                EndpointURI newEndpointURI = new MuleEndpointURI(endpointUri, filterAddress);
                receiver.setEndpoint(new DynamicURIInboundEndpoint(endpoint, newEndpointURI));
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
143
                    message.removeProperty(key, scope);
                }
                else
                {
                    // fallback to the plain wildcard for simplicity
                    WildcardFilter filter = new WildcardFilter(expression);
                    if (filter.accept(key))
                    {
                        message.removeProperty(key, scope);
                    }
                }
            }
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
        List<DataHandler> result;
        //Enable Wildcard matching
        if (expression.contains(ALL_ARGUMENT))
        {
            WildcardFilter filter = new WildcardFilter(expression);
            result = new ArrayList<DataHandler>(message.getInboundAttachmentNames().size());
            for (String name : message.getInboundAttachmentNames())
            {
                if (filter.accept(name))
                {
                    result.add(message.getInboundAttachment(name));
                }
            }
        }
View Full Code Here
TOP

Related Classes of org.mule.routing.filters.WildcardFilter

  • org.mule.context.notification.Sender
  • org.mule.exception.AbstractExceptionStrategy
  • org.mule.execution.ErrorHandlingExecutionTemplateTestCase
  • org.mule.expression.ExpressionUtils
  • org.mule.expression.MessageAttachmentsExpressionEvaluator
  • org.mule.expression.MessageAttachmentsListExpressionEvaluator
  • org.mule.model.resolvers.ReflectionEntryPointResolver
  • org.mule.module.spring.events.MuleEventMulticaster
  • org.mule.test.integration.exceptions.ExceptionRollbackTestCase
  • org.mule.transformer.simple.MessagePropertiesTransformer
    • 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.