activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tabish...@gmail.com>
Subject Re: No IConnectionFactory implementation found for connection URI: activemq:tcp://localhost:61616
Date Tue, 09 Apr 2013 00:23:19 GMT
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.bish@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/


Mime
View raw message