CollectCollectionSourceConnectorCommand

// Id: 1fae561a-8d65-4150-8f57-7476b41e08e8
using Api.Code;

var hangfireBackgroundCommandHandler = Activate<HangfireBackgroundCommandHandler>();
await hangfireBackgroundCommandHandler.DispatchOnQueue(
    "CollectCollectionSourceConnectorCommand",
    "Utopia.Contracts.CollectionSourceConnectors.CollectCollectionSourceConnectorCommand, Utopia.Contracts, Version=0.12.1622.0, Culture=neutral, PublicKeyToken=null",
    "{"ConnectorId":"23b43bb8-e511-4858-aee8-5c0fe2c5d4e2"}");

Parameters

CurrentCulture
""
CurrentUICulture
""
QueueName
"005_sourceconnectors"

State

11/26/2024 20:08:18 (+45.506s) Failed

Failed to change state to a 'Failed' one due to an exception after 10 retry attempts

MySql.Data.MySqlClient.MySqlException

Unable to connect to any of the specified MySQL hosts.

MySql.Data.MySqlClient.MySqlException: Unable to connect to any of the specified MySQL hosts. ---> System.Net.Internals.SocketExceptionFactory+ExtendedSocketException: Connection refused 10.152.183.230:3306
   at System.Net.Sockets.Socket.EndConnect(IAsyncResult asyncResult)
   at System.Net.Sockets.Socket.DoMultipleAddressConnectCallback(Object result, Socket.MultipleAddressConnectAsyncResult context)
   at System.Net.Sockets.Socket.DoMultipleAddressConnectCallback(Object result, Socket.MultipleAddressConnectAsyncResult context)
   at System.Net.Sockets.Socket.MultipleAddressConnectCallback(IAsyncResult result)
   at System.Net.Sockets.Socket.EndConnect(IAsyncResult asyncResult)
   at System.Net.Sockets.TcpClient.EndConnect(IAsyncResult asyncResult)
   at System.Net.Sockets.TcpClient.<>c.<ConnectAsync>b__28_1(IAsyncResult asyncResult)
   at System.Threading.Tasks.TaskFactory<TResult>.FromAsyncCoreLogic(IAsyncResult iar, Func<IAsyncResult, TResult> endFunction, Action<IAsyncResult> endAction, Task<TResult> promise, Boolean requiresSynchronization)
   --- End of inner exception stack trace ---
   at MySql.Data.MySqlClient.NativeDriver.<>c.<Open>b__40_0(Exception ex)
   at System.AggregateException.Handle(Func<Exception, Boolean> predicate)
   at MySql.Data.MySqlClient.NativeDriver.Open()
   at MySql.Data.MySqlClient.Driver.Open()
   at MySql.Data.MySqlClient.Driver.Create(MySqlConnectionStringBuilder settings)
   at MySql.Data.MySqlClient.MySqlPool.CreateNewPooledConnection()
   at MySql.Data.MySqlClient.MySqlPool.GetPooledConnection()
   at MySql.Data.MySqlClient.MySqlPool.TryToGetDriver()
   at MySql.Data.MySqlClient.MySqlPool.GetConnection()
   at MySql.Data.MySqlClient.MySqlConnection.Open()
   at MySql.Data.MySqlClient.MySqlConnection.<OpenAsync>b__78_0()
   at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(Thread threadPoolThread, ExecutionContext executionContext, ContextCallback callback, Object state)
   at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread)
   at ElmahCore.MySql.LogRepository.ExecuteNonQueryAsync(MySqlCommand command)
   at ElmahCore.MySql.LogRepository.EnsureCreated()
   at ElmahCore.MySql.LogRepository.LogAsync(Guid id, Error error)
   at ElmahCore.MySql.LogRepository.Log(Guid id, Error error)
   at ElmahCore.MySql.MySqlErrorLog.Log(Error error)
   at Api.Code.ElmahJobFilterAttribute.OnStateElection(ElectStateContext context) in /src/Api/Code/HangfireConfiguration.cs:201
   at Hangfire.States.StateMachine.InvokeOnStateElection(Tuple<IElectStateFilter, ElectStateContext> x)

+27ms Processing

Server:
utopia-microservices-7fc5dfffcb-xk8d6:sourcing:1
Worker:
ba357c34

+23ms Enqueued

11/26/2024 20:07:32 Created