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<mailto:nawazali.sh...@sainsburys.co.uk> | 
Mobile: +44-7405734657
[cid:image001.jpg@01D84B56.55235840]
 www.sainsburys.co.uk<http://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).

________________________________

Reply via email to