[akka-user] delete persisted message in Journal

[hfaouaz]

Hello,

I need to delete a message after it has been successfully delivered from 
the Journal.  Currently it seem I can only deleteMessageTo using sequence 
Number, but if I only need to delete one message how I can do that?  thanks 
for your time and help

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] shutdown camel route in an akka actor

[hfaouaz]

Hello,
  I am trying to leverage akka to initiate one single camel route 
execution, as such once the actor gets a message, it initiates the camel 
route, and upon completion, shutdown the route.  Example below, though I am 
not able to achieve it.  Either the camel route stays and if I try to shut 
it down, the route is never complete.  Any ideas I would appreciate...

class CamelRouteExecutor extends Actor with ActorLogging {

  implicit val system = context.system

  val camel = CamelExtension(system)

  def receive = {

case work:Any =>

  val route = work.asInstanceOf[java.lang.String]
  log.debug("Executing camel route {}", route)
  val is = new ByteArrayInputStream(route.toString().getBytes())
  val routesDef = camel.context.loadRoutesDefinition(is)
  camel.context.addRouteDefinition(routesDef.getRoutes.get(0))
  log.debug("stopping route Id {} from camel context", 
routesDef.getRoutes.get(0).getId)
  camel.context.stopRoute(routesDef.getRoutes.get(0).getId)
  camel.context.removeRoute(routesDef.getRoutes.get(0).getId)

  sender() ! Worker.WorkComplete("work status: ")


case _ =>
  log.warning("got a message, which I don't understand")
  }
}

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] akka-camel

[hfaouaz]

Hello,

   I am attempting to integrate camel with akka, though I have a question 
concerning best practice approach in creating a camel route.


1) Should I create a route, where each consumer and producer are actors and 
chain them?  or
2) Should I have one actor and have it RouteBuilder within?

The problem I encountering doing he first option, I may sometime have more 
consumers then producer, since akka is asynchronous and it causing the 
route to break or even restart in the middle, since actors restart if they 
fail.

any ideas, guidance, is appreciated.

thanks

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.