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). ________________________________
