duh, thanks
semog wrote:
>
> I'm not sure how this worked in Java, but the way I read the code, the
> behavior you are describing is not surprising. There is nothing in the
> run() function to keep that thread alive after it has received one
> message.
> I would expect it to terminate after receiving the message. To keep it
> alive and processing more messages, you will need some kind of looping
> mechanism.
>
> On Wed, Jan 27, 2010 at 5:01 PM, slyfox <bobby.richa...@gmail.com> wrote:
>
>>
>> Working fine in java but switched a client over to C#, producer worked,
>> consumer works, just dies after 1 message:
>>
>> ##############################
>> using System;
>> using System.Collections.Generic;
>> using System.Linq;
>> using System.Text;
>> using System.Threading;
>> using Apache.NMS;
>> using Apache.NMS.ActiveMQ;
>> using Apache.NMS.Util;
>>
>> namespace QuoteProvider
>> {
>> public class JMSQuoteProvider : IJMSQuoteSource
>> {
>> protected static AutoResetEvent semaphore = new
>> AutoResetEvent(false);
>> protected static ITextMessage message = null;
>> protected static TimeSpan receiveTimeout =
>> TimeSpan.FromSeconds(10);
>>
>> public event Action<IncomingQuote> QuoteArrived;
>>
>> public JMSQuoteProvider()
>> {
>> Thread JMSQuotes = new Thread(new ThreadStart(run));
>> JMSQuotes.IsBackground = true;
>> JMSQuotes.Priority = ThreadPriority.Normal;
>> JMSQuotes.Start();
>> }
>>
>> private void run()
>> {
>> Uri connecturi = new
>> Uri("activemq:tcp://127.0.0.1:61616?consumer.dispatchAsync=true");
>> IConnectionFactory factory = new
>> NMSConnectionFactory(connecturi);
>> using (IConnection connection = factory.CreateConnection())
>> using (ISession session = connection.CreateSession())
>> {
>> IDestination destination = session.GetTopic("PX.UPDATE");
>>
>> using (IMessageConsumer consumer =
>> session.CreateConsumer(destination))
>> {
>> connection.Start();
>>
>> consumer.Listener += new MessageListener(OnMessage);
>>
>> semaphore.WaitOne();
>> if (message != null)
>> {
>> crack(message.Text.ToString());
>> }
>>
>> }
>> }
>> }
>>
>> private void crack(String msg)
>> {
>> // crack logic //
>>
>> IncomingQuote tempQuote = new IncomingQuote(symbol, bid, ask,
>> stamp);
>> QuoteArrived(tempQuote);
>> }
>>
>> protected static void OnMessage(IMessage receivedMsg)
>> {
>> message = receivedMsg as ITextMessage;
>> semaphore.Set();
>> }
>>
>> #region IJMSQuoteSource Members
>>
>> protected virtual void OnQuoteArrived(IncomingQuote quote)
>> {
>> if (QuoteArrived != null)
>> QuoteArrived(quote);
>> }
>>
>> #endregion
>>
>> }
>> }
>>
>>
>> --
>> View this message in context:
>> http://old.nabble.com/My-NMS-topic-consumer-dies-after-1-message-tp27349478p27349478.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>
>
--
View this message in context:
http://old.nabble.com/My-NMS-topic-consumer-dies-after-1-message-tp27349478p27351025.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
