camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vadim Chekan" <kot.bege...@gmail.com>
Subject Re: MS SQL Message Service endpoint
Date Wed, 09 Jul 2008 00:51:47 GMT
Never mind. "pipeline" is the answer to my question.

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")).
pipeline("jdbc:msServiceBroker").
to("activemq:vadim33");

On Tue, Jul 8, 2008 at 12:45 PM, Vadim Chekan <kot.begemot@gmail.com> wrote:
> 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.
>



-- 
>From RFC 2631: In ASN.1, EXPLICIT tagging is implicit unless IMPLICIT
is explicitly specified

Mime
View raw message