Package org.apache.camel.processor

Examples of org.apache.camel.processor.SendProcessor

242
243
244
245
246
247
248
249
250
251
252
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedBodiesReceived("A+B+C", "D");
        mock.expectedPropertyReceived(Exchange.AGGREGATED_COMPLETED_BY, "interval");

        Processor done = new SendProcessor(context.getEndpoint("mock:result"));
        Expression corr = header("id");
        AggregationStrategy as = new BodyInAggregatingStrategy();

        AggregateProcessor ap = new AggregateProcessor(context, done, corr, as, executorService);
        ap.setCompletionInterval(3000);
View Full Code Here
68
69
70
71
72
73
74
75
76
    // Properties
    // -------------------------------------------------------------------------

    public Processor getFailureProcessor() {
        if (failureProcessor == null) {
            failureProcessor = new SendProcessor(deadLetter);
        }
        return failureProcessor;
    }
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
106
        assertIsInstanceOf(CamelContextStartedEvent.class, events.get(2));
        assertIsInstanceOf(ExchangeCreatedEvent.class, events.get(3));

        ExchangeFailureHandledEvent e = assertIsInstanceOf(ExchangeFailureHandledEvent.class, events.get(4));
        assertEquals("should be DLC", true, e.isDeadLetterChannel());
        SendProcessor send = assertIsInstanceOf(SendProcessor.class, e.getFailureHandler());
        assertEquals("mock://dead", send.getDestination().getEndpointUri());

        // dead letter channel will mark the exchange as completed
        assertIsInstanceOf(ExchangeCompletedEvent.class, events.get(5));
        // and the sent will be logged after they are complete sending as it record the time taken as well
        assertIsInstanceOf(ExchangeSentEvent.class, events.get(6));
View Full Code Here
70
71
72
73
74
75
76
77
78
    // -------------------------------------------------------------------------

    public Processor getFailureProcessor() {
        if (failureProcessor == null) {
            // force MEP to be InOnly so when sending to DLQ we would not expect a reply if the MEP was InOut
            failureProcessor = new SendProcessor(deadLetter, ExchangePattern.InOnly);
        }
        return failureProcessor;
    }
View Full Code Here
814
815
816
817
818
819
820
821
822
823
824
                    Endpoint endpoint = camelContext.getEndpoint(recoverable.getDeadLetterUri());
                    if (endpoint == null) {
                        throw new NoSuchEndpointException(recoverable.getDeadLetterUri());
                    }
                    // force MEP to be InOnly so when sending to DLQ we would not expect a reply if the MEP was InOut
                    deadLetterProcessor = new SendProcessor(endpoint, ExchangePattern.InOnly);
                    ServiceHelper.startService(deadLetterProcessor);
                }
            }
        }
View Full Code Here
240
241
242
243
244
245
246
    public DeadLetterChannelBuilder deadLetterChannel(String deadLetterUri) {
        return deadLetterChannel(endpoint(deadLetterUri));
    }

    public DeadLetterChannelBuilder deadLetterChannel(Endpoint deadLetterEndpoint) {
        return new DeadLetterChannelBuilder(new SendProcessor(deadLetterEndpoint));
    }
View Full Code Here
68
69
70
71
72
73
74
    }

    @Override
    public Processor createProcessor(RouteContext routeContext) throws Exception {
        Endpoint endpoint = resolveEndpoint(routeContext);
        return new SendProcessor(endpoint);
    }
View Full Code Here
224
225
226
227
228
229
230
    public DeadLetterChannelBuilder deadLetterChannel(String deadLetterUri) {
        return deadLetterChannel(endpoint(deadLetterUri));
    }

    public DeadLetterChannelBuilder deadLetterChannel(Endpoint deadLetterEndpoint) {
        return new DeadLetterChannelBuilder(new SendProcessor(deadLetterEndpoint));
    }
View Full Code Here
65
66
67
68
69
70
71
72
73
        for (Route<Exchange> route : routes) {
            Endpoint<Exchange> key = route.getEndpoint();
            assertEquals("From endpoint", "seda:a", key.getEndpointUri());
            Processor processor = getProcessorWithoutErrorHandler(route);

            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class, processor);
            assertEquals("Endpoint URI", "seda:b", sendProcessor.getDestination().getEndpointUri());
        }
    }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
            Endpoint key = route.getEndpoint();
            assertEquals("From endpoint", "seda:a", key.getEndpointUri());
            Processor processor = getProcessorWithoutErrorHandler(route);

            FilterProcessor filterProcessor = assertIsInstanceOf(FilterProcessor.class, processor);
            SendProcessor sendProcessor = assertIsInstanceOf(SendProcessor.class,
                                                             unwrapErrorHandler(filterProcessor
                                                                 .getProcessor()));
            assertEquals("Endpoint URI", "seda:b", sendProcessor.getDestination().getEndpointUri());
        }
    }
View Full Code Here
TOP

Related Classes of org.apache.camel.processor.SendProcessor

  • org.apache.camel.AsyncCallback
  • org.apache.camel.AsyncProducerCallback
  • org.apache.camel.builder.BuilderSupport
  • org.apache.camel.builder.ContextErrorHandlerTest
  • org.apache.camel.builder.DeadLetterChannelBuilder
  • org.apache.camel.builder.ErrorHandlerTest
  • org.apache.camel.builder.RouteBuilderTest
  • org.apache.camel.builder.ToBuilder
  • org.apache.camel.Endpoint
  • org.apache.camel.Exchange
    • 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.