Mailing-List: contact camel-user-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: camel-user@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of kot.begemot@gmail.com
 designates 74.125.44.157 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=message-id:date:from:to:subject:in-reply-to:mime-version
         :content-type:content-transfer-encoding:content-disposition
         :references;
        b=vkQk/Nr+857y70lJ08a5xb234CvoXSxJChoNaJObaPhEedMasVixV/ZrVm+riJjM0Q
         idQmw/Z2rhiGvQ8VAXQVHhlv7LXP3PTHYlK7zXxCSl6ymLXfeOFmNNVn331bSadyK6zZ
         /xjFmowk/EJKuSloBHSHUiMjT8dRaCUR4eKYM=
Message-ID: <6e8974e40807081245y52eaedc2l5c0e0a595ad90dc@mail.gmail.com>
Date: Tue, 8 Jul 2008 12:45:26 -0700
From: "Vadim Chekan" <kot.begemot@gmail.com>
To: camel-user@activemq.apache.org
Subject: Re: MS SQL Message Service endpoint
In-Reply-To: <4C1FB9C00D24A140906239533638C4D204BD814B@EXVS04.exserver.dk>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit
Content-Disposition: inline
References: <6e8974e40807071532p291b70b0wa8e7395e2ab209a4@mail.gmail.com>
	 <4C1FB9C00D24A140906239533638C4D204BD814B@EXVS04.exserver.dk>

Ok, I managed to receive MS Service Borker messages from sql server. Like this:
		from("timer://kickoff?period=10000").
			setBody(constant("declare @h uniqueidentifier; declare @str
nvarchar(4000); receive top(1) @h=conversation_handle,
@str=message_body from Aspcust1LogQueue; if @h is not null begin; end
conversation @h; select @str as body; end")).
to("jdbc:msServiceBroker");

So what I do from now?
Ideally i'd like to have it like this:
from("jdbc:msBroker?sql=......").to("activemq:log");
from(activemq:log).to("xmpp:myuser:password@host/room");


But apparently jdbc component offers only producers endpoint. As Claus
advised I used "timer" trick (see above).
I thought that I can create 2 routes:
route 1: timer->jdbc
route 2: jdbc->activemq
but I got the same problem: in the second route jdbc can not create a
consumers endpoint.
So the question is: how to consume a message from jdbc component if it
does not offer consumers endpoint?

I looked at components\camel-jdbc\src\test\java\org\apache\camel\component\jdbc\jdbcroutetest.java
and it contains code that sends a message "manually" to a queue with
jdbc route and the the code extracts "out" message from exchange. I'm
scratching my head how to hook it up to the camel (not junit)
scenario.

Vadim.