Return-Path: 
 <users-return-56398-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
X-Original-To: apmail-camel-users-archive@www.apache.org
Delivered-To: apmail-camel-users-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 7DD57186BA
	for <apmail-camel-users-archive@www.apache.org>;
 Wed, 22 Jul 2015 10:06:59 +0000 (UTC)
Received: (qmail 12525 invoked by uid 500); 22 Jul 2015 09:39:57 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 12479 invoked by uid 500); 22 Jul 2015 09:39:57 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Delivered-To: moderator for users@camel.apache.org
Received: (qmail 97498 invoked by uid 99); 22 Jul 2015 09:33:12 -0000
X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 2.765
X-Spam-Level: **
X-Spam-Status: No, score=2.765 tagged_above=-999 required=6.31
	tests=[DKIM_ADSP_CUSTOM_MED=0.001, FREEMAIL_ENVFROM_END_DIGIT=0.25,
	NML_ADSP_CUSTOM_MED=1.2, URIBL_BLOCKED=0.001, URI_HEX=1.313]
	autolearn=disabled
Date: Wed, 22 Jul 2015 02:33:03 -0700 (MST)
From: moorthy31 <manohar237@gmail.com>
To: users@camel.apache.org
Message-ID: <1437557583283-5769738.post@n5.nabble.com>
Subject: Set referenced Bean as end point
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

As part of camel integration test, I am trying to set bean referenced in the
route builder as end point where body and header message is used to process
the data and insert into the database. I don't know how to set  reference
bean as end point in my test case

This is my camel contest :
<camelContext id=&quot;camel.main&quot; trace=&quot;true&quot;
&lt;route id=&quot;inbound.processing.route&quot;
startupOrder=&quot;1&quot;>
			<from
				uri="activemq:queue:ABC-TEST" />
			<setExchangePattern pattern="InOnly" />
			<bean id="processor.bean" ref="ABCBean" />
			<to id="man.cdt.log.incoming"
			
uri="log:log.incoming?level=INFO&amp;multiline=true&amp;showHeaders=true&amp;showBodyType=false&amp;showBody=false&amp;showException=true&amp;showStackTrace=true"
/>
			<to id="log.stats"
			
uri="log:log.stats?level=INFO&amp;groupInterval=10000&amp;groupDelay=60000&amp;groupActiveOnly=false"
/>
		</route>
	</camelContext>

<bean id="ABCBean" class="com.processor.ABCBean">
			<property name="parserFactory" ref="parserFactory" />
		<property name="hibernateTransform" ref="hibernateTransform" />
	</bean>


The below is the test method in my test case

@Test
	public void testAsyncEndpointOK() throws InterruptedException {

		CamelContext camelContext = null;

		MockEndpoint end = null;
		try {
			ApplicationContext context = createApplicationContext();			
			camelContext = (CamelContext) context.getBean("camel.main");	
			
			ProducerTemplate producer = camelContext.createProducerTemplate();
			end = getMockEndpoint("mock:ABCBean.class");
			String messageBody = readMessage();
			Map<String, Object> map = new HashMap<String, Object>();
			map.put("messageType", "MSG_TYPE");
			map.put("table", "TABLE");
			// producer.sendBody(messageBody);
			// producer.sendBody("mock:ProcessorBean.class", messageBody);
			producer.sendBodyAndHeaders(end, messageBody, map);
		} catch (CamelExecutionException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println(camelContext.getEndpoints());
		end.assertIsSatisfied();
		

	}


public class ABCBean {
	 @Handler
    public void handler(@Body String body,
            @Header(Constants.TABLE_NAME) String tableName,
            @Header(Constants.APP_ID) String appId) throws
ApplicationException {

        try {  
		
		methdod A{}
		
		}

I want my test control goes to ABC bean where  the messages get inserted
into the table. Currently test control is not going to bean end point. Could
you please help me, how do I send the message and header info into the
referenced Bean?






--
View this message in context: http://camel.465427.n5.nabble.com/Set-referenced-Bean-as-end-point-tp5769738.html
Sent from the Camel - Users mailing list archive at Nabble.com.