Package org.apache.camel.spi

Examples of org.apache.camel.spi.ThreadPoolProfile

29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
    @Override
    protected CamelContext createCamelContext() throws Exception {
        CamelContext camel = super.createCamelContext();

        ThreadPoolProfile profile = new ThreadPoolProfileSupport("custom");
        profile.setPoolSize(5);
        profile.setMaxPoolSize(15);
        profile.setKeepAliveTime(25L);
        profile.setMaxQueueSize(250);
        profile.setRejectedPolicy(ThreadPoolRejectedPolicy.Abort);

        camel.getExecutorServiceStrategy().setDefaultThreadPoolProfile(profile);
        return camel;
    }
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
52
        camel.getExecutorServiceStrategy().setDefaultThreadPoolProfile(profile);
        return camel;
    }

    public void testCamelCustomDefaultThreadPoolProfile() throws Exception {
        ThreadPoolProfile profile = context.getExecutorServiceStrategy().getDefaultThreadPoolProfile();
        assertEquals(5, profile.getPoolSize().intValue());
        assertEquals(15, profile.getMaxPoolSize().intValue());
        assertEquals(25, profile.getKeepAliveTime().longValue());
        assertEquals(250, profile.getMaxQueueSize().intValue());
        assertEquals(ThreadPoolRejectedPolicy.Abort, profile.getRejectedPolicy());
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
55
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                // create a profile for the throttler
                ThreadPoolProfile profile = new ThreadPoolProfileSupport("myThrottler");
                profile.setMaxPoolSize(5);
                profile.setMaxQueueSize(2);
                context.getExecutorServiceStrategy().registerThreadPoolProfile(profile);
               
                from("seda:start")
                    .throttle(1).timePeriodMillis(100)
                        .asyncDelayed().executorServiceRef("myThrottler").callerRunsWhenRejected(true)
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
53
54
55
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                // create and register thread pool profile
                ThreadPoolProfile profile = new ThreadPoolProfileSupport("myProfile");
                profile.setPoolSize(2);
                profile.setMaxPoolSize(8);
                profile.setRejectedPolicy(ThreadPoolRejectedPolicy.Abort);
                context.getExecutorServiceStrategy().registerThreadPoolProfile(profile);

                from("direct:start")
                    .aggregate(header("id"), new BodyInAggregatingStrategy())
                        // use our custom thread pool profile
View Full Code Here
1047
1048
1049
1050
1051
1052
1053
1054
1055
1056
1057
            // camel context will shutdown the executor when it shutdown so no need to shut it down when stopping
            if (executorServiceRef != null) {
                executorService = camelContext.getRegistry().lookup(executorServiceRef, ScheduledExecutorService.class);
                if (executorService == null) {
                    ExecutorServiceManager manager = camelContext.getExecutorServiceManager();
                    ThreadPoolProfile profile = manager.getThreadPoolProfile(executorServiceRef);
                    executorService = manager.newScheduledThreadPool(this, executorServiceRef, profile);
                }
                if (executorService == null) {
                    throw new IllegalArgumentException("ExecutorServiceRef " + executorServiceRef + " not found in registry.");
                }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                ThreadPoolProfile profile = new ThreadPoolProfileSupport("custom");
                profile.setPoolSize(5);
                profile.setMaxPoolSize(15);
                profile.setKeepAliveTime(25L);
                profile.setMaxQueueSize(250);
                profile.setRejectedPolicy(ThreadPoolRejectedPolicy.Abort);

                context.getExecutorServiceStrategy().registerThreadPoolProfile(profile);

                from("direct:start").threads().executorServiceRef("custom").to("mock:result");
            }
View Full Code Here
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                ThreadPoolProfile profile = new ThreadPoolProfileSupport("custom");
                profile.setPoolSize(5);
                profile.setMaxPoolSize(15);
                profile.setKeepAliveTime(25L);
                profile.setMaxQueueSize(250);
                profile.setRejectedPolicy(ThreadPoolRejectedPolicy.Abort);

                context.getExecutorServiceStrategy().registerThreadPoolProfile(profile);

                from("direct:start").threads().executorServiceRef("custom").to("mock:result");
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
    @Override
    protected CamelContext createCamelContext() throws Exception {
        CamelContext camel = super.createCamelContext();

        ThreadPoolProfile profile = new ThreadPoolProfile("custom");
        profile.setPoolSize(5);
        profile.setMaxPoolSize(15);
        profile.setKeepAliveTime(25L);
        profile.setMaxQueueSize(250);
        profile.setRejectedPolicy(ThreadPoolRejectedPolicy.Abort);

        camel.getExecutorServiceManager().setDefaultThreadPoolProfile(profile);
        return camel;
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
53
        return camel;
    }

    public void testCamelCustomDefaultThreadPoolProfile() throws Exception {
        DefaultExecutorServiceManager manager = (DefaultExecutorServiceManager)context.getExecutorServiceManager();
        ThreadPoolProfile profile = manager.getDefaultThreadPoolProfile();
        assertEquals(5, profile.getPoolSize().intValue());
        assertEquals(15, profile.getMaxPoolSize().intValue());
        assertEquals(25, profile.getKeepAliveTime().longValue());
        assertEquals(250, profile.getMaxQueueSize().intValue());
        assertEquals(ThreadPoolRejectedPolicy.Abort, profile.getRejectedPolicy());
    }
View Full Code Here
23
24
25
26
27
28
29
public class ThreadPoolProfileBuilder {
    private final ThreadPoolProfile profile;

    public ThreadPoolProfileBuilder(String id) {
        this.profile = new ThreadPoolProfile(id);
    }
View Full Code Here
TOP

Related Classes of org.apache.camel.spi.ThreadPoolProfile

  • org.apache.camel.builder.DefaultErrorHandlerBuilder
  • org.apache.camel.builder.ThreadPoolBuilder
  • org.apache.camel.builder.ThreadPoolProfileBuilder
  • org.apache.camel.component.facebook.FacebookProducer
  • org.apache.camel.core.xml.AbstractCamelContextFactoryBean
  • org.apache.camel.core.xml.AbstractCamelThreadPoolFactoryBean
  • org.apache.camel.impl.CamelCustomDefaultThreadPoolProfileTest
  • org.apache.camel.impl.DefaultExecutorServiceManager
  • org.apache.camel.impl.DefaultExecutorServiceManagerTest
  • org.apache.camel.impl.DefaultExecutorServiceStrategy
    • 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.