Service is launched successfully and consumers connected to queues. However, after around an hour or so we would find that the consumers on the journey.welcome.request queue would disappear however the other journey queue were reflecting the consumers fine.

What we found was the queue worker process would die (as per screenshot) the only way to get the consumers back was to restart the warewolf server service

2023-04-21 12:49:07,354 INFO - [00000000-0000-0000-0000-000000000000] - Trigger restarting '05c7daf0-3a79-410e-b101-0c9addf63136'
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - Logging Server OnError, Error details:Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host.
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - 4/21/2023 12:49:07 PM [Debug] Error while reading System.IO.IOException: Unable to read data from the transport connection: An existing connection was forcibly closed by the remote host. ---> System.Net.Sockets.SocketException: An existing connection was forcibly closed by the remote host
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - at System.Net.Sockets.Socket.EndReceive(IAsyncResult asyncResult)
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - at System.Net.Sockets.NetworkStream.EndRead(IAsyncResult asyncResult)
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - --- End of inner exception stack trace ---
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - at System.Net.Sockets.NetworkStream.EndRead(IAsyncResult asyncResult)
2023-04-21 12:49:07,573 INFO - [WarewolfLogger.exe] - at System.Threading.Tasks.TaskFactory`1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization)
2023-04-21 12:49:07,588 INFO - [Warewolf Info] - queue process died: Journey Start Trigger(05c7daf0-3a79-410e-b101-0c9addf63136)
2023-04-21 12:49:07,729 ERROR - [ at System.Diagnostics.Process.Kill()

What we tried to do was to increase the concurrency to 3 and set the prefetch to 1, and we still experienced the same issue

On deeper investigation it appeared that if the message being process was unable to reach the external api’s for any reason for instance the product api, it would kill the consumers, we tested this by correlating the timelines of when the “product” api was available to when the consumers disappear.

Once we had the “product” api stabilized consumers were stable and remained present

So appears to be a bug with the queue worker when it is unable to process the message correct caused this to crash

My understanding of this is:

• Error was experienced during processing of the message
• That message which is an unack message with the error did not leave RabbitMQ due to the fact that it never received an ack back from warewolf.
• RabbitMQ did not allow additional messages to be processed due to not receiving the ack back (aka message stuck)
• Appear to be the way that warewolf error handling works where it does not send through the ack even if an error was experienced with the message.

SQL Server source returning "Object reference not set to an instance of an object" in version 2.8.1.42. The same workflow returns an actual value in previous versions. Tested successfully on 2.8.1.3.

A tool or source that could do OAuth2 authentication and then be used by those APIs that need it.

Exists any possibility how to execute more command during one connection? I mean 2 stored procedures ....
Thanks

Hi, 

I have a problem with the stored procedure on the MSSQL server. I did it the same way as in the tutorial PDF, but with a different database. When I want to debug the flow, I only get the following error message: The command sent to ExecuteXmlReader is invalid. The command must return an XML result.

Thanks in advance.

I've been trying to use SQL Bulk Insert service however with Oracle i unable to choose table:

Hi. Why when I create Oracle database source the database choices are limited to HR, SCOTT, OE, PM, SH and IX

There should be user that i create as database. For example, there be include 'SPBO2' as if in normal oracle query it will be SELECT * FROM SPBO2.TABLENAME

Thank you

I want to connect to New Datasource Database in Oracle.

The info as below

IP address : 192.168.50.30

Operating platform : Windows Server 2012 R2 Standard

Database/OraClient installed : Oracle 11g R2 Client 64bit

user: orcluser

password: orclpassword

SID: orcl

port: 1521

How to setup the oracle connection?