求高手 求C#连接ActiveMQ的代码 或者 DLL

Question

求 C#连接ActiveMQ的代码 或者 DLL 我现在用的nms连接ActiveMQ服务器, public void dsds()
        {
            string sb = "123456789";
            Uri connecturi = new Uri("tcp://192.102.187.54:61616");
            IConnectionFactory factory = new NMSConnectionFactory(connecturi);
            using(IConnection connection = factory.CreateConnection())
            using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
            {
                IDestination destination = SessionUtil.GetDestination(session, "queue://textMQ");
                 using (IMessageConsumer consumer = session.CreateConsumer(destination))
                 using (IMessageProducer producer = session.CreateProducer(destination))
                 {
                     connection.Start();
                     producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
                     #region text                     ITextMessage request = session.CreateTextMessage(sb.ToString());
                     
                     producer.Send(request);
                     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);
                     }
                     #endregion
                 }
            }
            //ActiveMQTopic 
        }红色的部分的是报错 连接不上  服务端接收是Java写的

Answer 1

额 没人回答 但是已经解决了 分享出来吧//首先 需要两个DLL,Apache.NMS.ActiveMQ.dll和Apache.NMS.dll
//下载地址http://www.springframework.net/download.html
//最新版本 也可以 一般都是向下兼容 这里 我只涉及到发送和接收 所以没有搭建服务器,建议搭建服务器
//activeMQ 下载地址http://activemq.apache.org/nms/download.html
//具体代码为:
static void Main(string[] args)
        {
            string sb = "1,2,3";
            Uri connecturi = new Uri("tcp://10.10.10.10:61616");
            IConnectionFactory factory = new NMSConnectionFactory(connecturi);
            using(IConnection connection = factory.CreateConnection())   
            using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
            {                Console.WriteLine("Created a connection!");
                ActiveMQTopic MQTopic = (ActiveMQTopic)session.GetTopic("mbaobaoNet");
                IDestination destination = SessionUtil.GetDestination(session, "queue://mbaobaoNet");
                //IDestination destination1 = SessionUtil.GetDestination(session, "queue://mbaobaoNet1");
                //using (IMessageConsumer consumer = session.CreateConsumer(destination1))
                using (IMessageProducer producer = session.CreateProducer(destination))
                {
                    connection.Start();
                    producer.DeliveryMode = MsgDeliveryMode.NonPersistent;
                    
                        ITextMessage request = session.CreateTextMessage(sb.ToString());
                        producer.Send(request);
               
                    //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);
                    //}                }
            }
        }
//注销的部分为接收端

Answer 2

使用VS2010，引用两个DLL文件，为什么编译的时候总是报错？楼主有没有这个情况