Hi,
It looks more like Activemq issue instead of camel-jms issue.
Did you try to ask the question in the activemq user mailing list?
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspot.com (htt
Hi,
I just did some test, the below route should work
from("direct:json").unmarshal().json(JsonLibrary.Gson)
from("direct:json").unmarshal().json(JsonLibrary.Gson, Map.class)
It looks you need to enable the StreamCache[1] as the input stream is consumed.
[1]http://camel.apache.org/stream-cachi
Hello All,
I am using Apache ActiveMQ distributed queues, on executing
endPoint.getExchanges(), I am actually getting messages from a random broker
where camel is connected now.
JmsQueueEndpoint endPoint = camelContext.getEndpoint(toDestination,
JmsQueueEndpoint.class);
endPoint.getExchanges();
We have an Activemq Cluster of 3 brokers (Master - Master, multicast) with 2
networkConnectors (for each broker with duplex turned on) with one connector
for queues with conduitSubscriptions as false and the other connector for
topics with conduitSubscriptions as true. Activemq version is 5.6 and C
Hi Raul,
can you please provide your inputs on the below piece of code.
This method the uses the producer template asyncCallback to call the
commonRoute.and i used the future handle to get the response.
public void getDataUsingProducerTemplate(Exchange exchange) throws
TimeoutException, Inter
Sorry, just forgot to say that I'm using camel 2.10.1 in this example.
On Fri, Oct 26, 2012 at 3:01 PM, Maxime Tremblay wrote:
> Hi All,
>
> I just have to switch to camel-http4 for some request proxying whit
> bridgeEnpoint=true.
>
> Now I have the problem that the Host header is not set correc
Hi All,
I just have to switch to camel-http4 for some request proxying whit
bridgeEnpoint=true.
Now I have the problem that the Host header is not set correctly in the
HTTP request.
The original Host is put instead of the target Host.
Everything was working fine with camel-http.
And I cannot fin
Hi
You should enable stream caching[1] if you want to read a stream more than once.
[1] http://camel.apache.org/stream-caching.html
Taariq
On 26 Oct 2012, at 18:34, clakech wrote:
> I find an answer to my question:
>
> to("http4://sample").convertBodyTo(String.class) WORKS FINE
>
> to("http4:
Hi,
I am trying to call a remote http service to retrieve a message using http4
component.
I would like to understand the sentence from the http4 component web page
http://camel.apache.org/http4.html
"Camel will store the HTTP response from the external server on the OUT
body. All headers from t
Hi,
Thank you for answering my question:
@Willem: As I explained I my mail, I know that I can do this with a
processor or a bean bu I would like to be able to do it with the json
component.
@Marco: I already try the json component but I get an error when using:
unmarshal().json()...
or
unmarsha
Hi,
there is a json data type you can use for un/marshalling.
have a look here:
http://camel.apache.org/json.html
regards, Marco
Am 26.10.2012 11:51, schrieb clakech:
Hi,
I would like to unmarshal a Json to a Map/List of Strings (eg Map>...)
Here is my input:
{"pointsOfSale":
{"pointOfSale
You can add Processor[1] or bean method[2] to do the job here.
[1]http://camel.apache.org/processor.html
[2]http://camel.apache.org/bean.html
--
Willem Jiang
Red Hat, Inc.
FuseSource is now part of Red Hat
Web: http://www.fusesource.com | http://www.redhat.com
Blog: http://willemjiang.blogspo
Hi,
after taking a closer look on how a bundle update in Karaf does work
and how Camel handles the camel contexts I found the reason
for why my update of the bundle containing the route didn't work :-)
Some details on this "issue"
at first my route didn't contain the needed localWorkDirectory att
Hi Ravi,
You should use set timeouts on the outgoing CXF invocations, where the sum
of the CXF timeouts is a tad lower than the timeout you set on the SEDA
call to commonRoute. I call this the "cascading timeouts" pattern.
So if timeout(webservice1) + timeout(webservice2) + timeout(webservice3) =
Hello,
I'm trying to connect to an FTPS server with explicit TLS. I created a jks
(keytool -genkey -alias signFiles -keystore theStingKeyStore.jks) and I
configured my uri as following:
from("ftps://esb...@myftpesserver.com/test?delay=3&fileName=sites.xml&ftpClient.keyStore.file=%2FmyKeyStore.
Hi Dan,
did you have any progress with this CloudWatch component?
At this moment such a component would be very useful for me :)
Cheers
Bilgin
On 20 March 2012 23:54, dacc wrote:
> Hello All,
>
> I'm considering adding a CloudWatch capability to the AWS component. Does
> this sound useful a
Hi:
Thanks for your quick reply, I have fired a bug
https://issues.apache.org/jira/browse/CAMEL-5746 .
And one more question:
The maven dependencies of camel-saxon were changed from 2.9.3 to 2.10.2 ,
and on 2.10.0, the dependencies are:
net.sf.saxon
saxon9he
But unfo
On Fri, Oct 26, 2012 at 10:36 AM, liugang wrote:
> Hi All:
>
> I found the wiretap will always copy the original exchange message after
> deprecated those methods like " wireTap(String uri, boolean copy, Expression
> body) " and " wireTap(String uri, boolean copy, Processor processor)" .
>
> Check
Hi All:
I found the wiretap will always copy the original exchange message after
deprecated those methods like " wireTap(String uri, boolean copy, Expression
body) " and " wireTap(String uri, boolean copy, Processor processor)" .
Checked the source code of org.apache.camel.model.WireTapDefinition
it contains javax.jms because the jar contains the SPEC - the JMS API.
Then you add vendor jars to provide the connection factory implementations etc.
2012/10/26 Caa_man :
> Jens is right!
> I studied all dependencies which were loaded with ActiveMQ. One of
> dependencies is geronimo-jms_1.1_spec.
On Fri, Oct 26, 2012 at 9:57 AM, Martin Stiborský
wrote:
> :D now it's working, I don't know what changed…
>
> Crazy, I need a break I guess…
>
Did you restart the server. You use Karaf I can see and sometimes
restarting it "fixes" weird issues.
> On Tue, Oct 23, 2012 at 7:22 PM, Martin Stibors
On Fri, Oct 26, 2012 at 9:38 AM, Zhemzhitsky Sergey
wrote:
> Hello guys,
>
> One more question,
>
> What is the reason to allow DefaultEndpoint.isSingleton() and
> DefaultProducer.isSingleton() return false as it prevents caching of these
> objects and new instances of endpoints and producers wi
:D now it's working, I don't know what changed…
Crazy, I need a break I guess…
On Tue, Oct 23, 2012 at 7:22 PM, Martin Stiborský
wrote:
> Hello,
>
> On Mon, Oct 22, 2012 at 9:18 PM, Hilde wrote:
>> Hello,
>>
>> why do you incorporate
>>
>> log4j.logger.org.springframework= ...
>>
>> instead of
Hello guys,
One more question,
What is the reason to allow DefaultEndpoint.isSingleton() and
DefaultProducer.isSingleton() return false as it prevents caching of these
objects and new instances of endpoints and producers will be created on each
lookup?
Best Regards,
Sergey
-Original M
Jens is right!
I studied all dependencies which were loaded with ActiveMQ. One of
dependencies is geronimo-jms_1.1_spec. This jar has javax.jms packages (WHY
THE HELL???). As a result I removed geronimo jars from compiled archive and
this change yielded application deployment to be Ok.
25 matches
Mail list logo
