Building predicates/routes at runtime

2014-12-06 Thread Behrad
case class Book( author: Person, title: String ) case class Person( name: String, age: Int ) when user inputs "author.name" and "startsWith" and "behrad" I should create "fromEndpoint" when( _.in.asInstanceOf[Book].author.name.startsWith( "behrad" )

Persisting CBR choice in body

2014-12-19 Thread Behrad
ctWithPred2Id ) to "somewhere2" otherwise transform setBody(updatedObjectWithNoMatchId ) to "somewhere3" -- --Behrad

Re: Persisting CBR choice in body

2014-12-20 Thread Behrad
Message body is my persistent domain model @taariq On Sat Dec 20 2014 at 1:57:01 PM Taariq Levack wrote: > Hi > Just wondering, is there a reason you want to enrich the body instead of > setting a header or property on the exchange? > > Taariq > > > > On Fri, Dec

Dealing with ProcessorDefinition

2015-01-07 Thread Behrad
In my org.apache.camel.scala.dsl.builder.RouteBuilder when I write from ==> { idempotentConsumer(uuid) repository db choice { ... } } everything is OK, however when I want to write from ==> { if( idempotencyIsSet) { idempotentConsumer(uuid) repository db } choice { ...

Idempotency Support in a chain of CBRs

2015-01-07 Thread Behrad
Considering I have a CBR chain like this, CBR0 = from seda:preRoute to receipientList (seda:1 OR seda:2 OR seda:3) CBR1 = from seda:1 to seda:postRoute CBR2 = from seda:2 to seda:postRoute CBR3 = from seda:3 to seda:postRoute CBRP = from seda:postRoute to finalEndpoint and I want to add idempote

RejectedExecutionException: Task rejected due queue size limit reached

2015-02-11 Thread Behrad
that big to me :( -- --Behrad

Re: RejectedExecutionException: Task rejected due queue size limit reached

2015-02-11 Thread Behrad
ava/org/apache/camel/component/seda/SedaDefaultUnboundedQueueSizeTest.java > > Taariq > > > On Thu, Feb 12, 2015 at 7:33 AM, Behrad wrote: > > > When my SEDA producer peaks seems I'm getting ExecusionService queue > limit > > with this trace: > > > >

Re: RejectedExecutionException: Task rejected due queue size limit reached

2015-02-13 Thread Behrad
; javadoc), which mean > // we could potentially keep adding tasks, and run out of memory. > if (profile.getMaxPoolSize() > 0) { > return new SizedScheduledExecutorService(answer, > profile.getMaxQueueSize()); > } else { > return answer; &

Async IdempotentRepository

2015-02-25 Thread Behrad
futures to send back add/remove/contains results and this is not currently provide the concurrency/performance we need on high load. -- --Behrad

upgrading to Scala 2.11

2015-04-06 Thread Behrad
/Elem java.lang.NoClassDefFoundError: scala/xml/Elem -- --Behrad

Re: upgrading to Scala 2.11

2015-04-07 Thread Behrad
t; AnnotationTypeConverterLoader - Ignoring converter type: > > org.apache.camel.scala.converter.ScalaTypeConverter as a dependent class > > could not be found: java.lang.NoClassDefFoundError: scala/xml/Elem > > java.lang.NoClassDefFoundError: scala/xml/Elem > > > > > > > > -- > > --Behrad > > -- --Behrad