Re: No IConnectionFactory implementation found for connection URI: activemq:tcp://localhost:61616

[Timothy Bish]

You need the Apache ActiveMQ NMS Provider.
http://activemq.apache.org/nms/apachenmsactivemq-v156.html


On 04/08/2013 07:44 PM, JavyRocks wrote:

*I still get the "No IConnectionFactory implementation found for connection
URI: activemq:tcp://localhost:61616" Error. I've paste and include in the
compile project the archive "nmsprovider-activemq.config"
I'm Working with .NET 4.0 and the references are
Apache.NMS-1.5.1-bin.zip\net-4.0\release

The code is very estandar and simple but I can't get throw the connection
error*

     using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Apache.NMS;
using Apache.NMS.Util;
using System.Collections;
using System.Reflection;
using System.IO;

namespace ConexionActiveMQ
{
     class Program
     {
         private static string[] GetConfigSearchPaths()
         {
             ArrayList pathList = new ArrayList();

             // Check the current folder first.
             pathList.Add("");
             AppDomain currentDomain = AppDomain.CurrentDomain;

             // Check the folder the assembly is located in.

pathList.Add(Path.GetDirectoryName(Assembly.GetExecutingAssembly().Location));

             if (null != currentDomain.BaseDirectory)
             {
                 pathList.Add(currentDomain.BaseDirectory);
             }

             if (null != currentDomain.RelativeSearchPath)
             {
                 pathList.Add(currentDomain.RelativeSearchPath);
             }

             return (string[])pathList.ToArray(typeof(string));
         }

         static void Main(string[] args)
         {
             string[] direcciones;
             direcciones = GetConfigSearchPaths();
             // Example connection strings:
             //    activemq:tcp://localhost:61616
             //    stomp:tcp://activemqhost:61613
             //    ems:tcp://tibcohost:7222
             //    msmq://localhost

             Uri connecturi = new Uri("activemq:tcp://localhost:61616");

             Console.WriteLine("About to connect to " + connecturi);

             // NOTE: ensure the nmsprovider-activemq.config file exists in
the executable folder.
             IConnectionFactory factory = new
NMSConnectionFactory(connecturi);

             using (IConnection connection = factory.CreateConnection())
             using (ISession session = connection.CreateSession())
             {
                 // Examples for getting a destination:
                 //
                 // Hard coded destinations:
                 //    IDestination destination =
session.GetQueue("FOO.BAR");
                 //    Debug.Assert(destination is IQueue);
                 //    IDestination destination =
session.GetTopic("FOO.BAR");
                 //    Debug.Assert(destination is ITopic);
                 //
                 // Embedded destination type in the name:
                 //    IDestination destination =
SessionUtil.GetDestination(session, "queue://FOO.BAR");
                 //    Debug.Assert(destination is IQueue);
                 //    IDestination destination =
SessionUtil.GetDestination(session, "topic://FOO.BAR");
                 //    Debug.Assert(destination is ITopic);
                 //
                 // Defaults to queue if type is not specified:
                 //    IDestination destination =
SessionUtil.GetDestination(session, "FOO.BAR");
                 //    Debug.Assert(destination is IQueue);
                 //
                 // .NET 3.5 Supports Extension methods for a simplified
syntax:
                 //    IDestination destination =
session.GetDestination("queue://FOO.BAR");
                 //    Debug.Assert(destination is IQueue);
                 //    IDestination destination =
session.GetDestination("topic://FOO.BAR");
                 //    Debug.Assert(destination is ITopic);

                 IDestination destination =
SessionUtil.GetDestination(session, "queue://FOO.BAR");
                 Console.WriteLine("Using destination: " + destination);

                 // Create a consumer and producer
                 using (IMessageConsumer consumer =
session.CreateConsumer(destination))
                 using (IMessageProducer producer =
session.CreateProducer(destination))
                 {
                     // Start the connection so that messages will be
processed.
                     connection.Start();
                     //producer.Persisten = true;

                     // Send a message
                     ITextMessage request = session.CreateTextMessage("Hello
World!");
                     request.NMSCorrelationID = "abc";
                     request.Properties["NMSXGroupID"] = "cheese";
                     request.Properties["myHeader"] = "Cheddar";

                     producer.Send(request);

                     // Consume a message
                     ITextMessage message = consumer.Receive() as
ITextMessage;
                     if (message == null)
                     {
                         Console.WriteLine("No message received!");
                     }
                     else
                     {
                         Console.WriteLine("Received message with ID:   " +
message.NMSMessageId);
                         Console.WriteLine("Received message with text: " +
message.Text);
                     }
                 }
             }
         }
     }
}




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/No-IConnectionFactory-implementation-found-for-connection-URI-activemq-tcp-localhost-61616-tp4665743.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

--
Tim Bish
Sr Software Engineer | RedHat Inc.
tim.b...@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/