Package org.apache.camel

Examples of org.apache.camel.ProducerTemplate.send()

382
383
384
385
386
387
388
389
390
391
392
              this.exchange = exchange;
              return this;
            }
            @Override
            public void run() {
              producer.send("direct:tdrRuleTest5", exchange);
            }
          }.setExchange(exchange)
          ).start();
    }
    // Wait a bit to be sure
View Full Code Here
469
470
471
472
473
474
475
476
477
478
479
    exchange = new DefaultExchange(camelContext);
    exchange.getIn().setHeader("DynamicHeader7",
        "The value header 7, but will not be extracted");
    exchange.getIn().setHeader("DynamicHeader8", "The value header 8");

    producer.send("direct:tdrRuleTest6", exchange);

    assertEquals("Wrong expected message count", 1,
        mockEndpoint.getReceivedCounter());

    receivedExchange = mockEndpoint.getExchanges().get(0);
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
            @Override
            public void run() {
              for(int i=0; i<100; i++) {
                Exchange exchange = new DefaultExchange(camelContext);
                exchange.getIn().setHeader("DynamicHeader", "The dynamic value message:"+i);
                producer.send("direct:tdrWriterTest", exchange);
              }
            }
          }
          ).start();
    }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
    public void testCxfBusConfiguration() throws Exception {
        // get the camelContext from application context
        CamelContext camelContext = (CamelContext) ctx.getBean("camel");
        ProducerTemplate template = camelContext.createProducerTemplate();
        try {
            template.send("cxf:bean:serviceEndpoint", new Processor() {
                public void process(final Exchange exchange) {
                    final List<String> params = new ArrayList<String>();
                    params.add("hello");
                    exchange.getIn().setBody(params);
                    exchange.getIn().setHeader(CxfConstants.OPERATION_NAME, "echo");
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
            final Endpoint e = context.getEndpoint("direct:a");
            context.start();

            for (int i = 0; i < ITERS; i++) {
                template.send(e, new SendingProcessor(i), new AsyncCallback() {
                    public void done(boolean arg0) {
                        // Do nothing here
                    }
                });
            }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
        for (int i = 0; i < messages; i++) {
            Exchange e = targetEndpoint.createExchange();
            e.getIn().setBody("<message>" + i + "</message>");
            // only send if we are still started
            if (context.getStatus().isStarted()) {
                myTemplate.send(targetEndpoint, e);
                sentExchanges.add(e);
                Thread.sleep(100);
            }
        }
        myTemplate.stop();
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
    public void testCxfBusConfiguration() throws InterruptedException {
        // get the camelContext from application context
        CamelContext camelContext = (CamelContext) ctx.getBean("camel");
        ProducerTemplate template = camelContext.createProducerTemplate();
        Exchange exchange = template.send("cxf:bean:routerEndpoint", new Processor() {
            public void process(final Exchange exchange) {
                final List<String> params = new ArrayList<String>();
                params.add("hello");
                exchange.getIn().setBody(params);
                exchange.getIn().setHeader(CxfConstants.OPERATION_NAME, "echo");
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
    Logger log = Logger.getLogger(TestHelper.class);

    protected void sendText(final String fragment, CamelContext context) throws Exception {
        ProducerTemplate template = context.createProducerTemplate();
        template.start();
        template.send("direct:start", new Processor() {
            public void process(Exchange exchange) throws Exception {
                // Set the property of the charset encoding
                exchange.setProperty(Exchange.CHARSET_NAME, "UTF-8");
                Message in = exchange.getIn();
                in.setBody(fragment);
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
            Exchange exchange = endpoint.createExchange(ExchangePattern.InOut);
            exchange.getIn().setHeader(HbaseAttribute.HBASE_ROW_ID.asHeader(), key[0]);
            exchange.getIn().setHeader(HbaseAttribute.HBASE_FAMILY.asHeader(), family[0]);
            exchange.getIn().setHeader(HbaseAttribute.HBASE_QUALIFIER.asHeader(), column[0][0]);
            exchange.getIn().setHeader(HBaseConstants.OPERATION, HBaseConstants.GET);
            Exchange resp = template.send(endpoint, exchange);
            assertEquals(body[0][0][0], resp.getOut().getHeader(HbaseAttribute.HBASE_VALUE.asHeader()));
        }
    }

    @Test
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
                        putExchange.getIn().setHeader(HbaseAttribute.HBASE_VALUE.asHeader(index++), body[row][fam][col]);
                    }
                }
            }
            putExchange.getIn().setHeader(HBaseConstants.OPERATION, HBaseConstants.PUT);
            template.send(startEndpoint, putExchange);

            Exchange getExchange = startWithModelEndpoint.createExchange(ExchangePattern.InOut);
            getExchange.getIn().setHeader(HbaseAttribute.HBASE_ROW_ID.asHeader(), key[0]);
            getExchange.getIn().setHeader(HBaseConstants.OPERATION, HBaseConstants.GET);
            Exchange resp = template.send(startWithModelEndpoint, getExchange);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.