MSMQ - > ACTIVEMQ?

[aboyz]

Hi,

Anyone got any example I can see how to get msmq to work with activemq? I installed the fuse mediation router, but there are no sample on how to get it working..

[aboyz]

I know in order to get this to work, I need to install fuse mediation router. Which i did.. Here is my setup

Windows Box (MSMQ) <> (ACTIVEMQ) linux box. + Fuse mediation Router.? Should the fuse mediation router be on the windows box where msmq is install? or can it be on the linux box?

Ok, says all this is install How do I test it, what command do I use, There is not example or help that show me how to test it and see if the msmq is talking to the activemq? I'm really confuse..

thanks for any help.

[davsclaus]

Hi

Yeah this component doesnth have extensive documentation.

You can check the unit tests how it tests itself where it sends and receives message with AMQ and MQ

Link to source here

https://projects.open.iona.com/projects/svn/iona/camel/trunk/components/camel-msmq/

I do think that it requires to run on a Windows platform as it uses native .dll to access MQ (using Java JNI).

[aboyz]

Thanks for the info.. So I'm trying to do this and i'm getting this..

http://fusesource.com/wiki/display/ProdInfo/BridgingMSMQwithJMSusing+FUSE-ESB4

error. please advise..

C:\>svn co https://projects.open.iona.com/projects/svn/iona/camel/trunk/componen

ts/camel-msmq

Error validating server certificate for 'https://projects.open.iona.com:443':

- The certificate is not issued by a trusted authority. Use the

   fingerprint to validate the certificate manually!

- The certificate hostname does not match.

- The certificate has expired.

Certificate information:

- Hostname: zeus.inthesource.com

- Valid: from Fri, 26 Jan 2007 10:11:25 GMT until Sat, 26 Jan 2008 10:11:25 GMT

- Issuer: http://www.cacert.org, Root CA

- Fingerprint: 65:b6:ea:7b:11:91:84:be:68:5f:fa:06:0d:09:71:01:93:4a:ee:2d

(R)eject, accept (t)emporarily or accept (p)ermanently? t

A    camel-msmq\src

A    camel-msmq\src\test

A    camel-msmq\src\test\java

A    camel-msmq\src\test\java\org

A    camel-msmq\src\test\java\org\apache

A    camel-msmq\src\test\java\org\apache\camel

A    camel-msmq\src\test\java\org\apache\camel\component

A    camel-msmq\src\test\java\org\apache\camel\component\msmq

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqSendWithProper

tiesTest.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqXPathTest.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\native_support

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\native_support\Nat

iveSupportTest.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqJmsSendReceive

PerformanceTest.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\Person.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqObjectMessageT

est.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqSendReceiveTes

t.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqSendReceivePer

formanceTest.java

A    camel-msmq\src\test\java\org\apache\camel\component\msmq\MsmqSendReceiveStr

essTest.java

A    camel-msmq\src\test\resources

A    camel-msmq\src\test\resources\org

A    camel-msmq\src\test\resources\org\apache

A    camel-msmq\src\test\resources\org\apache\camel

A    camel-msmq\src\test\resources\org\apache\camel\component

A    camel-msmq\src\test\resources\org\apache\camel\component\msmq

A    camel-msmq\src\test\resources\org\apache\camel\component\msmq\spring.xml

A    camel-msmq\src\main

A    camel-msmq\src\main\java

A    camel-msmq\src\main\java\org

A    camel-msmq\src\main\java\org\apache

A    camel-msmq\src\main\java\org\apache\camel

A    camel-msmq\src\main\java\org\apache\camel\component

A    camel-msmq\src\main\java\org\apache\camel\component\msmq

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\MsmqComponent.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\MsmqProducer.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\msm

q_native_support.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\SWI

GTYPE_p_signed_char.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\msm

q_native_supportJNI.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\Byt

eArray.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\Msm

qMessage.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\Msm

qQueue.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\Nat

iveLibraryLoader.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\native_support\msm

q_native_supportConstants.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\MsmqConsumer.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\MsmqConstants.java

A    camel-msmq\src\main\java\org\apache\camel\component\msmq\MsmqEndpoint.java

A    camel-msmq\src\main\native

A    camel-msmq\src\main\native\msmq_native_support.cxx

A    camel-msmq\src\main\native\msmq_native_support.h

A    camel-msmq\src\main\native\msmq_native_support_wrap.cxx

A    camel-msmq\src\main\native\Makefile

A    camel-msmq\src\main\resources

A    camel-msmq\src\main\resources\META-INF

