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(NmsTransactionInfo > 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/EnterpriseSubscriber.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(NmsTransactionInfo > 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/EnterpriseSubscriber.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(NmsTransactionInfo > transactionInfo) > > at > Apache.NMS.AMQP.Provider.Amqp.AmqpTransactionContext.Commit(NmsTransactionInfo > 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/EnterpriseSubscriber.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.processProtonEvents(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(AmqpTransportFilter.java:107)[activemq-amqp-5.16.3.jar:5.16.3] > > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.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:215)[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). > ------------------------------ >
