SQS - possible thread handling confusion with transactions

2020-03-30 Thread James Green
Hi, I am looking at Spring Boot app that has been extended to include an @SqsListener that uses ProducerTemplate to forward messages into a Camel route. An integration test was hooked up with ElasticMQ and all _appears_ correct except assertions that the database records are correct - they in

Spring Boot Testing & @DirtiesContext

2018-08-09 Thread James Green
I have an itch to scratch. Why does my test class require @DirtiesContext to avoid a stack trace telling me that ActiveMQ was never started and so it cannot be stopped after my test completes? Context: @RunWith(CamelSpringBootRunner.class) @SpringBootTest @MockEndpoints @DirtiesContext(classMode

Re: Spring Boot 2

2018-03-02 Thread James Green
Bah, 2.22, YKWIM! On 2 March 2018 at 14:43, James Green <james.mk.gr...@gmail.com> wrote: > Thanks for the quick replies - we'll hold fire for 2.21. > > On 2 March 2018 at 14:33, Andrea Cosentino <ancosen1...@yahoo.com> wrote: > >> Actually there is a branch boo

Re: Spring Boot 2

2018-03-02 Thread James Green
; > > > > > On Friday, March 2, 2018, 3:30:50 PM GMT+1, James Green < > james.mk.gr...@gmail.com> wrote: > > > > > > I'm guessing that the current Camel release just won't do... > > Caused by: java.lang.NoClassDefFoundError: > org/springframework

Spring Boot 2

2018-03-02 Thread James Green
I'm guessing that the current Camel release just won't do... Caused by: java.lang.NoClassDefFoundError: org/springframework/boot/bind/RelaxedPropertyResolver at org.apache.camel.spring.boot.security.CamelSSLAutoConfiguration$Condition.getMatchOutcome(CamelSSLAutoConfiguration.java:51) at

Re: Application halts for 30 minutes or until restart

2017-07-31 Thread James Green
We deployed changes Thursday evening that fixed the HTTP endpoint the wiretap sends payloads to, and it's been running without incident since. Feels like something may be wrong with error handling there. On 27 July 2017 at 10:34, James Green <james.mk.gr...@gmail.com> wrote: > I have

Re: Application halts for 30 minutes or until restart

2017-07-27 Thread James Green
f there are any > locking issues. And perhaps increasing the verbosity of the logs can give > you more clues, > > zoran > > On Thu, Jul 27, 2017 at 9:58 AM, James Green <james.mk.gr...@gmail.com> > wrote: > > > This is a Spring Boot 1.3 application that was r

Application halts for 30 minutes or until restart

2017-07-27 Thread James Green
This is a Spring Boot 1.3 application that was recently re-imaged (Docker) and rebooted after several months of loyal service. We are unaware of any major changes beyond going from java:8 to openjdk:8. It receives payloads from ActiveMQ, works against Mongo, and spits out payloads to HTTP and

wiretap + sampler = potentially lost exchanges?

2016-11-09 Thread James Green
The thought occurred to me that I could use a wiretap on a route to send an exchange both to the original destination and to a route that logs what is happening. The "logger" route would start with a sampler to reduce the logging output. However, if the wiretap thread pool is full, wiretap would

Re: Large message handling

2016-11-07 Thread James Green
mel does support > that EIP ( http://camel.apache.org/claim-check.html < > http://camel.apache.org/claim-check.html> ) > > HTH > > > > On Nov 4, 2016, at 8:53 AM, James Green <james.mk.gr...@gmail.com> > wrote: > > > > Hi, > > > > We are preparin

Re: Best way to build a wait/retry loop with Camel?

2016-11-04 Thread James Green
Are you unable to move the messages into a database for "long-term" storage? That's what we do, and we simply scan for messages due to be "re-sent" and re-submit them back into the queue. I do not believe ActiveMQ was really intended to hold many messages for long term storage, hence we use

Large message handling

2016-11-04 Thread James Green
Hi, We are preparing to start handling very large messages. Currently we have small (<1k) messages arriving from message queues and being processed, but these new messages could be several mb each. Each message is basically a JSON formatted payload with metadata and a content-body. It's this

Re: Non-Blocking throttler?

2016-10-26 Thread James Green
an use? > > On Wed, Oct 26, 2016 at 2:28 PM, James Green <james.mk.gr...@gmail.com> > wrote: > > I'm looking at a route that will be exercised in the event of an > emergency > > situation such as "database is down". > > > > Is there a non-bloc

Non-Blocking throttler?

2016-10-26 Thread James Green
I'm looking at a route that will be exercised in the event of an emergency situation such as "database is down". Is there a non-blocking Throttler, one that lets the caller continue AND only samples the Exchanges that arrives? I would like to call a third party if this route is called but they

Re: IDE for newer Camel versions using Camel Spring Boot

2016-10-26 Thread James Green
atest today is 2.3.60 > > > > On Tue, Oct 25, 2016 at 3:29 PM, James Green <james.mk.gr...@gmail.com> > wrote: > > Nice video indeed, however on asking to edit an endpoint in IDEA > 2016.2.5 I > > get "No Facet of type [interface > > org.jboss.forge.ad

Re: IDE for newer Camel versions using Camel Spring Boot

2016-10-25 Thread James Green
Nice video indeed, however on asking to edit an endpoint in IDEA 2016.2.5 I get "No Facet of type [interface org.jboss.forge.addon.projects.facets.WebResourcesFacet] is installed." Not sure I know where this needs to be reported as a bug - is it a JBoss thing, a fabic8 thing, or a Camel thing?

onException documentation error?

2016-08-04 Thread James Green
Referencing http://camel.apache.org/exception-clause.html under "Marking exceptions as handled" is an example "Example using handled" where it is stated: "In this route below we want to do special handling of all OrderFailedException as we want to return a customized response to the caller. First

Re: MockEndpoint header test seems wrong

2016-08-03 Thread James Green
Forget this - finally found a case where the header was being set in a somewhat contrived manner. On 2 August 2016 at 18:02, James Green <james.mk.gr...@gmail.com> wrote: > Hi, > > In my test I have: > > mockEndpoint.allMessages().header("SomeKey").isInstanceOf(Som

MockEndpoint header test seems wrong

2016-08-02 Thread James Green
Hi, In my test I have: mockEndpoint.allMessages().header("SomeKey").isInstanceOf(SomeClazz.class); Which should fail, as the route sets SomeKey as a Property of the Exchange, not a Header. I have scanned the code base several times for SomeKey to be set as a Header but I cannot find such a

description vs routeDescription

2016-05-17 Thread James Green
Hi, Not clear on the difference. It seems at runtime I only get the last one set. Am I expected to use both to serve different purposes? James

Re: ClassNotFoundException ObjectFactory

2016-05-13 Thread James Green
Interestingly we get something similar: 10/May/2016 16:36:54,356 [DEBUG] ObjectHelper: Cannot find class: java.lang.ObjectFactory 10/May/2016 16:36:54,357 [DEBUG] ObjectHelper: Cannot find class: java.lang.ObjectFactory 10/May/2016 16:36:54,357 [DEBUG] ObjectHelper: Cannot find class:

Re: interceptSendToEndpoint

2016-05-12 Thread James Green
You could do it that way and add a second interceptSendToEndpoint intercepting the next hop I guess. You may wish to consider what you are trying to achieve - if you do not require the full payload to be audited it may be that using an HTTP proxy satisfies your requirements and requires very

ActiveMQ Consumer stalled?

2016-04-27 Thread James Green
Got a Message Driven Consumer which the broker shows as connected but after a while it seems to stop accepting new messages. Nothing amiss in the logs, the whole process just appears stalled. I have just obtained a thread dump (see https://gist.github.com/jmkgreen/8c4e399520f731c9175ee1bad969261f

Sub-classing org.apache.camel.spring.javaconfig.Main - bug?

2016-04-04 Thread James Green
Tried writing an Application.java extending org.apache.camel.spring.javaconfig.Main and overriding the public void setBasedPackages(String config) method. My sub-class method does not get called yet the base class version does get called. On inspection, there's a static call to

Re: CamelContext.hasComponent()

2016-03-30 Thread James Green
users, but more for > component developers / camel itself. > > > On Wed, Mar 30, 2016 at 12:00 PM, Claus Ibsen <claus.ib...@gmail.com> > wrote: > > No this is by design > > > > On Wed, Mar 30, 2016 at 11:56 AM, James Green <james.mk.gr...@gmail.com> > wro

CamelContext.hasComponent()

2016-03-30 Thread James Green
I was expecting this to return boolean, but it returns a Component if present or null otherwise. This feels counter-intuitive and horrible to code against. Are there plans to this this? Thanks, James

Multiple interceptors?

2016-02-24 Thread James Green
http://camel.apache.org/intercept.html does not describe the behaviour of having more than one interceptor in use. For example: intercept().to("log:foo"); intercept().to("log:bar"); from("direct:start").to("direct:end"); Do both logging endpoints get triggered? If so, in any particular order?

Re: Use Simple to log Message History?

2016-02-24 Thread James Green
Yeah we switched that on and nothing happened. Must have been us but it seemed pretty simple! On 24 February 2016 at 11:34, Claus Ibsen <claus.ib...@gmail.com> wrote: > You can use the tracer > http://camel.apache.org/tracer > > On Wed, Feb 24, 2016 at 12:12 PM, James

Re: Use Simple to log Message History?

2016-02-24 Thread James Green
f events that > track the details. But the formatting is done elsewhere. > > > > On Wed, Feb 24, 2016 at 10:48 AM, James Green <james.mk.gr...@gmail.com> > wrote: > > Is this possible? > > > > We really just want to from().log("${exchange.histo

Use Simple to log Message History?

2016-02-24 Thread James Green
Is this possible? We really just want to from().log("${exchange.history}").to() in our route. Seems like this should be really easy? Thanks, James

Sending Exchange to Multiple HTTP endpoints

2015-11-27 Thread James Green
I'm curious how others might do this. On the Exchange I can dynamically build a list of URIs (web hooks, basically) that need the body of this message. First attempt: add this list to a known header and pass it into recipient list: recipientList(header('webHooksList')) Sadly I also need to

[security] http4 endpoint headers leaking

2015-08-05 Thread James Green
We recently had cause to tcpdump an http request from the http4 component to a web site. We were most surprised to find a load of exchange headers listed as HTTP header: value pairs. A quick search on-line brings up a couple of Red Hat / Fuse documents saying that headers named 'Camel...' are not

Re: [security] http4 endpoint headers leaking

2015-08-05 Thread James Green
, 2015 at 9:51 AM, James Green james.mk.gr...@gmail.com wrote: We recently had cause to tcpdump an http request from the http4 component to a web site. We were most surprised to find a load of exchange headers listed as HTTP header: value pairs. A quick search on-line brings up a couple

Re: [security] http4 endpoint headers leaking

2015-08-05 Thread James Green
things on. I'm no expert but I'm not seeing anything obvious to fix this in the commit. Thanks, James On 5 August 2015 at 10:04, James Green james.mk.gr...@gmail.com wrote: We're using to - i.e. a producer. ..to(http4:some.host) and some.host gets all the headers in the request. On 5 August

Stuck route with file2 - suggestion for defaults change

2015-07-06 Thread James Green
We have an application that uses http://camel.apache.org/file2.html to scan for files as input to a route. Nothing special about it and until last week was working just fine. Then we noticed the route was handling nothing from the file component. When we checked there was in excess of 500,000

Re: ElasticSearch- Best practice for indexing entire JSON Files?

2015-05-15 Thread James Green
If widgets.json is effectively a database of products and each product should existing as a document in an elasticsearch index you will need to split it before sending it onwards. You could use Camel, but also consider logstash. If widgets.json is one of many source files representing products

DLQ, cause:null

2015-04-17 Thread James Green
We have a camel route consuming from ActiveMQ and occasionally get a DLQ entry without anything logged through our deadLetterChannel. The only thing we have to go on is a dlqFailureCause header which says: java.lang.Throwable: Exceeded redelivery policy limit:RedeliveryPolicy {destination =

Re: Sending email - possible bug?

2015-04-13 Thread James Green
as-is. If you want to include stacktraces / exception message or whatever you need to enrich the message before sending to the DLQ to include that. On Mon, Apr 13, 2015 at 5:12 PM, James Green james.mk.gr...@gmail.com wrote: An update: the email is sent just fine (I received it eventually

Re: Sending email - possible bug?

2015-04-13 Thread James Green
traces. Cheers Reji On 10 Apr 2015 16:51, James Green james.mk.gr...@gmail.com wrote: We just saw this in the log: 10/Apr/2015 10:56:04,683- DefaultJavaMailSender: Connecting to localhost:25 10/Apr/2015 10:56:04,701- DefaultJavaMailSender: Sending MimMessage

Re: Sending email - possible bug?

2015-04-13 Thread James Green
s/route/root/ that's habit creaking in for you. On 13 April 2015 at 16:12, James Green james.mk.gr...@gmail.com wrote: An update: the email is sent just fine (I received it eventually). The trouble is later on - the deadLetterChannel does not appear to log a stack trace. An engineer here

Are transactions useful in these use-cases?

2015-03-10 Thread James Green
We have a number of routes: from(HTTP POST).to(JMS) from(JMS).to(SOAP Endpoint).to(JMS) from(JMS).to(MongoDB) from(MongoDB).to(JMS) Hugely simplified and these are across various JAR services. Are transactions actually useful in the above? Actually understanding the behaviour of code routes is

Re: can i get discount for camel in action book

2015-03-05 Thread James Green
The Camel in Action is worth every penny. A light bulb came on in my mind when reading the early chapter on how Spring Application Contexts get wired together - I was pretty early in my Spring experience back then. The rest of the book is about Camel itself and really the only thing it lacks is a

Re: can i get discount for camel in action book

2015-03-05 Thread James Green
Ah ServiceMix. Another on my list of just why does this software exist? I guess I need to read a paragraph entitled Practical ServiceMix to know... On 6 March 2015 at 06:42, Cristiano Costantini cristiano.costant...@gmail.com wrote: I cannot avoid to say too that reading the book of Claus has

Test body mutation

2015-03-02 Thread James Green
I need to check that an object is mutated by a route properly. The testing.html page does not show this - only that the message passed through routes as expected. I'm downloading the camel sources now - is there a good test class that demonstrates this? Thanks, James

Re: Test body mutation

2015-03-02 Thread James Green
Or am I being silly - is it really as simple as asserting that the endpoint got the message,then doing simple JUnit assertions on the body sent in to check it is now as expected? (Brain somewhat stuck in asynchronous routes at the moment.) On 2 March 2015 at 10:27, James Green james.mk.gr

http4.html Possible error

2015-02-19 Thread James Green
Halfway down the page under Configuring the URI to call the example is given: from(direct:start) .setHeader(Exchange.HTTP_URI, constant(http://newhost;)) .to(http4://oldhost); Under it states: *Where Constants is the class, org.apache.camel.component.http4.Constants.* Is this correct as

http4 - socket timeout configured per-message?

2015-02-19 Thread James Green
I have a route that sends to a uri provided in the message. Also in the message is the socket timeout value. The first part is easy, but I can't see a way of specifying the socket timeout at runtime. Any ideas? Thanks, James

java-dsl.html error

2015-02-16 Thread James Green
At the bottom it talks about intercept() but doesn't use it. Confusing at least! And the link to InterceptorProcessor is a 404. James

Route with JMS down

2015-02-09 Thread James Green
We have a route from a REST endpoint into a JMS (InOnly) endpoint. We took down the broker to see what would happen. Turns out HTTP clients hang waiting for a response (for several minutes) while a load of stack traces are logged by Camel: 09/Feb/2015 15:07:52,677- DefaultErrorHandler: Failed

Re: Route with JMS down

2015-02-09 Thread James Green
February 2015 at 15:39, Claus Ibsen claus.ib...@gmail.com wrote: Hi If you use ActiveMQ you may need to turn off asyncSend http://activemq.apache.org/async-sends.html On Mon, Feb 9, 2015 at 4:20 PM, James Green james.mk.gr...@gmail.com wrote: We have a route from a REST endpoint into a JMS

Cross RouteBuilder exceptions

2015-02-09 Thread James Green
Our application contains a few RouteBuilders. I understand I can use onException across these but only by having them chained together through OO inheritance. Is there an alternative means? Ideally the RouteBuilder that constructs our public interface ought to be catching and mapping exceptions

Re: REST InOut with JMS InOnly

2015-02-05 Thread James Green
/camel/blob/master/camel-core/ src/test/java/org/apache/camel/processor/AnimalDeepClonePrepare.java Regards, Morgan On 5/02/2015 10:38, James Green wrote: Yes this is the simple bit. The not so simple bit is appreciating what happens under the hood. wiretap, quite rightly, sends the same

MailProducer not documented

2015-02-05 Thread James Green
http://camel.apache.org/mail.html mentions MailProducer but I can't find an example and the JavaDoc does not show it being used. Can anyone provide an update to the documentation as I'm not aware of whether we should be using it instead of an smtp: endpoint. Thanks, James

Re: REST InOut with JMS InOnly

2015-02-03 Thread James Green
or use WireTap On Tue, Feb 3, 2015 at 12:27 PM, James Green james.mk.gr...@gmail.com wrote: I have two routes: 1. A rest dsl accepting data from HTTP clients and sending it to the route below before replying to the client 2. A backend route that receives an Exchange and sends it to a JMS

Re: REST InOut with JMS InOnly

2015-02-03 Thread James Green
/02/2015 13:14, Claus Ibsen wrote: Hi You can send the message to the JMS as InOnly or use WireTap On Tue, Feb 3, 2015 at 12:27 PM, James Green james.mk.gr...@gmail.com wrote: I have two routes: 1. A rest dsl accepting data from HTTP clients and sending it to the route below before

Re: Periodic queue consumer

2015-02-02 Thread James Green
, Jan 30, 2015 at 4:28 PM, James Green james.mk.gr...@gmail.com wrote: We have a need to route message to a temporary location and to re-submit them every n seconds. We're thinking of sending the message to a queue if a later re-try is needed. A separate process would then be required

Periodic queue consumer

2015-01-30 Thread James Green
We have a need to route message to a temporary location and to re-submit them every n seconds. We're thinking of sending the message to a queue if a later re-try is needed. A separate process would then be required to read from the queue and re-submit. This is fine but clearly listening on a

Re: Messages sitting on ActiveMq for x period of time

2015-01-21 Thread James Green
May be worth connecting to ActiveMQ to inspect it at the JMX level (hawt.io is an excellent interface). Check why ActiveMQ thinks it should not be delivering it. On 21 January 2015 at 04:29, mvandersteen mark.vanderst...@servicestream.com.au wrote: Hi Guys, I have 1 queue created through

Re: Rest DSL Exception mapping

2015-01-21 Thread James Green
to be formatted to JSON/XML according to the HTTP client's choice? On 21 January 2015 at 11:51, James Green james.mk.gr...@gmail.com wrote: If Camel can accept and map both JSON and XML inputs to POJOs, is there a way of reversing this for onException handling purposes? The only example

Modifying a shipped TypeConverter

2015-01-20 Thread James Green
The mongodb component uses Jackson to marshal Object to DBObject. The trouble is that Date becomes long due to the default configuration of Jackson. Is it possible to change this by obtaining that Jackson instance and reconfiguring it? Or must be add a TypeConvertor for our specify type to the

Re: simple recipientlist expansion

2015-01-20 Thread James Green
(), route(${body.media}))) with a class like: public class MyRouter { public String route(ListString media) {...} // returns comma-seperated endpoints } Jakub On 19/01/15 18:01, James Green wrote: You mean a class implementing Expression? On 19 January 2015 at 17:56, Claus Ibsen

Re: simple recipientlist expansion

2015-01-20 Thread James Green
Map? I meant a ListString on the header, of course. On 20 January 2015 at 16:00, James Green james.mk.gr...@gmail.com wrote: I ended up with a Processor that built a new Map on a header iterating over the media and prefixing each in the header variant. I may in-line this in the camel route

Re: Modifying a shipped TypeConverter

2015-01-20 Thread James Green
Jakub On 20/01/15 14:50, James Green wrote: The mongodb component uses Jackson to marshal Object to DBObject. The trouble is that Date becomes long due to the default configuration of Jackson. Is it possible to change this by obtaining that Jackson instance and reconfiguring

simple recipientlist expansion

2015-01-19 Thread James Green
.recipientList(simple(direct:${body.media})) So media is a ListString property where each entry has a media value: sms, email, etc. What I get out of this is an exception (where sms is the only media): org.apache.camel.component.direct.DirectConsumerNotAvailableException: No consumers available

Re: simple recipientlist expansion

2015-01-19 Thread James Green
to a list. I think I have seen that done in fabric8 v1. On Mon, Jan 19, 2015 at 6:32 PM, James Green james.mk.gr...@gmail.com wrote: .recipientList(simple(direct:${body.media})) So media is a ListString property where each entry has a media value: sms, email, etc. What I get out

Re: Where is logName used?

2015-01-16 Thread James Green
/src/main/java/org/apache/camel/component/log/LogComponent.java#L55 On Tue, Jan 13, 2015 at 11:17 AM, James Green james.mk.gr...@gmail.com wrote: The following code: .log(LoggingLevel.ERROR, com.foo.server.ngw.router, Account Not Found. Message discarded.).stop

Re: Irrecoverable faults

2015-01-15 Thread James Green
Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On January 9, 2015 at 5:53:32 PM, James Green (james.mk.gr...@gmail.com) wrote: Should we avoid issuing these? We are implementing some checks that ask, for example

Re: Where is logName used?

2015-01-15 Thread James Green
configuration to make sure you setup the log rightly? -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On January 13, 2015 at 6:17:48 PM, James Green (james.mk.gr

Where is logName used?

2015-01-13 Thread James Green
The following code: .log(LoggingLevel.ERROR, com.foo.server.ngw.router, Account Not Found. Message discarded.).stop(); Results in the following in the log: 10:12:11,690 ERROR org.slf4j.helpers.MarkerIgnoringBase:145 error() - Account Not Found. Message discarded. I was

Re: onException is ignored

2015-01-12 Thread James Green
:03,993 ERROR org.slf4j.helpers.MarkerIgnoringBase:145 error() - Account Not Found. Message discarded. So what was the point of supplying a logName? On 12 January 2015 at 12:05, James Green james.mk.gr...@gmail.com wrote: As suggested: errorHandler(transactionErrorHandler

Re: onException is ignored

2015-01-12 Thread James Green
(English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On January 10, 2015 at 1:38:52 AM, James Green (james.mk.gr...@gmail.com) wrote: Project is Spring based with Camel 2.14 and the following configuration: onException(AccountNotFoundException.class) .log

Re: onException is ignored

2015-01-12 Thread James Green
: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On January 10, 2015 at 1:38:52 AM, James Green ( james.mk.gr...@gmail.com) wrote: Project is Spring based with Camel 2.14 and the following

Irrecoverable faults

2015-01-09 Thread James Green
Should we avoid issuing these? We are implementing some checks that ask, for example, Is the customer allowed to do this? And if the answer is no we're treating this as irrecoverable. Map this to irrecoverable according to Camel in Action Ch 5, Error Handling. Yet this chapter barely touches

onException is ignored

2015-01-09 Thread James Green
Project is Spring based with Camel 2.14 and the following configuration: onException(AccountNotFoundException.class) .log(Account Not Found. Message discarded.).to(jms:queue:RouterAccountNotFound).stop();

Re: Spring auto-registration of Components?

2015-01-08 Thread James Green
would be a good thing but I don't see how without using a strategy similar to the routes method. On 8 January 2015 at 17:51, Claus Ibsen claus.ib...@gmail.com wrote: Hi Are you talking about spring-boot or spring javaconfig? On Thu, Jan 8, 2015 at 11:58 AM, James Green james.mk.gr

Spring auto-registration of Components?

2015-01-08 Thread James Green
If CamelConfiguration.routes() registers RouteBuilders found in the application content, is there a reason why CamelConfiguration does not register Components in the same way? I'm just learning about this stuff so I may be mentally missing some steps :) Really looking to let our ops people

RecipientList to queue?

2015-01-08 Thread James Green
This errors: from(source()) .transacted() .unmarshal(jacksonUnmarshall) .process(router) .recipientList(simple(${body.media})) .marshal(jacksonMarshall); The router sets the In of the Exchange to an object

Are getters/setters required for simple?

2015-01-07 Thread James Green
http://camel.apache.org/simple.html talks about using getters/setters of a POJO. If the POJO has no business logic, can it not merely hold a set of public fields? Is this intended for work? No real point in the getters/setters existing. James

Recording events

2015-01-06 Thread James Green
We're about to build a number of jars which will use Camel to route messages from sources to destinations via business logic processors. One of things we're looking for is the ability to record business events as they happen. Sounds a bit like Wire Tap? We're unsure. Ultimately the events will

Cryptography - real world use

2014-12-24 Thread James Green
I'm looking at Camel's CryptoDataFormat and am wondering to what extent we might employ it. In our use-case we want multiple Camel-powered JARs to send each other messages via a message broker. Some of message needs to remain private so cryptography needs to be used. Right now we have routes that

Re: Cryptography - real world use

2014-12-24 Thread James Green
wrote: Sure! The crypto is agnostic of transport and payload - stick it in between the marshalling and the endpoint - and inbetween endpoint and unmarshalling and you should be fit for fight. Good luck! 2014-12-24 11:17 GMT+01:00 James Green james.mk.gr...@gmail.com: I'm looking

Re: Cryptography - real world use

2014-12-24 Thread James Green
wrote: Scott and Jakubs book has an excellent chapter about security where they cover this https://www.packtpub.com/application-development/apache-camel-developers-cookbook On Wed, Dec 24, 2014 at 11:29 AM, James Green james.mk.gr...@gmail.com wrote: So something like: from

Re: Cryptography - real world use

2014-12-24 Thread James Green
the dataformat a property of the endpoint/transport. 2014-12-24 11:29 GMT+01:00 James Green james.mk.gr...@gmail.com: So something like: from(the.input.queue).unmarshal(cryptoDataFormat).unmarshal(jaxbMapper).process(byBusinessProcessor).marshal(cryptoDataFormat).to(the.output.queue

Re: Cryptography - real world use

2014-12-24 Thread James Green
Incidentally what you expect to see if I have a POJO and sent it to MongoDB via an encrypting marshaller? A document full of binary or a hash where the values are binary? On 24 December 2014 at 11:39, James Green james.mk.gr...@gmail.com wrote: OK do we need to wrap the process() with both un

SMTP receiver

2014-11-07 Thread James Green
The components page lists camel-mail as the SMTP component (twice in fact) but that it can only send emails. Is there something that can listen for inbound SMTP connections? James

Re: [ANNOUNCE] Apache Camel 2.13.3 Released

2014-11-05 Thread James Green
The [4] link below does not exist. The download page shows 2.13.3 but is linked to 2.13.2. On 1 November 2014 07:53, Christian Mueller cmuel...@apache.org wrote: The Apache Camel project [1] is a powerful open source integration framework based on known Enterprise Integration Patterns [2].

Camel 2.14 breaks our test

2014-10-31 Thread James Green
We just upgraded from 2.13.2 to 2.14.0 and our test now hangs using the producerTemplate to send to an ActiveMQ (5.10.0) endpoint. The route accepts the message, sends it through JAXB and into a Processor which doesn't seem to be executed. We set debug logging on, and ActiveMQ seems to increment

Application naivity about endpoints

2014-10-07 Thread James Green
I want my application to connect to ActiveMQ today, and possibly RabbitMQ tomorrow. Therefore I do not want anything in code to mention either - it should just be a matter of altering a .properties file and restarting, right? However we're having trouble working out how to do this without

Re: Application naivity about endpoints

2014-10-07 Thread James Green
you avoid making your route bundle depend on the jms provider. Christian On 07.10.2014 13:18, James Green wrote: I want my application to connect to ActiveMQ today, and possibly RabbitMQ tomorrow. Therefore I do not want anything in code to mention either - it should just be a matter

Re: Can unit tests be @Transactional?

2014-09-23 Thread James Green
. This will ensure no threading will occur due to the jms consumer when you execute the route in your unit test. On 23 Sep 2014, at 1:41 am, James Green james.mk.gr...@gmail.com wrote: OK - we have a working solution. Someone should document this at http://camel.apache.org/transactional-client.html

Is this route possible..?

2014-09-22 Thread James Green
We want to consume from JMS and route the message through a set of Processors which may or may not invoke database calls via DAOs. Thing is, we want the database calls to be wrapped in a transaction, but we don't have an XA transaction manager so the JMS part ought to be excluded. Is this

Can unit tests be @Transactional?

2014-09-22 Thread James Green
We have a Spring project that has a unit test annotated @Transactional. This uses a DAO to save a sample Entity before invoking a Camel route that accepts a JMS message and sends it to some Processors. The problem we have is when the test itself is annotated @Transactional. The route stops having

Corrections to Wiki

2014-09-22 Thread James Green
Apparently I don't have permission to edit the following page: http://camel.apache.org/transactional-client.html Could someone correct the links to the Spring website (there are several that now 404)? Thanks, James

Re: Can unit tests be @Transactional?

2014-09-22 Thread James Green
and camel transaction is set to PROPAGATION_REQUIRED which is the default, this should just work. This assumes your unit test and camel execution is running under the same thread though. If not then stick to the first method. On 22 Sep 2014, at 11:51 pm, James Green james.mk.gr...@gmail.com wrote

Camel + Spring + JpaTransactionManager = Hung on SELECT

2014-09-05 Thread James Green
We have a maven project that bundles Camel and Spring. The trouble is a processor receives a message and uses an EntityManager to perform a database query which hangs completely until a 20s timeout kicks in during routing. The hang is during an integration test against an in-memory database with

Re: Camel + Spring + JpaTransactionManager = Hung on SELECT

2014-09-05 Thread James Green
2 millis) At this point we've waited 20 seconds and camel has given up waiting. As previously noted this is an in-memory db with a single record. On 5 September 2014 17:08, James Green james.mk.gr...@gmail.com wrote: We have a maven project that bundles Camel and Spring. The trouble

Spring Transactions, Camel processors doesn't see the data...

2014-09-03 Thread James Green
We have a project that includes Spring Camel. An integration test (FooIT.java) is annotated for running with Spring and uses a camel route. The problem is that the test creates a database record (which it can read back) but the camel processor that we're written does not see it. The route

Simplest route does nothing..?

2014-08-12 Thread James Green
We're missing something fundamental here. https://gist.github.com/jmkgreen/ed271348de66646a87be I run this, I get the following in the logs: https://gist.github.com/jmkgreen/91b89c32fe03ffb93ead So we're wondering what we're doing that doesn't actually execute the route? This comes out of a

Polling for file updates over http/s?

2013-10-24 Thread James Green
I'm having to write a java daemon that polls a service over http for an updated file. This effectively provides an automatic updates mechanism. Sounds like a job that could be a fit for Camel. Has anyone ever tried developing such a component? James

Re: The Camel Components Poster - PDF - FREE

2013-10-08 Thread James Green
I'm getting 404s from both. Has this been withdrawn? On 2 October 2013 14:27, gliesian glies...@yahoo.com wrote: The Camel Components Poster - PDF - FREE http://gliesian.com/camel/TheCamelComponentPosterWithWatermark.pdf The Camel Components Poster - PRINTED - NOT SO FREE

  1   2   >