A    camel-msmq\src\main\resources\META-INF\NOTICE.txt

A    camel-msmq\src\main\resources\META-INF\LICENSE.txt

A    camel-msmq\src\main\resources\META-INF\services

A    camel-msmq\src\main\resources\META-INF\services\org

A    camel-msmq\src\main\resources\META-INF\services\org\apache

A    camel-msmq\src\main\resources\META-INF\services\org\apache\camel

A    camel-msmq\src\main\resources\META-INF\services\org\apache\camel\component

A    camel-msmq\src\main\resources\META-INF\services\org\apache\camel\component\

msmq

A    camel-msmq\pom.xml

A    camel-msmq\README

Checked out revision 78531.

C:\>cd camel-msmq

C:\camel-msmq>

C:\camel-msmq>mvn install

Scanning for projects...

-

---

FATAL ERROR

-

---

Error building POM (may not be this project's POM).

Project ID: null:camel-msmq:bundle:null

Reason: Cannot find parent: org.apache.camel:camel-parent for project: null:came

l-msmq:bundle:null for project null:camel-msmq:bundle:null

-

---

Trace

org.apache.maven.reactor.MavenExecutionException: Cannot find parent: org.apache

.camel:camel-parent for project: null:camel-msmq:bundle:null for project null:ca

mel-msmq:bundle:null

        at org.apache.maven.DefaultMaven.getProjects(DefaultMaven.java:432)

        at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:300)

        at org.apache.maven.DefaultMaven.execute(DefaultMaven.java:137)

        at org.apache.maven.cli.MavenCli.main(MavenCli.java:362)

        at org.apache.maven.cli.compat.CompatibleMain.main(CompatibleMain.java:4

1)

        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.

java:39)

        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces

sorImpl.java:25)

        at java.lang.reflect.Method.invoke(Method.java:597)

        at org.codehaus.classworlds.Launcher.launchEnhanced(Launcher.java:315)

        at org.codehaus.classworlds.Launcher.launch(Launcher.java:255)

        at org.codehaus.classworlds.Launcher.mainWithExitCode(Launcher.java:430)

        at org.codehaus.classworlds.Launcher.main(Launcher.java:375)

Caused by: org.apache.maven.project.ProjectBuildingException: Cannot find parent

: org.apache.camel:camel-parent for project: null:camel-msmq:bundle:null for pro

ject null:camel-msmq:bundle:null

        at org.apache.maven.project.DefaultMavenProjectBuilder.assembleLineage(D

efaultMavenProjectBuilder.java:1396)

        at org.apache.maven.project.DefaultMavenProjectBuilder.buildInternal(Def

aultMavenProjectBuilder.java:823)

        at org.apache.maven.project.DefaultMavenProjectBuilder.buildFromSourceFi

leInternal(DefaultMavenProjectBuilder.java:508)

        at org.apache.maven.project.DefaultMavenProjectBuilder.build(DefaultMave

nProjectBuilder.java:200)

        at org.apache.maven.DefaultMaven.getProject(DefaultMaven.java:632)

        at org.apache.maven.DefaultMaven.collectProjects(DefaultMaven.java:515)

        at org.apache.maven.DefaultMaven.getProjects(DefaultMaven.java:419)

        ... 12 more

Caused by: org.apache.maven.project.ProjectBuildingException: POM 'org.apache.ca

mel:camel-parent' not found in repository: Unable to download the artifact from

any repository

  org.apache.camel:camel-parent:pom:2.x-fuse-SNAPSHOT

