[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    Re: .Net consumer is not at all receiving message
From:       Clebert Suconic <clebert.suconic () gmail ! com>
Date:       2017-03-26 10:57:20
Message-ID: CAKF+bsrj0KhW93Z_QQeKswB8cwbeZtsag0eiD7G=7-a-o1+4Lg () mail ! gmail ! com
[Download RAW message or body]


61616 is an Artemis port.  Can u try a build from master if it's Artemis ?


On Sat, Mar 25, 2017 at 6:59 PM Timothy Bish <tabish121@gmail.com> wrote:

> On 03/24/2017 07:39 AM, Logeshwaran wrote:
> > Hi,
> > I am new to ActiveMQ. I am just trying examples which is given by
> ActiveMQ.
> >
> > Producer is working fine but consumer is not at all receiving message
> >
> > Following is my code
> >
> > using Apache.NMS;
> > using Apache.NMS.Util;
> > using System;
> > using System.Collections.Generic;
> > using System.Linq;
> > using System.Text;
> > using System.Threading.Tasks;
> >
> > namespace ConsoleApplication1
> > {
> >      class Program
> >      {
> >          static void Main(string[] args)
> >          {
> >              try
> >              {
> >                  Uri connecturi = new Uri("tcp://localhost:61616");
> >
> >                  Console.WriteLine("About to connect to " + connecturi);
> >                  IConnectionFactory factory = new
> > NMSConnectionFactory(connecturi);
> >
> >                  using (IConnection connection =
> factory.CreateConnection())
> >                  using (ISession session = connection.CreateSession())
> >                  {
> >
> >                      IDestination destination =
> > SessionUtil.GetDestination(session, "TestExample");
> >                      Console.WriteLine("Using destination: " +
> destination);
> >
> >                      // Create a consumer and producer
> >
> >                      using (IMessageProducer producer =
> > session.CreateProducer(destination))
> >                      using (IMessageConsumer consumer =
> > session.CreateConsumer(destination))
> >                      {
> >                          // Start the connection so that messages will be
> > processed.
> >                          connection.Start();
> >                            producer.DeliveryMode =
> > MsgDeliveryMode.Persistent;
> >                          // 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);
> >                          }
> >                      }
> >                  }
> >              }
> >              catch (Exception e)
> >              {
> >                  Console.WriteLine(e.Message);
> >              }
> >          }
> >      }
> > }
> > <http://activemq.2283324.n4.nabble.com/file/n4724094/QueueStatus.png>
> > <
> http://activemq.2283324.n4.nabble.com/file/n4724094/waitingForResponse.png
> >
> >
> > Thanks in advance
> >
> >
> >
> > --
> > View this message in context:
> http://activemq.2283324.n4.nabble.com/Net-consumer-is-not-at-all-receiving-message-tp4724094.html
> > Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
> >
>
> Have you checked that there isn't another consumer listening on that
> Queue stealing your messages?
>
> --
> Tim Bish
> twitter: @tabish121
> blog: http://timbish.blogspot.com/
>
> --
Clebert Suconic


[prev in list] [next in list] [prev in thread] [next in thread] 

Configure | About | News | Add a list | Sponsored by KoreLogic