Threading issue when using Unity container and satellites

Björn Bailleul

unread,

Feb 26, 2014, 5:16:59 AM2/26/14

to particula...@googlegroups.com

It seems there's an issues when using a Unity 2.x container and starting satellites. We use a lot of injection in our handlers and in our production environment we see that the parallel tasks for starting satellites poses an issue on startup. In special the second level retry processor satellite. The results in the second level retry processor not starting correctly and not handling its queue.

Any ideas on how to solve this?

Helpful information to include

Product name: NServiceBus

Version: 4.0.4

Stacktrace:

2014-02-25 16:25:25,726 [21] DEBUG NServiceBus.Satellites.SatelliteLauncher [(null)] - Starting 1/3 'NServiceBus.SecondLevelRetries.SecondLevelRetriesProcessor, NServiceBus.Core, Version=4.0.0.0, Culture=neutral, PublicKeyToken=9fc386479f8a226c' satellite

2014-02-25 16:25:25,726 [22] DEBUG NServiceBus.Unicast.UnicastBus [(null)] - Started NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions.StorageInitializer, NServiceBus.Core, Version=4.0.0.0, Culture=neutral, PublicKeyToken=9fc386479f8a226c.

2014-02-25 16:25:25,742 [8] DEBUG Pms.Framework.Unity.UnityServiceHostFactory [(null)] - Creating service host for server AdminService with Uri's http://----.com/services/application/AdminService.svc,

2014-02-25 16:25:25,742 [21] ERROR NServiceBus.Unicast.UnicastBus [(null)] - System.AggregateException: One or more errors occurred. ---> Microsoft.Practices.Unity.ResolutionFailedException: Resolution of the dependency failed, type = "NServiceBus.Unicast.Transport.TransportReceiver", name = "(none)".

Exception occurred while: while resolving.

Exception is: InvalidOperationException - Collection was modified; enumeration operation may not execute.

-----------------------------------------------

At the time of the exception, the container was:

Resolving NServiceBus.Unicast.Transport.TransportReceiver,(none)

---> System.InvalidOperationException: Collection was modified; enumeration operation may not execute.

at System.ThrowHelper.ThrowInvalidOperationException(ExceptionResource resource)

at System.Collections.Generic.Dictionary`2.KeyCollection.Enumerator.MoveNext()

at Microsoft.Practices.Unity.UnityContainer.FillTypeRegistrationDictionary(IDictionary`2 typeRegistrations)

at Microsoft.Practices.Unity.UnityContainer.get_Registrations()

at Microsoft.Practices.Unity.UnityContainerExtensions.IsRegistered(IUnityContainer container, Type typeToCheck, String nameToCheck)

at Microsoft.Practices.Unity.UnityContainerExtensions.IsRegistered(IUnityContainer container, Type typeToCheck)

at NServiceBus.ObjectBuilder.Unity.PropertyInjectionBuilderStrategy.PreBuildUp(IBuilderContext context)

at Microsoft.Practices.ObjectBuilder2.StrategyChain.ExecuteBuildUp(IBuilderContext context)

at Microsoft.Practices.Unity.UnityContainer.DoBuildUp(Type t, Object existing, String name, IEnumerable`1 resolverOverrides)

--- End of inner exception stack trace ---

at Microsoft.Practices.Unity.UnityContainer.DoBuildUp(Type t, Object existing, String name, IEnumerable`1 resolverOverrides)

at Microsoft.Practices.Unity.UnityContainer.Resolve(Type t, String name, ResolverOverride[] resolverOverrides)

at Microsoft.Practices.Unity.UnityContainerExtensions.Resolve(IUnityContainer container, Type t, ResolverOverride[] overrides)

at NServiceBus.ObjectBuilder.Unity.UnityObjectBuilder.Build(Type typeToBuild)

at NServiceBus.ObjectBuilder.Common.CommonObjectBuilder.NServiceBus.ObjectBuilder.IBuilder.Build[T]()

at NServiceBus.Satellites.SatelliteLauncher.<>c__DisplayClass4.<Start>b__2(Int32 index)

at System.Threading.Tasks.Parallel.<>c__DisplayClassf`1.<ForWorker>b__c()

at System.Threading.Tasks.Task.InnerInvoke()

at System.Threading.Tasks.Task.InnerInvokeWithArg(Task childTask)

at System.Threading.Tasks.Task.<>c__DisplayClass11.<ExecuteSelfReplicating>b__10(Object param0)

--- End of inner exception stack trace ---

at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions)

at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken cancellationToken)

at System.Threading.Tasks.Task.Wait()

at System.Threading.Tasks.Parallel.ForWorker[TLocal](Int32 fromInclusive, Int32 toExclusive, ParallelOptions parallelOptions, Action`1 body, Action`2 bodyWithState, Func`4 bodyWithLocal, Func`1 localInit, Action`1 localFinally)

at System.Threading.Tasks.Parallel.For(Int32 fromInclusive, Int32 toExclusive, Action`1 body)

at NServiceBus.Satellites.SatelliteLauncher.Start()

at NServiceBus.Unicast.UnicastBus.<>c__DisplayClass18.<Start>b__16()

---> (Inner Exception #0) Microsoft.Practices.Unity.ResolutionFailedException: Resolution of the dependency failed, type = "NServiceBus.Unicast.Transport.TransportReceiver", name = "(none)".