1 2 Previous Next 17 Replies Latest reply on Jul 9, 2009 1:13 AM by Claus Ibsen

    MSMQ - > ACTIVEMQ?

    Song Wong Newbie

      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..

        • 1. Re: MSMQ - > ACTIVEMQ?
          Song Wong Newbie

          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.

          • 2. Re: MSMQ - > ACTIVEMQ?
            Claus Ibsen Master

            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).

            • 3. Re: MSMQ - > ACTIVEMQ?
              Song Wong Newbie

              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..

              • 4. Re: MSMQ - > ACTIVEMQ?
                Willem Jiang Master

                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/

                • 5. Re: MSMQ - > ACTIVEMQ?
                  Claus Ibsen Master

                  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

                  • 6. Re: MSMQ - > ACTIVEMQ?
                    Song Wong Newbie

                    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!!

                    • 7. Re: MSMQ - > ACTIVEMQ?
                      Song Wong Newbie

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

                       

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

                      • 8. Re: MSMQ - > ACTIVEMQ?
                        Claus Ibsen Master

                        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

                        • 9. Re: MSMQ - > ACTIVEMQ?
                          Claus Ibsen Master

                          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

                          • 10. Re: MSMQ - > ACTIVEMQ?
                            Claus Ibsen Master

                            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.

                            • 11. Re: MSMQ - > ACTIVEMQ?
                              Song Wong Newbie

                              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!!

                              • 12. Re: MSMQ - > ACTIVEMQ?
                                Song Wong Newbie

                                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

                                • 13. Re: MSMQ - > ACTIVEMQ?
                                  Willem Jiang Master

                                  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

                                  • 14. Re: MSMQ - > ACTIVEMQ?
                                    Song Wong Newbie

                                    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?

                                    1 2 Previous Next