from the specified remote repositories:

  central (http://repo1.maven.org/maven2)

for project org.apache.camel:camel-parent

        at org.apache.maven.project.DefaultMavenProjectBuilder.findModelFromRepo

sitory(DefaultMavenProjectBuilder.java:605)

        at org.apache.maven.project.DefaultMavenProjectBuilder.assembleLineage(D

efaultMavenProjectBuilder.java:1392)

        ... 18 more

Caused by: org.apache.maven.artifact.resolver.ArtifactNotFoundException: Unable

to download the artifact from any repository

  org.apache.camel:camel-parent:pom:2.x-fuse-SNAPSHOT

from the specified remote repositories:

  central (http://repo1.maven.org/maven2)

        at org.apache.maven.artifact.resolver.DefaultArtifactResolver.resolve(De

faultArtifactResolver.java:228)

        at org.apache.maven.artifact.resolver.DefaultArtifactResolver.resolve(De

faultArtifactResolver.java:90)

        at org.apache.maven.project.DefaultMavenProjectBuilder.findModelFromRepo

sitory(DefaultMavenProjectBuilder.java:558)

        ... 19 more

Caused by: org.apache.maven.wagon.ResourceDoesNotExistException: Unable to downl

oad the artifact from any repository

        at org.apache.maven.artifact.manager.DefaultWagonManager.getArtifact(Def

aultWagonManager.java:349)

        at org.apache.maven.artifact.resolver.DefaultArtifactResolver.resolve(De

faultArtifactResolver.java:216)

        ... 21 more

-

---

Total time: < 1 second

Finished at: Thu Jul 02 16:19:32 PDT 2009

Final Memory: 1M/4M

-

---

C:\camel-msmq>

Anyone know what its giving me a parent null?? or that error.. thanks in advance..

[njiang]

Hi,

I think you need to check out the whole project and build the source from the root.

BTW, since we start to use FUSE Forge host our project, the latest camel fuse trunk code move to here.

http://fusesource.com/forge/svn/fuseeip/trunk/

[davsclaus]

You can grab the .jars from the fuse maven repo.

Both releases and snapshots.

http://repo.fusesource.com/

See this blog entry if you use maven how to do it

http://davsclaus.blogspot.com/2009/02/how-to-use-fuse-releases-when-you-cant.html

[aboyz]

I'm still lost on how to get camel-msmq to be installed.. Can you show me the exalt step on how to get it setup? I"m getting the same error on whatever trunk I'm checking out. i'm totally lost, any help will be greatful!!

[aboyz]

I can't find the camel-msmq in the maven repo release or the SNAPSHOT.

http://repo.fusesource.com/maven2-snapshot/org/apache/camel/

[davsclaus]

Hi

Sorry about that, looks like it very well is missing in the distributions builds.

I have created a ticket

http://fusesource.com/issues/browse/MR-206

And will get it fixed so we have it in the next release of FUSE MR

[davsclaus]

Hi

I have attached the camel-msmq.jar for the FUSE MR 1.x router.

Eg if you use FUSR MR 1.6.0.x then it should work with the attached .jar

[davsclaus]

Hi

And the 2.x version is attached as well.

It should be included in the distributions from this day forward. And will be published to the fuse maven repo when the CI servers do its next rounds of builds and deploys.

[aboyz]

davsclaus,

thank you so much for the response, really appreciate your help. I downloaded the file and I'm getting this error when I try to run the .jar file. All I did was just double click on the .jar file and it should open using the java software. Or is there some other way of opening that .jar file?

attached is the screen shot..

thanks again!!

[aboyz]

Here is my java version..

C:\camel-trunk\components\camel-msmq>java -version

java version "1.6.0_14"

Java(TM) SE Runtime Environment (build 1.6.0_14-b08)

Java HotSpot(TM) Client VM (build 14.0-b16, mixed mode, sharing)

java camel-msmq-2.x-fuse-SNAPSHOT.jar

Exception in thread "main" java.lang.NoClassDefFoundError: camel-msmq-2/x-fuse-SNAPSHOT/jar

Caused by: java.lang.ClassNotFoundException: camel-msmq-2.x-fuse-SNAPSHOT.jar

        at java.net.URLClassLoader$1.run(URLClassLoader.java:200)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:188)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:307)

        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:252)

        at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)

Could not find the main class: camel-msmq-2.x-fuse-SNAPSHOT.jar.  Program will exit.

Edited by: aboyz on Jul 7, 2009 10:32 PM

[njiang]

no, you can't direct run the jar without using any main class to start up camel context with MSMQ endpoint.

You can find some unit test to show how to use MSMQ component here

http://fusesource.com/forge/svn/fuseeip/trunk/components/camel-msmq/src/test

[aboyz]

njiang

Thank you for the reply.. I try running those test file and getting this error?

C:\camel-test\java\org\apache\camel\component\msmq>java MsmqSendReceivePerformanceTest.java

Exception in thread "main" java.lang.NoClassDefFoundError: MsmqSendReceivePerfor

manceTest/java

Caused by: java.lang.ClassNotFoundException: MsmqSendReceivePerformanceTest.java

        at java.net.URLClassLoader$1.run(URLClassLoader.java:200)

        at java.security.AccessController.doPrivileged(Native Method)

        at java.net.URLClassLoader.findClass(URLClassLoader.java:188)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:307)

        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)

        at java.lang.ClassLoader.loadClass(ClassLoader.java:252)

        at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)

Could not find the main class: MsmqSendReceivePerformanceTest.java.  Program wil

l exit.

Am I running it incorrectly?