We are using IBM MQ in our PRODCUTION and QA environments. We need to route
messages being received in PRODUCTION environment to our QA environment too
for some testing.
The queue manager being used in PRODUCTION environment is different that the
one being used in QA environment. I will appreciate
I have just started learning CAMEL. There are some good basic examples to
learn CAMEL. It seems that, using CAMEL, it is so simple to send a message
from one queue to the other. For example he is one example:
from("activemq:queue1”)
.to("activemq:queue2");
The above two lines will do the job. I h
Thank you very much for such a precise explanation.
Our customer is using IBM MQ, can you also provide SPRING tags to configure
IBM MQ broker?
Also, we used VPN to cennect to our customer Queue, do I need to configure
CAMEL/ACTIVE MQ for the VPN?
Thank you
--
View this message in context:
ht
Also,
in the follwing code:
from("activemq_production:queue:queue1”)
.to("activemq_staging:queue:queue2","activemq_customer:queue:customerQueue");
Do I need to create queue1, queue2 or customerQueue? or the above "from ->
to" statements will automatically create the queues if they don't exist
I want to try a CAMEL example in my Test environment:
Following is the example:
Content based router
${header.CamelFileName} regex '^.*xml$'
${header.CamelFileName} re
I want to try a CAMEL example in my Test environment: Following is the
example: (please refer to the attachment)
I put this code in
"serviceMix\apache-servicemix-4.3.0\apache-servicemix-4.3.0\deploy".
I was able to see that this route has been created and an ID had been given
to it.
When I run i
I would like to first thank for prompt replies. CAMEL is a great product and
through this site, I'm learning and making my concenpts clear.
Here is my question:
I am successfully running examples using MAVEN. MAVEN compiles the java code
and retrieved all the dependencies. Now suppose I want to t
Thank you all for the feeback.
Here is the result of executing
1. MVN INSTALL and
2. mvn dependency:copy-dependencies
1. mvn install: it created a jar file which contains the following:
i. log4j.properties
ii. META-INF folder which contains MANIFEST.MF and a package. The package
contains pom
I have written a program to FTP files from a server to a folder on my laptop
using SFTP component. The program is able to copy. I had to just write one
line of code (excluding boilderplate code) to get everything done. Thank
you CAMEL!
Now I want to enhance this program. Here is how I want this p
Claus Ibsen:
Thank you for the great feedback.
It seems that I will have to recursively read all the files from all the
folders and using the custom filter will prevent the files from being copies
to the destination folder. I would like to know if there is a way to read
the folder name so that I
Thank you for the reply.
I tried it but I'm getting " java.lang.NoClassDefFoundError:
FileCopierWithCamel"
I have tried HelloWorld example and it runs successfully (just to make sure
all environment varialbes are set properly).
I have both "dependency" folder and "chapter1-file-copy-1.0.jar" in
I have created a project using m2eclipse, when I run the goal maven:run in
Eclipse, I'm getting the following error: (please tell me how can I fix this
error)
No plugin found for prefix 'maven' in the current project and in the plugin
groups [org.apache.maven.plugins, org.codehaus.mojo] available
thank you Claus.
--
View this message in context:
http://camel.465427.n5.nabble.com/No-plugin-found-for-prefix-maven-in-the-current-project-and-in-the-plugin-groups-tp4905711p4906914.html
Sent from the Camel - Users mailing list archive at Nabble.com.
I would like to know if following is possible:
I want to send messages to different assets. Let's say I have two listeners
A and B. Listener A is configured on port 2000 and Listener B is configured
on port 2500. For each listener there is a queue. I send a healthCheck
message which contains infor
All,
Thank you very much for the suggestions/recommendation.
I would like to visually see the message flow (the graphical view of the
message should be a live view and should show , some how, that messages are
going throug (for example, when IBM BMP is executed, it should how requests
are flowin
I want to write a program in JAVA that will connect to a remote assets let's
say TRUCKS. (The big trucks that carry cargo) Trucks have a digi device
(cell modem) installed which is connected to the onboard computer (via a
serial port, each truck has a computer). The onboard computer are
proprieta
Thank you for the reppy.
I can use any of the following protocols:
XMPP (Jabber)
HTTPS
SSL
SFTP
Secure MQ
But most probably I would prefer to use HTTPS. The thing is that the digi
device is connected to the computer on board truck via a serial port so all
the communication reaching at digi devic
Jesus:
I need to know which component should I use for low level TCP/IP
communication i.e. netty or mina?
After going throug the documentation I think MINA is more advance.
My application will need to send messages to many trucks every 15 minutes.
So let say my application is a client machine wh
Thank you all for your feedback.
I have tried an example similar to the one given at the following site:
http://marcelojabali.blogspot.com/2011/09/using-apache-mina-in-camel.html
But this works only if the client and server are on the same machines i.e.
local host.
In my case, I will have to use
I will be opening a socket connection with digi device some thing like this:
Socket clientSocket = new Socket(IP address, port#);
my application is going to act as a client sending commands to the digi
device. Digi device in return will send my application a message that my
application will put i
Thank you very much to all for your time and valuable feedback.
Let me answer the questions that have been asked:
Q. does the server know in advance the IP address of each digi device? Are
they static?
A. IP addresses are dynamic. Digi device has Connect ware manager through
which the IP address
Thank you for the response.
Below are some more clarifications and my questions:
"Good, dynamic addresses are ok, DNS is ok. However, you need to know the
host names then, right? How do you know those? "
In the digi Connect ware manager we have both IP address and the host name.
We'll send the
Hadrian
Thank you very much, it is indeed very nice of you. I am vehemently waiting
for the example.
--
View this message in context:
http://camel.465427.n5.nabble.com/Remotely-pulling-messages-using-CAMEL-tp4971149p4997180.html
Sent from the Camel - Users mailing list archive at Nabbl
Hadrian
---
Thank you very much for all the hard work you have done. I am going through
the code and will be posting my questions later today.
--
View this message in context:
http://camel.465427.n5.nabble.com/Remotely-pulling-messages-using-CAMEL-tp4971149p5004013.html
Sent from the Camel
suppose we have this route:
http://camel.apache.org/schema/spring";>
and we have this bean:
public class HelloBean {
public String hello(String name) {
return "Hello " + name;
}
}
My Questions:
1. In ="direct:start" , what does start refer to or is this just a name, can
it be any n
Thanks Bilgin
--
View this message in context:
http://camel.465427.n5.nabble.com/invoking-bean-from-CAMEL-route-tp5008230p5008349.html
Sent from the Camel - Users mailing list archive at Nabble.com.
to test the bean I have done the followiing but the queue is not in ActiveMQ.
generated "http://localhost:8161/admin/queues.jsp"; . Can you tell me why
the queue is not generated.
Note: Route has been started successfully. I ahve added active mq
components.
Spring XML:
http://camel.apache
hi,
I want to remotely send serial SSH commands to digi device and in response
digi device will send the message, can I use NETTY component to achieve
this.
1. How can I specify the user name and the password in Netty component?
2. First I will have to use "netty:tcp://localhost:9[?options]"
hi Bilgin:
Thanks for the response. After replacing the line "" with " " the queues is created.
I am curious why it didn't work with
does this endpoint wait for something and then it triggers?
Thanks
--
View this message in context:
http://camel.465427.n5.nabble.com/invoking-bean-fro
I have following JAVA DSL:
from("timer://myTimer?period=2000")
.setBody().simple("Current time is ${header.firedTime}")
.to("stream:out");
how can I converted the first and third lines to Spring DSL:
How can I convert .setBody().simple("Current time is ${header.firedTime}")
t
Hadrian:
Thank you for putting the code together. I feel that I am gaining a lot from
your code as I go through it again and again.
Your code shows how to establish TCP connection. Can you also give few hints
about how to send commands to the Digi and get the response back.
I want to know, if
Thank you to both Bilgin and Hadrian
--
View this message in context:
http://camel.465427.n5.nabble.com/invoking-bean-from-CAMEL-route-tp5008230p5011239.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hadrian;
I am executing each route one by one. Here is what I have done:
First route:
It runs successfully and I am able to see all the host:IP in the digiQueue
Nex I add the second route:
${body}
Thanks Bilgin.
I'm not using IDE but will try using it.
--
View this message in context:
http://camel.465427.n5.nabble.com/converting-form-JAVA-DSL-to-Spring-DSL-tp5011220p5011615.html
Sent from the Camel - Users mailing list archive at Nabble.com.
I have following route:
${body}
netty:tcp://${body}?sync=true
DigiUri
DigiUri
If I replace:
DigiUri
with:
The value of "DigiUri" is printed on the command prompt.
But with
Thanks Hadrian, I'm going to fix it as you have explained.
--
View this message in context:
http://camel.465427.n5.nabble.com/No-consumers-available-on-endpoint-Endpoint-direct-start-tp5011742p5011993.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Hadrian: thanks for your valuable feedback.
this is my partial route:
${body}
netty:tcp://${body}?sync=true
DigiUri
The first route (from above) works fine.
in the second route, it works
I have define the following simple route for testing:
http://camel.apache.org/schema/spring";>
I've been trying to run this route since morning but I am getting the same
error every time I run it. (error is given below. e.g.
java.net.BindException: Addres
Hi Iocanel :
Thanks for the reply. My route will have to open the connection with digi
device and automatically send SSH commands to it by pulling them from the
database. Can you provide some hints how can I send SSH commands using
camel-exec after establishing connection with the digi device.
Th
Claus:
Thanks for the reply.
As I have mentioned in my question. I have Java Client/Server program which
opens the socket conneciont using the same port i.e 8000.
I am able to run my java program and pass messages back and forth. When the
program is being run I applied the following command net
Hadrian:
I have sent my route. Here is the complete XML file
http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:camel="http://camel.apache.org/schema/spring";
xsi:schemaLocation="
http://www.springframework.or
Tim
Prior to posting this question, I tried it using 9900 port but no luck!
--
View this message in context:
http://camel.465427.n5.nabble.com/CAMEL-is-throwing-error-tp5014337p5014654.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Tariq,
Attached is the entire program. This is a very simple route and it doesn't
require me to copy code from Hadrian's example.
http://camel.465427.n5.nabble.com/file/n5016269/netty.zip netty.zip
Attached is the java program that I run prior to executing CAMEL
application.
http://camel.46
Tariq,
Thanks for the reply.
Server_9900 is written to send messages to CAMEL, and to it "java program"
needs to be started prior to running CAMEL application (is this not the
right thing to do) . How can otherwise, messages be sent to port 9201 for
CAMEL to consume?
--
View this message in con
CAMEL Community:
I have raised this question earlier also and got some directions which are
great, but I am still stuck at a critical step and need your help in solving
it.
I am new to CAMEL and learning it. I have a project which I have explained
in my other post but now I am focusing on where
CAMEL Community:
I have raised this question earlier also and got some directions which are
great, but I am still stuck at a critical step and need your help in solving
it.
I am new to CAMEL and learning it. I have a project which I have explained
in my other post but now I am focusing on where
Calus:
Thanks for the reply.
I have already gone through the example "MinaTcpTest.java" given chpater 7
and other example. The examples show how the actual route works through unit
testing. I understand that but when it comes to
creating my own route, and executing it in real not thorugh unit te
Hi
I am trying to use database (MySQL) in CAMEL (v. 2.6). I have defined my SQL
using Spring DSL. When I run
"mvn -e camel:run" I get the following error:
Error occurred while running main from: org.apache.camel.spring.Main
java.lang.ClassNotFoundException: org.apache.camel.spring.Main
at
Jon:
Thanks for the replty.
I have following in the pom: (I'm using JDBC)
org.apache.camel
camel-jdbc
${camel-version}
org.springframework
spring-jdbc
2.5
test
And I have following in the camel-context.xml
Babak:
Thanks for the reply. (camel version is 2.6)
I addded the following in the pom.xml:
org.apache.camel
camel-spring
${camel-version}
When I run mvn "mvn -e camel:run" I am now getting the following error:
Error occurred while running main from: org.apache.camel.spring.
Babak:
Thanks for the correction.
Here is what I now have in the pom:
org.apache.camel
camel-jdbc
${camel-version}
org.springframework
spring-jdbc
2.5
org.apache.camel
camel-spring
Babak:
Thank you for the reply.
I have added the mysql jdbc-driver (found from the site given below [1])
dependency in the pom i.e.
mysql
mysql-connector-java
5.1.9
[1]
http://www.mkyong.com/spring/maven-spring-hibernate-annot
Willem:
Thanks for the reply.
Here are all the dependencies defined in the pom file: (I have explicitly
assigned the version)
2.6.0
1.2.16
2.1
2.1.13
org.apache.camel
camel-core
${camel-version}
org.apache.ca
Please let me know the following.
1. Does CAMEL provide out-of-the box support for SLIP Encoding/Decoding?
2. Does CAMEL has built-in function/method to ensure proper integrity of the
message using CRC-16 and does CAMEL has built-in function to create CRC-16.
3. Does CAMEL has any component for A
If I define my route using JAVA DSL and then if I want to run my program from
a different computer where maven does not exist, I can do the following:
java -cp dependency/*;chapter1-file-copy-1.0.jar
camelinaction.FileCopierWithCamel
Here my route is in "FileCopierWithCamel"
My question is: I
Thanks Bilgin.
I added the followig in my POM file:
org.apache.maven.plugins
maven-jar-plugin
2.4
true
org.apache.ca
My route is something like this:
C08005005472C0
..
The message is suppose to be sent as a byte array. Whereas I am sending it
as a string. How can I set the body to the byte array.
Thank you
--
View this message in context:
http://camel.465427.
Hi,
I have a need to send and consume messages from IBM MQ. I have been using
ACTIVE MQ and I will appreciate if an expert could correct the snapshot
shown below:
1. Spring configuration for IBM MQ: (I have been using similar for Active MQ
but would like to confirm if I could use the same for IBM
In the POM file, this is what I have:
org.apache.camel
camel-jms
2.5.0
com.ibm.mq
com.ibm.mq
5.3
Is this all I need to use IBM MQ or Is there anything misssing that I need
to add.
If I search your site, it takes considerable time to find th
Hi,
I am getting BUILD error because following JARS could not be found.
com.ibm.mq:com.ibm.mq.jmqi:jar:7.0.1.3
com.ibm:com.ibm.mqjms:jar:7.0.1.3
com.ibm:com.ibm.mqjms:jar:7.0.1.3
To use IBM MQ, I have added following in my POM:
com.ibm.mq
com.ibm.mq.jmqi
7.0.1.3
I am trying to connect to IBM MQ following the settings, that "Ashwin Karpe"
has placed in the following link:
http://camel.465427.n5.nabble.com/Can-Camel-communicate-over-IBM-MQ-sender-receiver-channels-td4429050.html
However, I am getting the following error:
[ltMessageListenerContainer-102]
61 matches
Mail list logo
