The akka-camel module allows Untyped Actors to receive and send messages over a great variety of protocols and APIs. In addition to the native Scala and Java actor API, actors can now exchange messages with other systems over large number of protocols and APIs such as HTTP, SOAP, TCP, FTP, SMTP or JMS, to mention a few. At the moment, approximately 80 protocols and APIs are supported.
Questions tagged [akka-camel]
23 questions
4
votes
1 answer
Apache camel: connecting to a ZeroMQ server
I’m trying to connect to a ZeroMQ server using apache camel. I’m using the camel-zeromq component provided by the camel-extra project, but seems that this requires the previous installation of the native ZeroMQ library on the system.
Does someone…
Julen
- 263
- 1
- 9
2
votes
1 answer
Akka Streams, source items as another source?
I am using Alpakka-FTP, but maybe I'm looking for a general akka-stream pattern. The FTP connector can list files or retrieve them:
def ls(host: String): Source[FtpFile, NotUsed]
def fromPath(host: String, path: Path): Source[ByteString,…
ticofab
- 7,551
- 13
- 49
- 90
2
votes
1 answer
Check status of message queue connection in Apache Camel
I am using Apache Camel in Akka and am trying to check at given intervals what the status of the message queue is.
I see the queue logs its status periodically, but I would like to programmatically be able to make this check.
LK__
- 6,515
- 5
- 34
- 53
2
votes
0 answers
Two-way communications (ask or tell)?
akka documentation for java says
http://doc.akka.io/docs/akka/2.4/java/camel.html#Consumer_timeout
Two-way communications between a Camel endpoint and an actor are initiated by sending the request message to the actor with the ask pattern and the…
Javier Pajaro
- 43
- 5
2
votes
1 answer
Akka Camel multiple consumers
I'm using akka + camel to consume message from activemq, and I'm trying to figure out how to deploy this consumer in multiple machines without duplicate the message. In this case I'm consuming message from a topic and the activemq should know I have…
Thiago Pereira
- 1,724
- 1
- 17
- 31
2
votes
2 answers
Apache Camel File process is resulting in TypeConversion Error
I am using akka-camel to process files. My initial tests were working great, however when I started passing in actual xml files it is puking with type conversions.
Here is my consumer (very simple, but puking at msg.bodyAs[String]
class…
scarpacci
- 8,957
- 16
- 79
- 144
1
vote
1 answer
Explicit ack to JMS using Alpakka
I am currently using Akka-Camel for integrating my Akka based application with various message queues.
Now that I want to upgrade to the latest version of Akka I see that this integration is now deprecated.
I have tried using alpakka-jsm…
Evan M.
- 403
- 5
- 13
1
vote
1 answer
How does the Camel Jetty component work in Akka?
In the following example (taken from Akka Camel doc), the Jetty HTTP component is used to receive HTTP messages. Does it mean that the actor start a new Jetty server?
import akka.camel.{ CamelMessage, Consumer }
class MyEndpoint extends Consumer…
EugeneMi
- 3,475
- 3
- 38
- 57
1
vote
1 answer
Camel, Akka, JMS and deferred message acknowledgement: can I acknowledge a previously processed message to the broker?
I am using Akka (latest stable version), akka-camel and JMS (for the purposes of this conversation, let's say it's ActiveMQ, but ideally the solution should be generic).
The use-case
I have the following use-case. On a queue Q I receive messages…
mdm
- 3,928
- 3
- 27
- 43
1
vote
2 answers
Embedded Jetty timeout under load
I have an akka (Java) application with camel-jetty consumer. Under some minimum load (about 10 TPS), our client starts seeing HTTP 503 error. I tried to reproduce the problem in our lab, and it seems jetty can't handle overlapping HTTP requests.…
Khoa Nguyen
- 280
- 4
- 14
0
votes
0 answers
Apache Camel doTry doCatch not catching akka camel exception
We are using XML DSL with Akka Camel (2.5.13), and found that when a camel points to a bean, which answers with an Exception, it is not caught by Camel.
Our Scala code:
private def replyError(exception: ChannelException) {
…
Fede E.
- 2,118
- 4
- 23
- 39
0
votes
0 answers
Apache Camel wrong response JSON - UTF8
I have this configuration for Apache Camel Rest service:
dani77
- 199
- 2
- 5
- 26
0
votes
1 answer
No endpoint could be found for: test, please check your classpath contains the needed Camel component jar
I am trying to send and receive messages using akka-camel and created a sample example for producer and consumer like below :
Producer:
import akka.actor.{Actor, ActorSystem, Props}
import akka.camel.Producer
class CamelJmsProducer extends Actor…
Jet
- 3,018
- 4
- 33
- 48
0
votes
2 answers
Parsing csv data format in apache Camel
I followed an example from a book Camel in action. how to marshal and unmarshal csv data format. However, I want to unmarshal a csv file with (comma seperated delimiter) and split body. Then, I will use content based .choice to distribute messages…
Chayma Sakouhi
- 79
- 2
- 10
0
votes
0 answers
Actor doesn't exist
I want to create a camel akka actor, it will consume from a MQTT server. But when I recive a message from the MQTT server it throws an error and tell me thant the actor doesn't exist.
My actor
public class GetListener extends…
Elektroi
- 714
- 10
- 10