Hey Claus, Ashwin,
I haven't got any access to my development environment right now. But i can
tell you by memory that the topic is not durable and the durable topic name
and client id is not set.
Also Ashwin regarding the test; based on what i observed when looking at the
runtime route attribute
Ahswin excellent answer.
Do you mind creating a FAQ entry at the Camel site?
On Thu, Jul 7, 2011 at 8:17 PM, Ashwin Karpe wrote:
> Hi,
>
> You can raise it to any level if transactions are not involved. The main
> purpose of the cache is not to recycle connections, sessions or consumers
> and h
Hi,
I need to deploy the TCP proxy(*camel-example-tcpipproxy*) into servicemix.
*camel-example-tcpipproxy* is
in：https://github.com/scranton/camel-example-tcpipproxy
Could you tell me how to do that in details ?
Just like the picture shows below.
http://camel.465427.n5.nabble.com/file/n4563583
Hi, Claus.
I need to deploy the TCP proxy(camel-example-tcpipproxy) into servicemix.
Could you tell me how to do that in details ?
Thank you, sincerely.
Doraemon
--
View this message in context:
http://camel.465427.n5.nabble.com/tcp-proxy-route-tp4332461p4563560.html
Sent from the Camel -
Now I must deploy this TCP proxy(camel-example-tcpipproxy) into servicemix,
as the picture shows below.
Could you tell me how to do that in details ?
http://camel.465427.n5.nabble.com/file/n4563555/Untitled.png
Thank you, sincerely.
Best wishes.
Doraemon
--
View this message in context:
h
Current CXF know nothing about the CXF.
If you want to put the Camel Exchange into the CXF invocation-context,
you may need to do some modification in the DefaultCxfBinding.
On Fri Jul 8 13:50:39 2011, Jim Talbut wrote:
Hi,
I want to log the "on the wire" data seen by CXF, which I can do wit
Can you not ask the same question across the topics ?
It's very annoying and can't help you to get the answer more quickly.
Please be patient.
--
View this message in context:
http://camel.465427.n5.nabble.com/ServiceMix-4-3-1-and-Camel-2-8-SNAPSHOT-tp4553864p4563603.html
Sent from the Camel -
Hi,
As you're talking about web service invocation, your requirement
sounds really like the callback usecase in cxf.
You may need take a look at the callback simple shipped with cxf kit.
Freeman
On 2011-7-8, at 下午1:49, ychawla wrote:
Hello All,
I have two one-way asynchronous web services.
What kind of error did you get?
Can you show us your stack trace?
BTW, there is an partical Class example that you may want to take a look.
http://example.camel.org/apache}po"; />
On 7/8/11 10:58 AM, whofeih wrote:
Can anyone help me? I can't seem to make partialClass to work. My class
doesn'
Hi,
I want to log the "on the wire" data seen by CXF, which I can do with a
CXF interceptor, but I want to be able to correlate that log with the
state of the Camel Exchange at that point.
What I really want is a cross between a CXF interceptor and a Camel
TraceEventHandler, but that's not pos
Hello All,
I have two one-way asynchronous web services. The first receives a request
asynchronously. It processes it and then turns around sends a response to
the second service. Both of these services will respond to any successful
invocation with an HTTP 200 or 202 status and I am using a WS
I just created a JIRA[1] and verified this issue is fixed in CAMEL
2.8-SNAPSHOT.
[1]https://issues.apache.org/jira/browse/CAMEL-4190
On 7/8/11 8:53 AM, Willem Jiang wrote:
Can you try the latest Camel 2.8-SNAPSHOT? As the CxfSpringEndpointBean
was removed, you should not got the error before.
Can anyone help me? I can't seem to make partialClass to work. My class
doesn't have @XMLRootElement that's why i decided to give partialClass a
try, but still no luck with .marshall(jaxbDataFormat)
below is my code.
JaxbDataFormat dataFormat = new JaxbDataFormat(true);
dataFormat.setCont
Anyone who can help with this one? below is my code. thanks!
private static final String CONVERSION_ENDPOINT =
"seda:CONVERSION_ENDPOINT";
@Override
public void configure() throws Exception {
JaxbDataFormat dataFormat = new JaxbDataFormat(true);
dataFormat.setContextPath(
I'm using Camel 2.7.1 on top of ActiveMQ 5.5.0. For some reason, when I
specify a custom replyTo destination on the endpoint url, the time it
takes for the producer to receive a reply increases drastically. The
curious thing is that the time to receive a reply is almost exactly 1
second. W
http://localhost:8080/aml/AmlService?wsdl is the WSDL which is generated
from your service.
You still need to open the WSDL file to find out the service name and
the port name.
BTW, can I have a look of URI of you CXF endpoint?
Maybe it shows something we are just missing.
On 7/7/11 10:56 PM
Can you try the latest Camel 2.8-SNAPSHOT? As the CxfSpringEndpointBean
was removed, you should not got the error before.
On 7/8/11 1:31 AM, alberto.zigoni wrote:
I am using camel 2.6.0 and have configured a cxf endpoint like this:
http://localhost:9090/my/mockServices";
wsdlUR
OK!
I have tried again and achieved it.I am very excited.oh yeah..
Thank you for your great help, Ashwin.
Could you tell me your msn or email ?
Best wishes.^_^
Doraemon
--
View this message in context:
http://camel.465427.n5.nabble.com/tcp-proxy-route-tp4332461p4562182.html
Sent from the C
"*In command window 2: run the following command
> mvn camel:run *"
I have tried the 3 steps, but in the second step, it built error. So I
failed to run my example.
Could you give me some solutions ?
http://camel.465427.n5.nabble.com/file/n4562015/camel01.png
http://camel.465427.n5.nabble.com
Ah, ok.. This one is not too bad. You just need to edit your pm.xml and add
the following set of dependencies under the tag
org.slf4j
slf4j-api
1.5.11
org.slf4j
slf4j-log4j12
1.5.11
Then run "mvn clean" followed by "mvn camel:run"...
Cheer
Hi,
Running it in Servicemix is a little more involved and it seems like you
have not played with it much.
For now, if all you are looking to do is run it, you should open 3 command
windows
In command window 3 : run your server
> java TCPServer
In command window 2: run the following comman
Hi,
Running it in Servicemix is a little more involved and it seems like you
have not played with it much.
For now, if all you are looking to do is run it, you should open 3 command
windows
In command window 3 : run your server
> java TCPServer
In command window 2: run the following comman
It's very kind of you. Thank you for your patient explanation. ^_^
I tried Scott Cranton's camel-example-tcpipproxy, but it built error and
failed to run.
I ran camel-example-tcpipproxy in steps below:
First, run *mvn camel:run* in camel-example-tcpipproxy root directory.
Second, copy *.zip
Hi,
You can raise it to any level if transactions are not involved. The main
purpose of the cache is not to recycle connections, sessions or consumers
and has nothing to do with transactions.
There was a bug in the JMSSpringTemplate which caused connection and session
objects to be recycled pos i
Hi,
You can use the Camel context as is. The only thing I see changing is the
TCPServer port which should be set to 7890. The camel route is a TCP proxy
which sets up a message consumer and listens for a client request on port
6789 and when it receives a message from the TCPCLient, it logs the mes
Hi Willem,
yes, I double checked.
Got this also from the generated code:
package com.mycomp.aml;
import...
@WebServiceClient(name = "AmlService",
wsdlLocation =
"http://localhost:8080/aml/AmlService?wsdl";,
targetNamespace = "http://aml.mycomp.com/";)
publ
Thanks for posting your code, Ashwin. Newbies like me find it really useful.
But I have some questions.
1.
what *7890* port is uesd to ?
what need I do is just change the code
*...*, is all right ？
need I change my tcp client code or tcp server code ?
2.
After I change the code *...*,
I am using camel 2.6.0 and have configured a cxf endpoint like this:
http://localhost:9090/my/mockServices";
wsdlURL="classpath:wsdl/my.wsdl"
serviceClass="com.acme.BusinessServicePort"
serviceName="my:BusinessService"
endpointName="my:Di
Alright, I coded a simple solution basically using a bounded LinkedList as an
LRU cache for filtering already processed message IDs on the callback.
This is not the most efficient approach (overhead piping payload through
Spring/Camel, before reaching my filtering logic & potential for contention
Yes, I have read and understand that JavaDoc entry. It says it MAY be
possible to raise the cache level when not explicitly doing XA
transactions on JBoss 4. I'm asking what is the safe level to raise
it to when doing Locally managed (non-XA) transactions when working
with the ActiveMQComponent.
Thanks Claus -
In the meantime, do you have an opinion how to work around it? I see two
options (a) go via concurrentConsumers and somehow filter duplicate messages
or (b) hand the payload off to a custom async worker thread pool. (a) seems
to be quicker to do but not so sure about the overhead o
Claus to the rescue ;)
While waiting for the fix Enalposi maybe you can try a slightly uglier
wiretap to do the processing or something similar.
This will keep the request/response cycle theoretically low.
On Thu, Jul 7, 2011 at 11:10 AM, Claus Ibsen wrote:
> The JmsConsumer will wait for the Ex
Hi,
Please check out the following link...
http://static.springsource.org/spring/docs/2.0.x/api/org/springframework/jms/listener/DefaultMessageListenerContainer.html#setCacheLevel(int)
http://static.springsource.org/spring/docs/2.0.x/api/org/springframework/jms/listener/DefaultMessageListenerCont
Hi,
Did you see the camel route posted by Scott... socat is used just to see
what is happening with messages on the route and between the endpoints.
In your case, this is what you will need to do
http://camel.apache.org/schema/spring";
id="camelContext">
The JmsConsumer will wait for the Exchange to complete.
There is a ticket to improve this by supporting the async routing
engine on the consumer level for InOnly JMS consumers.
https://issues.apache.org/jira/browse/CAMEL-3632
On Thu, Jul 7, 2011 at 6:01 PM, enalposi wrote:
> Hi Tim -
>
> Using C
Hi,
Can you please remove "src/main/resources/" from the wsdlURL and change it
to "wsdl/AmlService.wsdl". See example below...
BTW, I am assuming you have a wsdl directory under src/main/resources. The
directory src/main/resources is already on your classloader classpath if
this is a maven deploy
Hi Tim -
Using Camel 2.7.2.
I actually had the ExchangePattern before threads() originally - the above
is just one permutation of several I tried (just moved it back - same
result).
Yes, I guess it should block if the 'consumer'/publisher is expecting a
response. But it's using OutOnly ExchangePa
Hi Daniel,
I am finding it hard to see an issue when I run the following test. While I
am not using JMS, I do have the same consumer setup under a different
routeId. I find that following a run of this test that routeId "bar" is
still up and running.
The line assertNull(context.getRouteStatus("ba
On Thu, Jul 7, 2011 at 2:56 PM, Daniel Spaven wrote:
> Hey chaps,
>
> Just had another look at this and made some progress.
>
> Now my routes were from JMS to JMS and not with two inputs.
>
> However that did get me thinking because I was testing CBR routes consuming
> from the same JMS topic. Whe
Ok. The behavior you are seeing makes sense to me if the consumer is waiting
for a 'response'.
I haven't looked at the code but there could be several reasons for this in
my mind.
1. Can you check the ack mode that you have on the topic?
2. Can you move the setting of the exchange pattern up to bef
Hi Daniel,
Thanks for the input. Will check this out. Stay tuned.
Cheers,
Ashwin...
-
-
Ashwin Karpe
Apache Camel Committer & Sr Principal Consultant
FUSESource (a Progress Software Corporation subsidiary)
http://fusesource.com
Blog:
I sometimes use AMQ for isolated local testing but our production transport
is Tibco EMS.
But in any case, the Camel approach to multi-threading doesn't seem to be
working as expected, so I am not quite ready to make changes to the
underlying configuration. I could probably also set up a single li
FO | bus.bao.EsbSampleStandalonePublisherImpl |
send | Thread-17| Sent [20110707
09:03:08:335]: SampleDtoImpl[data_13;thread=Thread-17]
2011-07-07 09:03:08,335|INFO | bus.bao.EsbSampleStandalonePublisherImpl |
send | Thread-6 | Sent [20110707
0
Hey Tim.
Sorry, I have everything parameterized and missed a few values. The
ExchangePattern is InOnly (system exposes same behavior for OutOnly for what
it's worth...). sleepTime is constant 1000 in this case - you see nicely in
the log how threads have a 1sec gap between ''start' and 'end' log a
} catch (InterruptedException e) {
>e.printStackTrace();
>}
>}
>log.info(String.format("Received(<-|) [%1$s/%2$s]: %3$s",
> df.format(new Date()), beanName_, _msg));
>}
>
> Something in the Camel libs see
The JIRA is
https://issues.apache.org/jira/browse/CAMEL-4184
And I am currently testing a possible fix. Keep an eye on the JIRA
ticket for updates.
And when/if a commit with a fix is committed then please give a test
on your system with the latest source code.
On Thu, Jul 7, 2011 at 12:27 PM, Cla
Hi,
Can you double check your WSDL definition to make sure the service name
is right?
On 7/7/11 10:01 PM, kmoens wrote:
Hi,
I am playing around to invoke an external webservice from Camel 2.6.
With Java DSL this works fine, but I struggle with the Spring DSL using
cxf:bean
/Failed to creat
Yes, I have tried that.
But Scott Cranton uses *socat* as both the back-end service (echo style) and
as a client.
I use *two java classes* as client and server.
I have no idea how to invoke camel-example-tcpipproxy with my own client and
server.
Can you tell me ?
Thank you !
--
View this messag
Hi,
I am playing around to invoke an external webservice from Camel 2.6.
With Java DSL this works fine, but I struggle with the Spring DSL using
cxf:bean
/Failed to create Producer for endpoint: Endpoint[cxf://bean:amlEndpoint].
Reason: org.apache.cxf.service.factory.ServiceConstructionException
Hi
Yeah we should have fixed/improved that in Camel 2.7 onwards. If you
check the release notes there is some tidbits about this
http://camel.apache.org/camel-270-release.html
On Thu, Jul 7, 2011 at 3:36 PM, tnk wrote:
> Hi,
>
> I have two bundles (in servicemix) using camel quartz.
> The first
Hi,
I have two bundles (in servicemix) using camel quartz.
The first one has route trigerred by quartz
from("quartz://MyTimer...).to(uri).
And the second bundle has route, which uses
org.apache.camel.routepolicy.quartz.CronScheduledRoutePolicy with
routeStartTime and routeStop time.
I noti
eStandalonePublisherImpl |
send | Thread-17| Sent [20110707
09:03:08:335]: SampleDtoImpl[data_13;thread=Thread-17]
2011-07-07 09:03:08,335|INFO | bus.bao.EsbSampleStandalonePublisherImpl |
send | Thread-6 | Sent [20110707
09:03:08:335]: SampleD
Hey chaps,
Just had another look at this and made some progress.
Now my routes were from JMS to JMS and not with two inputs.
However that did get me thinking because I was testing CBR routes consuming
from the same JMS topic. When CBR routes are consuming off different topics
it works fine. Here
On Thu, Jul 7, 2011 at 11:36 AM, Claus Ibsen wrote:
> Hi
>
> Yeah you need a custom codec if you want to handle this properly.
>
> On Thu, Jul 7, 2011 at 11:29 AM, Sushmita chandra
> wrote:
>> I am trying to send an XML message to a MINA endpoint and read it back from
>> there and do some process
Hi there,
I guess thats more a MINA question. But see here:
http://mina.apache.org/tutorial-on-protocolcodecfilter-for-mina-2x.html
http://mina.apache.org/codec-repository.html
Bye,
Norman
Am 07.07.2011 14:21, schrieb Sushmita chandra:
I am new to camel, can you please suggest me a good tutor
I am new to camel, can you please suggest me a good tutorial on how to write
a custom codec?
--
View this message in context:
http://camel.465427.n5.nabble.com/What-codec-do-we-need-to-use-for-sending-an-XML-message-to-a-MINA-endpoint-tp4560464p4560874.html
Sent from the Camel - Users mailing lis
Hi
I have reproduced the issue. The problem is when you use context
scoped onException.
If you define the onException on each route, then it works.
I will log a JIRA and see what can be done.
On Fri, Jul 1, 2011 at 10:13 AM, woggle23 wrote:
> Hi Claus
>
> I tried moving the adviceWith() to th
that didn't work :(
Camel is instantiating the Processor bean independently of the
FileSystemXmlApplicationContext given to it in:
protected AbstractXmlApplicationContext createApplicationContext()
camel creates a new instance of the Processor on each call to sendBody
Alistair
--
mov eax,1
Did you have a chance to try this[1] as Claus suggested before.
[1]http://scottcranton.blogspot.com/2011/04/socat-is-so-cool.html
On 7/7/11 4:56 PM, Doraemon wrote:
Hello,
I want to create a Tcp proxy with Camel and deploy this proxy into
ServiceMix.
http://camel.465427.n5.nabble.com/file/n4560
Ah okay so you use the prototype scope of spring XML.
Well the lookup the processor once when the route
is initialized.
You may want to use the Camel bean component and disable its cache
http://camel.apache.org/bean
Try something like this
On Thu, Jul 7, 2011 at 11:43 AM, Alistair Young
wr
yes, i do or shouldnt i do that ??
(context:i´m trying to use the topic as a many/many thing..., where
producers send and one consumer responds and a other just listens, which
should as close as possible to JMS (thats why i dont use a wiretap))
--
View this message in context:
http://camel.46542
sorry if I'm fuddling about too much. Perhaps if I rephrase:
How would I change the config of a Processor at run time in a test?
protected AbstractXmlApplicationContext createApplicationContext() {
...
TestProcessor testProcessor = (TestBean)c
you may use the jetty http-component instead of mina
eg.
from("jetty:http://0.0.0.0/transformxml";).transform().setBody("");
Am 07.07.2011 11:29, schrieb Sushmita chandra:
I am trying to send an XML message to a MINA endpoint and read it back from
there and do some processing.But I am not able
Hi
Yeah you need a custom codec if you want to handle this properly.
On Thu, Jul 7, 2011 at 11:29 AM, Sushmita chandra
wrote:
> I am trying to send an XML message to a MINA endpoint and read it back from
> there and do some processing.But I am not able to get the proper XML back.
> I tried to us
I am trying to send an XML message to a MINA endpoint and read it back from
there and do some processing.But I am not able to get the proper XML back.
I tried to use the following syntax:
1 from("mina:tcp://0.0.0.0:9091?sync=true") --->We get an exception where
the datalength= 1010792557 is ret
Hello,
I want to create a Tcp proxy with Camel and deploy this proxy into
ServiceMix.
http://camel.465427.n5.nabble.com/file/n4560390/Untitled.png
Let the Tcp Client invoke Servicemix(Tcp Proxy), and ServiceMix(Tcp Proxy)
can route the message to Tcp Server.
Now I have completed the Tcp client and
Thanks for the reply Ashwin,
I've read the Websphere docs and its pretty much a simple case of checking
the checkbox 'Support distributed two-phase commit protocol' to enable
XA-transactions. This is what we have. Our existing software which doesnt
use camel or spring and uses EJB's works fine wit
Hello,
I want to create a Tcp proxy with Camel and deploy this proxy into
ServiceMix.
http://camel.465427.n5.nabble.com/file/n4560386/Untitled.png
Let the Tcp Client invoke Servicemix(Tcp Proxy), and ServiceMix(Tcp Proxy)
can route the message to Tcp Server.
Now I have completed the Tcp client and
On Thu, Jul 7, 2011 at 10:05 AM, Jim Talbut wrote:
> Hi,
>
> In the claim check example (http://camel.apache.org/claim-check.html) the
> 'unwanted' information is placed in persistent storage and a tag is added to
> the exchange.
> What are the merits of doing this as opposed to simply storing the
On Thu, Jul 7, 2011 at 10:15 AM, Andrè wrote:
> thx, claus
> but thats not the point, ... why is it on the wire ? , it´s the product of
> an unmarshalling and directly inserted in an drools endpoints (see route),
> so it shouldnt be there, am i right ?
>
You get the exception on broker A when you
Thanks for reporting it.
On Thu Jul 7 14:19:25 2011, vssundar wrote:
We investigate further and found that when the splitter returns 0 results the
route seems to hang and this was on Camel 2.5. We tried upgrading to Camel
2.7.1 and that seems to fix the problem.
--
View this message in context
thx, claus
but thats not the point, ... why is it on the wire ? , it´s the product of
an unmarshalling and directly inserted in an drools endpoints (see route),
so it shouldnt be there, am i right ?
--
View this message in context:
http://camel.465427.n5.nabble.com/Failed-to-build-body-from-cont
Hi,
In the claim check example (http://camel.apache.org/claim-check.html)
the 'unwanted' information is placed in persistent storage and a tag is
added to the exchange.
What are the merits of doing this as opposed to simply storing the
information in the exchange?
i.e.:
exchange.setProperty(
73 matches
Mail list logo
