Hi,
Does the Camel RabbitMQ component handle blocked connection notifications
when publishing messages? I have been unable to find anything in the
documentation or in this list to say whether it does or does not.
This is what I'm talking about when i say blocked connection notifications:
https:/
no, this does not help :(
when i debug, interestingly i can see onConsume gets exhange's body as the
output of bean bound on from("direct:generateLine"...) route which is
LineGenerator..
from("sql:select rowid vrowid from myTable where nstatus = 0?outputClass=" +
MyBean.class.getName()
On 07/04/2016 06:12, Claus Ibsen wrote:
Hi
Ah can you log that in the JIRA
Done: https://issues.apache.org/jira/browse/CAMEL-9828
Ah yeah that is intended. The onConsume runs after the exchange is
complete. So you need to store the id somewhere in a header or
something if you modify the message body.
.setHeader("rowId").simple("${body.vrow_id}")
.threads...
And then use the header in the onConsume
On Thu, Apr 7, 2016 at
Hi, to coplete the information set I sent,
this is the config of hotrod-client.properties
infinispan.client.hotrod.transport_factory =
org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory
infinispan.client.hotrod.server_list = 10.0.0.77:11222
infinispan.client.hotrod.marshaller =
or
I'm trying to receive a JMS message and send it to a MQ queue, keeping
headers on the message.
But headers are sent when using targetClient=1.
So when using the following, no headers are sent.
from("*wmq:queue:A0*").log("${headers}");
template.sendBodyAndHeader("*wmq:queue:A0*", "body", "h1", "hea
Hmm.. I think i misunderstood the route conceptually.
What i thought was that below is a single route;
from("sql:select rowid vrowid from myTable where nstatus = 0?outputClass=" +
MyBean.class.getName()
+ "&onConsume=update myTable set nstatus = 1 where rowid =
:#${body.getVrowid
The onConsume is run when the exchange is complete at the end,
whatever that means routing over threads and whatnot.
If you want to break up your route into 2 lets, then consider using
wire-tap to fork of a separeted copy that is indepdenent.
On Thu, Apr 7, 2016 at 12:12 PM, onders wrote:
> Hm
targetClient=1 means there are no headers except the standard properties
from the MQMD header on the message. You can not send custom headers that
way.
And specifying the targetClient does not have any effect whatsoever when
reading messages from a queue.
Regards,
Jens
Von:blommis
An:
thanks for the guidance.
--
View this message in context:
http://camel.465427.n5.nabble.com/DefaultSqlPrepareStatementStrategy-lookupParameter-when-onConsume-used-in-SQL-component-tp5780437p5780671.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hello,
how to force my route to ISOLATING her headers?
I have this flow:
route A1
- set CamelSqlQuery
route A2
- set CamelSqlQuery
route B
- execute sql based on CamelSqlQuery header
Interceptor
- execute more sql to check permission using own CamelSqlQuery header
- remove CamelSqlQuery
Hi,
I’m working on a subject “Using Cache with Apache Camel and How to treat
large file”.
The purpose is to treat large file with camel without loading the file into
memory because it’s a huge file over 5 GO.
We found several tracks, the first track is to use the splitter component,
to allow us
Hi everyone,
I use ActiveMQ Component for my use case that foresee:
1. Read file from folder wich main cotain large number of line
2. Split with stream, Process each line and then store it in Active MQ
3. Consumers recieves messages from queue and then to invoke a Rest Service.
I defined a Poole
Sorry, I have only generic ideas:
Have you tried the „normal/non-spring“ ldap-component?
Have you tried to set Debug to TRACE?
Cheers, Thomas.
> Am 06.04.2016 um 07:06 schrieb Claus Ibsen :
>
> That is an old Camel version. You can try using a newer version.
>
> On Tue, Apr 5, 2016 at 4:46 PM,
I got it to work without blueprint (in java). Blueprint wiring was a bit too
complex for me. If anyone has a working example I will gladly add it to the
docs.
Should we add those elements to the xsd?
Cheers, Thomas.
> Am 05.04.2016 um 16:36 schrieb Quinn Stevenson :
>
> I learned something ne
Yeah and also dig up that source code line number where the NPE is to
maybe try to know what is null and maybe try to reason why it may be
null. Maybe some of that spring ldap template lookup stuff is not
correct
On Thu, Apr 7, 2016 at 4:20 PM, Walzer, Thomas
wrote:
> Sorry, I have only generic i
If you can share your Java configuration, I’ll see if I can convert it to
Blueprint.
As far as the XSD change - I can’t answer that one for certain, but I’d guess
the answer is no. Looking at the other definitions in the XSD, the attributes
appear to be primitive types (String, boolean, etc).
Your consuming route only defines one consumer (i.e. concurrentConsumers is not
set, so it defaults to 1). Try increasing that.
> On Apr 7, 2016, at 7:10 AM, Michele wrote:
>
> Hi everyone,
>
> I use ActiveMQ Component for my use case that foresee:
>
> 1. Read file from folder wich main co
The online xsd schemas are not always 100% up to date with the latest
release. The xsd's are in the JARs which your IDE and also the xml
parser should use at runtime. Should not rely on internet to an ASF
website.
On Mon, Apr 4, 2016 at 10:19 AM, Walzer, Thomas
wrote:
> Hi,
>
> is it possible tha
Hello,
I had recently have to move from using Jetty component on the producer side
to using Camel Http4 component, here is an example:
http://0.0.0.0:{{port}}/bridgeWithJetty?matchOnUriPrefix=true"; />
...
https://{{host}}/{{ctxPath}}/?bridgeEndpoint=true"; />
http://0.0.0.0:{{port}}/
In your new route you have skipDuplicate="false" so it won't block any
message
--
View this message in context:
http://camel.465427.n5.nabble.com/infinispan-Idempotent-and-RemoteCacheManager-tp5780600p5780705.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hi All,
I have the below scenario and from this I am not able to return a custom
response. Before I brief about the trouble I am facing, Below are the
details:
1) Apache Camel Version -2.16
2) Java version - 1.7
3) Server- Jetty Plugin of Maven
4) Using Apache camel CXF component.
I am having t
Hi all,
What is the current best practice for referencing JNDI inside your XML Camel
Route?
@Bean(name = "fileOutputDirectory")
@Scope(BeanDefinition.SCOPE_SINGLETON)
public String fileOutputDirectory() {
return simpleJndiBeanFactory().getBean("fileOutputDirectory",
String.class);
Hi Stevenson,
I configured component activemq using Pooled Connection Factory.
So, PooledConnection Factory regarded only Producer?
I try to add a concurrentConsumers as option...
Thank you so much
Regards
Michele
--
View this message in context:
http://camel.465427.n5.nabble.com/Unders
Hi Team,
Jboss Fuse Studio : Version: 8.1.0.GA
Jdk version: 1.8.0_73
Using XML DSL
Scenario:
Webservice SOAP response is received in multiparts as below:
response : --=_Part_4706_434840889.1459343688908
Content-Type: application/xop+xml;charset=UTF-8;type="text/xml"
Content-Transfer-Encoding:
The pooled connection factory is a good idea, and it can be used by both the
producer and consumer - but the connection factory doesn’t determine the number
of concurrent consumers.
> On Apr 7, 2016, at 10:04 AM, Michele
> wrote:
>
> Hi Stevenson,
>
> I configured component activemq using Po
Claus,
Please forgive all the @ in here as that was the only way I could post this
to get around the spam filter.
Just to get this working for me so I can start refactoring my code to accept
and process individual items from the unmarshaling of the multi-line beanio
beans I hacked this bit of code
Hi guys,
I have question related to the best way to connect to ActiveMQ from a
consumer and a producer. So does the way to connect to ActiveMQ from a
consumer and a producer have to be the same? that is, using caching in both
sides, connection pooling, max number of connections...etc
My current c
I’ve investigated this further and the exception is thrown from the
ZooKeeper.create method. Camel is actually trying to create a znode with a path
/regexTest1/192.168.202.25-25829641-de1f-4389-9bb6-2967ea60de1a without
creating the parent node /regexTest1 first.
According to the Zookeeper.cre
Just started observing that when there is JGroups route, the other routes
doesn't seem to start, specifically on the node which is designated as
master/coordinator
Any clue ?
--
View this message in context:
http://camel.465427.n5.nabble.com/JGroups-and-other-routes-tp5780715.html
Sent from t
Hi,
I have a problem using a seda queue when propagating an exception to a
caller route using errorHandler(noErrorHandler()).
What I want to achieve is to wait for a response message and sending an
exception to a caller route outside a camel context component, if no
response received within
Hi,
Which camel version are you using? MIME-Multipart is only available starting
Camel 2.17.0.
I am not 100% sure, but your response looks somewhat like SOAP with attachments
or MTOM. If you are using some kind of Camel-CXF endpoint for receiving it, the
endpoint might parse it for you.
Best
Sorry, was a typo.
On the new route obviously I've removed the attribute skipDuplicate...
But idempotent continues doesn't working
help me please
Thanks
Mirko
--
View this message in context:
http://camel.465427.n5.nabble.com/infinispan-Idempotent-and-RemoteCacheManager-tp5780600p5780723.htm
33 matches
Mail list logo
