I might be overlooking something, but that sounds like a bug. Would you be willing to submit a bug in JIRA for this, including a simple reproducer?
Tim On Wed, Apr 13, 2022, 6:37 AM NawazAli Shaik < nawazali.sh...@sainsburys.co.uk> wrote: > Hi Tim, > > Thanks for responding. We are able to resolve the issue by creating > connection and session for each queue separately later the error stopped > coming in the consumer. > > NMS client with single connection and single session with transaction to > consume from multiple queues is not working properly. > > Thanks & Regards, > Nawaz Ali Shaik > Integration Support | Digital & Technology Service Operations > Sainsbury's Supermarkets Ltd | Walsgrave,Coventry > nawazali.sh...@sainsburys.co.uk | Mobile: +44-7405734657 > > www.sainsburys.co.uk > > > -----Original Message----- > From: Tim Bain <tb...@alumni.duke.edu> > Sent: 13 April 2022 13:33 > To: ActiveMQ Users <users@activemq.apache.org> > Subject: Re: apache active mqueue nms client throwing exception > > ________________________________ > > CAUTION: This message was sent to you from outside of the organisation. Do > not click links or open attachments unless you are expecting the email and > know the content is safe. > > ________________________________ > > This isn't something I've seen reported for non-NMS clients, and it's my > understanding that the NMS client gets a lot less use than the JMS client > so it's entirely possible that there's a bug in the NMS client that no one > has detected till now. > > Are you able to reproduce this reliably? If so, please create a bug in > JIRA for the issue and include any config/code needed to reproduce the > issue. If not, can you tell us more about the conditions under which you've > seen it occur? Also, what version of the NMS client are you using? > > Tim > > On Fri, Apr 8, 2022, 7:38 AM NawazAli Shaik < > nawazali.sh...@sainsburys.co.uk> > wrote: > > > Hi Team, > > > > > > > > We are facing issues with one of the .net consumer when they connects > > to broker with transactions it is throwing exception while committing > > the message. > > > > > > > > Below is the consumer error: > > > > > > > > An error occurred receiving the message > > > > Apache.NMS.IllegalStateException: Commit called with no active > > Transaction. > > > > at > > Apache.NMS.AMQP.Provider.Amqp.AmqpTransactionContext.Commit(NmsTransac > > tionInfo transactionInfo, NmsTransactionInfo nextTransactionInfo) > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > at Apache.NMS.AMQP.NmsSession.CommitAsync() > > > > at > > Stock.Transformation.ProducerService.Subscribers.EnterpriseSubscriber. > > Start(CancellationToken > > cancellationToken) in > > /app/producer/Stock.Transformation.ProducerService/Subscribers/Enterpr > > iseSubscriber.cs:line > > 68 > > > > [41m[30mfail[39m[22m[49m: > > Stock.Transformation.ProducerService.Subscribers.EnterpriseSubscriber[ > > 0] > > > > An error occurred receiving the message > > > > Apache.NMS.IllegalStateException: Commit called with no active > > Transaction. > > > > at > > Apache.NMS.AMQP.Provider.Amqp.AmqpTransactionContext.Commit(NmsTransac > > tionInfo transactionInfo, NmsTransactionInfo nextTransactionInfo) > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > at Apache.NMS.AMQP.NmsSession.CommitAsync() > > > > at > > Stock.Transformation.ProducerService.Subscribers.EnterpriseSubscriber. > > Start(CancellationToken > > cancellationToken) in > > /app/producer/Stock.Transformation.ProducerService/Subscribers/Enterpr > > iseSubscriber.cs:line > > 68 > > > > [41m[30mfail[39m[22m[49m: > > Stock.Transformation.ProducerService.Subscribers.EnterpriseSubscriber[ > > 0] > > > > An error occurred receiving the message > > > > Apache.NMS.NMSException: Received an unexpected EOF or 0 bytes > > from the transport stream. > > > > ---> Amqp.AmqpException: Received an unexpected EOF or 0 bytes > > from the transport stream. > > > > at > > Apache.NMS.AMQP.Provider.Amqp.AmqpTransactionCoordinator.DeclareAsync( > > ) > > > > at > > Apache.NMS.AMQP.Provider.Amqp.AmqpTransactionContext.Begin(NmsTransact > > ionInfo > > transactionInfo) > > > > at > > Apache.NMS.AMQP.Provider.Amqp.AmqpTransactionContext.Commit(NmsTransac > > tionInfo transactionInfo, NmsTransactionInfo nextTransactionInfo) > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > --- End of inner exception stack trace --- > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > at Apache.NMS.AMQP.NmsLocalTransactionContext.Commit() > > > > at Apache.NMS.AMQP.NmsSession.CommitAsync() > > > > at > > Stock.Transformation.ProducerService.Subscribers.EnterpriseSubscriber. > > Start(CancellationToken > > cancellationToken) in > > /app/producer/Stock.Transformation.ProducerService/Subscribers/Enterpr > > iseSubscriber.cs:line > > 68 > > > > > > > > > > > > At broker side we are seeing the below error: > > > > > > > > org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ > > Transport: ssl:///X.X.X.X:13361 > > > > org.apache.activemq.transport.amqp.AmqpProtocolException: Could not > > process AMQP commands > > > > at > > org.apache.activemq.transport.amqp.protocol.AmqpConnection.processProt > > onEvents(AmqpConnection.java:442)[activemq-amqp-5.16.3.jar:5.16.3] > > > > at > > org.apache.activemq.transport.amqp.protocol.AmqpConnection.onAMQPData( > > AmqpConnection.java:386)[activemq-amqp-5.16.3.jar:5.16.3] > > > > at > > org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpT > > ransportFilter.java:107)[activemq-amqp-5.16.3.jar:5.16.3] > > > > at > > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupp > > ort.java:83)[activemq-client-5.16.3.jar:5.16.3] > > > > at > > org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport. > > java:171)[activemq-client-5.16.3.jar:5.16.3] > > > > at > > org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java > > :233)[activemq-client-5.16.3.jar:5.16.3] > > > > at > > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:2 > > 15)[activemq-client-5.16.3.jar:5.16.3] > > > > at java.lang.Thread.run(Thread.java:750)[:1.8.0_322] > > > > > > > > > > > > Could you please let me know whether we need to add anything at broker > > configurations to avoid the issue? > > > > > > > > Thanks & Regards, > > > > Nawaz Ali Shaik > > > > Integration Support | Digital & Technology Service Operations > > > > Sainsbury's Supermarkets Ltd | Walsgrave,Coventry > > > > nawazali.sh...@sainsburys.co.uk | Mobile: +44-7405734657 > > > > www.sainsburys.co.uk > > > > > > > > > > ------------------------------ > > > > > > This email and any files transmitted with it are confidential and > > intended solely for the use of the individual or entity to whom they are > addressed. > > If you have received this email in error please notify the system > > manager ( > > postmas...@sainsburys.co.uk) and delete it from your system. > > > > Sainsbury's Supermarkets Ltd (3261722 England) Registered Offices: 33 > > Holborn, London, EC1N 2HT > > > > Sainsbury’s Argos is a trading name of both: > > 1) Argos Limited, Registered office: 489-499 Avebury Boulevard, Milton > > Keynes, United Kingdom, MK9 2NW, registered number: 01081551 (England > > and Wales); and > > 2) Sainsbury’s Supermarkets Limited, Registered office: 33 Holborn, > > London, EC1N 2HT, registered number: 03261722 (England and Wales). > > > > All companies listed above are subsidiaries of J Sainsbury plc (185647). > > ------------------------------ > > > ________________________________ > > This footnote confirms that this email message has been swept by > Sainsbury's systems for the presence of computer viruses. Although no > viruses were detected, it is no guarantee that this message is virus-free. > Please direct any concerns regarding suspicious email to the STSD. > > ________________________________ > ________________________________ > > This email and any files transmitted with it are confidential and intended > solely for the use of the individual or entity to whom they are addressed. > If you have received this email in error please notify the system manager ( > postmas...@sainsburys.co.uk) and delete it from your system. > > Sainsbury's Supermarkets Ltd (3261722 England) > Registered Offices: 33 Holborn, London, EC1N 2HT > > Sainsbury’s Argos is a trading name of both: > 1) Argos Limited, Registered office: 489-499 Avebury Boulevard, Milton > Keynes, United Kingdom, MK9 2NW, registered number: 01081551 (England and > Wales); and > 2) Sainsbury’s Supermarkets Limited, Registered office: 33 Holborn, > London, EC1N 2HT, registered number: 03261722 (England and Wales). > > All companies listed above are subsidiaries of J Sainsbury plc (185647). > ________________________________ >
