Comments (14)
Also, this is causing the acceptance tests to hang.
So should we try/catch it?
from nservicebus.rabbitmq.
I think the test is wrong, since Rabbit needs to use the endpoint name during initalization we can't change it after:
I say we modify the test to use IWantToRunBeforeConfiguration instead
from nservicebus.rabbitmq.
We can try, but not sure it will fit the order for ASB's case.
from nservicebus.rabbitmq.
@yvesgoeleven ok, lets see if this breaks ASB instead :(
That said overriding local address seems like a think we want to do as early as possible?
from nservicebus.rabbitmq.
Not sure what the current situation is, but in the past getting timing for this setting right was a big pita as it was initialized rather late (and changed quite a few times over the past years)
from nservicebus.rabbitmq.
Have just tried the fix with IWantToRunBeforeConfiguration
and still no good.
I'm commenting out this test in the core till it actually works correctly against Rabbit
from nservicebus.rabbitmq.
Hmm, pretty sure it did work on the buildserver?
On Tue, Apr 29, 2014 at 9:46 AM, John Simons [email protected]:
Have just tried the fix with IWantToRunBeforeConfiguration and still no
good.
I'm commenting out this test in the core till it actually works correctly
against RabbitReply to this email directly or view it on GitHubhttps://github.com//issues/29#issuecomment-41649505
.
from nservicebus.rabbitmq.
Nope it fails locally for me, try it on your machine
On Tuesday, April 29, 2014, Andreas Öhlund [email protected] wrote:
Hmm, pretty sure it did work on the buildserver?
On Tue, Apr 29, 2014 at 9:46 AM, John Simons <[email protected]javascript:_e(%7B%7D,'cvml','[email protected]');
wrote:
Have just tried the fix with IWantToRunBeforeConfiguration and still no
good.
I'm commenting out this test in the core till it actually works correctly
against RabbitReply to this email directly or view it on GitHub<
#29 (comment).
Reply to this email directly or view it on GitHubhttps://github.com//issues/29#issuecomment-41661826
.
from nservicebus.rabbitmq.
@andreasohlund did u test this?
This is the exception I get locally:
RabbitMQ - Started @ 30/04/2014 9:03:04 AM
Failed to unload appdomain PubSub.Publisher.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ, reason: System.CannotUnloadAppDomainException: Error while unloading appdomain. (Exception from HRESULT: 0x80131015)
at System.AppDomain.Unload(AppDomain domain)
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.<UnloadAppDomains>b__17(ActiveRunner runner) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 197
Failed to unload appdomain PubSub.Subscriber1.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ, reason: System.CannotUnloadAppDomainException: Error while unloading appdomain. (Exception from HRESULT: 0x80131015)
at System.AppDomain.Unload(AppDomain domain)
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.<UnloadAppDomains>b__17(ActiveRunner runner) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 197
RabbitMQ - Finished @ 30/04/2014 9:03:39 AM
Test run aborted due to test failures
------------------------------------------------------
Test summary for: RabbitMQ
Using settings:
Transport: NServiceBus.RabbitMQ, NServiceBus.Transports.RabbitMQ, Version=1.2.0.0, Culture=neutral, PublicKeyToken=9fc386479f8a226c
Transport.ConnectionString: host=localhost
Endpoints:
- PubSub.Publisher.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ
- PubSub.Subscriber1.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ
Test failed: System.AggregateException: One or more errors occurred. ---> NServiceBus.AcceptanceTesting.Support.ScenarioException: Endpoint failed to start ---> RabbitMQ.Client.Exceptions.OperationInterruptedException: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=404, text="NOT_FOUND - no exchange 'PubSub.Subscriber1.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ' in vhost '/'", classId=40, methodId=30, cause=
at RabbitMQ.Client.Impl.SimpleBlockingRpcContinuation.GetReply()
at RabbitMQ.Client.Impl.ModelBase.ModelRpc(MethodBase method, ContentHeaderBase header, Byte[] body)
at RabbitMQ.Client.Framing.Impl.v0_9_1.Model._Private_ExchangeBind(String destination, String source, String routingKey, Boolean nowait, IDictionary`2 arguments)
at RabbitMQ.Client.Impl.ModelBase.ExchangeBind(String destination, String source, String routingKey)
at NServiceBus.Transports.RabbitMQ.Routing.ConventionalRoutingTopology.SetupSubscription(IModel channel, Type type, String subscriberName) in c:\Projects\NServiceBus.RabbitMQ\src\NServiceBus.RabbitMQ\Routing\ConventionalRoutingTopology.cs:line 33
at NServiceBus.Transports.RabbitMQ.RabbitMqSubscriptionManager.Subscribe(Type eventType, Address publisherAddress) in c:\Projects\NServiceBus.RabbitMQ\src\NServiceBus.RabbitMQ\RabbitMqSubscriptionManager.cs:line 18
at NServiceBus.Unicast.UnicastBus.Subscribe(Type messageType, Predicate`1 condition) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs:line 390
at NServiceBus.Unicast.UnicastBus.Subscribe(Type messageType) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs:line 343
at NServiceBus.Unicast.UnicastBus.Subscribe[T]() in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs:line 334
at NServiceBus.AcceptanceTests.PubSub.When_publishing_an_event_with_overridden_local_address.<Should_be_delivered_to_all_subscribers>b__4(IBus bus, Context context) in c:\Projects\NServiceBus.RabbitMQ\src\NServiceBus.RabbitMQ.AcceptanceTests\App_Packages\NServiceBus.AcceptanceTests\PubSub\When_publishing_an_event_with_overridden_local_address.cs:line 28
at NServiceBus.AcceptanceTesting.Support.GivenDefinition`1.<>c__DisplayClass2.<GetAction>b__1(IBus bus) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\EndpointBehaviour.cs:line 45
at NServiceBus.AcceptanceTesting.Support.EndpointRunner.Start() in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\EndpointRunner.cs:line 107
--- End of inner exception stack trace ---
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.<>c__DisplayClass22.<StartEndpoints>b__20() in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 274
at System.Threading.Tasks.Task.InnerInvoke()
at System.Threading.Tasks.Task.Execute()
--- End of inner exception stack trace ---
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, Int32 millisecondsTimeout)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, TimeSpan timeout)
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.StartEndpoints(IEnumerable`1 endpoints) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 269
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.PerformScenarios(RunDescriptor runDescriptor, IEnumerable`1 runners, Func`1 done) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 234
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.PerformTestRun(IList`1 behaviorDescriptors, IList`1 shoulds, RunDescriptor runDescriptor, Func`2 done) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 160
---> (Inner Exception #0) NServiceBus.AcceptanceTesting.Support.ScenarioException: Endpoint failed to start ---> RabbitMQ.Client.Exceptions.OperationInterruptedException: The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=404, text="NOT_FOUND - no exchange 'PubSub.Subscriber1.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ' in vhost '/'", classId=40, methodId=30, cause=
at RabbitMQ.Client.Impl.SimpleBlockingRpcContinuation.GetReply()
at RabbitMQ.Client.Impl.ModelBase.ModelRpc(MethodBase method, ContentHeaderBase header, Byte[] body)
at RabbitMQ.Client.Framing.Impl.v0_9_1.Model._Private_ExchangeBind(String destination, String source, String routingKey, Boolean nowait, IDictionary`2 arguments)
at RabbitMQ.Client.Impl.ModelBase.ExchangeBind(String destination, String source, String routingKey)
at NServiceBus.Transports.RabbitMQ.Routing.ConventionalRoutingTopology.SetupSubscription(IModel channel, Type type, String subscriberName) in c:\Projects\NServiceBus.RabbitMQ\src\NServiceBus.RabbitMQ\Routing\ConventionalRoutingTopology.cs:line 33
at NServiceBus.Transports.RabbitMQ.RabbitMqSubscriptionManager.Subscribe(Type eventType, Address publisherAddress) in c:\Projects\NServiceBus.RabbitMQ\src\NServiceBus.RabbitMQ\RabbitMqSubscriptionManager.cs:line 18
at NServiceBus.Unicast.UnicastBus.Subscribe(Type messageType, Predicate`1 condition) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs:line 390
at NServiceBus.Unicast.UnicastBus.Subscribe(Type messageType) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs:line 343
at NServiceBus.Unicast.UnicastBus.Subscribe[T]() in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs:line 334
at NServiceBus.AcceptanceTests.PubSub.When_publishing_an_event_with_overridden_local_address.<Should_be_delivered_to_all_subscribers>b__4(IBus bus, Context context) in c:\Projects\NServiceBus.RabbitMQ\src\NServiceBus.RabbitMQ.AcceptanceTests\App_Packages\NServiceBus.AcceptanceTests\PubSub\When_publishing_an_event_with_overridden_local_address.cs:line 28
at NServiceBus.AcceptanceTesting.Support.GivenDefinition`1.<>c__DisplayClass2.<GetAction>b__1(IBus bus) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\EndpointBehaviour.cs:line 45
at NServiceBus.AcceptanceTesting.Support.EndpointRunner.Start() in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\EndpointRunner.cs:line 107
--- End of inner exception stack trace ---
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.<>c__DisplayClass22.<StartEndpoints>b__20() in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs:line 274
at System.Threading.Tasks.Task.InnerInvoke()
at System.Threading.Tasks.Task.Execute()<---
Context:
Subscriber1GotTheEvent = False
Subscriber1Subscribed = False
EndpointsStarted = False
Exceptions =
System.AggregateException : Test run failed due to one or more exception
----> System.AggregateException : One or more errors occurred.
----> NServiceBus.AcceptanceTesting.Support.ScenarioException : Endpoint failed to start
----> RabbitMQ.Client.Exceptions.OperationInterruptedException : The AMQP operation was interrupted: AMQP close-reason, initiated by Peer, code=404, text="NOT_FOUND - no exchange 'PubSub.Subscriber1.WhenPublishingAnEventWithOverriddenLocalAddress.RabbitMQ' in vhost '/'", classId=40, methodId=30, cause=
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.Run(IList`1 runDescriptors, IList`1 behaviorDescriptors, IList`1 shoulds, Func`2 done, Int32 limitTestParallelismTo, Action`1 reports) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs: line 86
at NServiceBus.AcceptanceTesting.ScenarioWithContext`1.Run(Nullable`1 testExecutionTimeout) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Scenario.cs: line 88
at NServiceBus.AcceptanceTests.PubSub.When_publishing_an_event_with_overridden_local_address.Should_be_delivered_to_all_subscribers() in When_publishing_an_event_with_overridden_local_address.cs: line 16
--AggregateException
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, Int32 millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, Int32 millisecondsTimeout)
at System.Threading.Tasks.Task.WaitAll(Task[] tasks, TimeSpan timeout)
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.StartEndpoints(IEnumerable`1 endpoints) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs: line 269
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.PerformScenarios(RunDescriptor runDescriptor, IEnumerable`1 runners, Func`1 done) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs: line 234
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.PerformTestRun(IList`1 behaviorDescriptors, IList`1 shoulds, RunDescriptor runDescriptor, Func`2 done) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs: line 160
--ScenarioException
at NServiceBus.AcceptanceTesting.Support.ScenarioRunner.<>c__DisplayClass22.<StartEndpoints>b__20() in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\ScenarioRunner.cs: line 274
at System.Threading.Tasks.Task.InnerInvoke()
at System.Threading.Tasks.Task.Execute()
--OperationInterruptedException
at RabbitMQ.Client.Impl.SimpleBlockingRpcContinuation.GetReply()
at RabbitMQ.Client.Impl.ModelBase.ModelRpc(MethodBase method, ContentHeaderBase header, Byte[] body)
at RabbitMQ.Client.Framing.Impl.v0_9_1.Model._Private_ExchangeBind(String destination, String source, String routingKey, Boolean nowait, IDictionary`2 arguments)
at RabbitMQ.Client.Impl.ModelBase.ExchangeBind(String destination, String source, String routingKey)
at NServiceBus.Transports.RabbitMQ.Routing.ConventionalRoutingTopology.SetupSubscription(IModel channel, Type type, String subscriberName) in ConventionalRoutingTopology.cs: line 33
at NServiceBus.Transports.RabbitMQ.RabbitMqSubscriptionManager.Subscribe(Type eventType, Address publisherAddress) in RabbitMqSubscriptionManager.cs: line 18
at NServiceBus.Unicast.UnicastBus.Subscribe(Type messageType, Predicate`1 condition) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs: line 390
at NServiceBus.Unicast.UnicastBus.Subscribe(Type messageType) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs: line 343
at NServiceBus.Unicast.UnicastBus.Subscribe() in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Unicast\UnicastBus.cs: line 334
at NServiceBus.AcceptanceTests.PubSub.When_publishing_an_event_with_overridden_local_address.<Should_be_delivered_to_all_subscribers>b__4(IBus bus, Context context) in When_publishing_an_event_with_overridden_local_address.cs: line 28
at NServiceBus.AcceptanceTesting.Support.GivenDefinition`1.<>c__DisplayClass2.<GetAction>b__1(IBus bus) in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\EndpointBehaviour.cs: line 45
at NServiceBus.AcceptanceTesting.Support.EndpointRunner.Start() in c:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.AcceptanceTesting\Support\EndpointRunner.cs: line 107
from nservicebus.rabbitmq.
Works locally and on buildserve, closing as can't repro
from nservicebus.rabbitmq.
@andreasohlund I find that very strange, since that test is still marked as Explicit
!
Are you running
from nservicebus.rabbitmq.
BTW, I ran it again and still same error
from nservicebus.rabbitmq.
Doh!!
Good catch
On Sun, Nov 30, 2014 at 11:36 PM, John Simons [email protected]
wrote:
BTW, I ran it again and still same error
—
Reply to this email directly or view it on GitHub
#29 (comment)
.
from nservicebus.rabbitmq.
Fixed by df67c3c
from nservicebus.rabbitmq.
Related Issues (20)
- Expose ConnectionFactory.MaxMessageSize on the transport configuration API
- Stopping an endpoint floods the log with "Reconnecting to the broker failed: System.ObjectDisposedException" HOT 1
- Add automated tests that runs against AmazonMQ
- Add automated tests that runs against CloudAMQP
- Endpoint never reconnects to RabbitMQ after channel timeout HOT 7
- Multi target commandline to net6, net7 and newer
- Retries of headerless message causes indefinite requeuing on classic queues HOT 5
- Message loss in migrate-to-quorum command HOT 3
- Automatic rate limiting feature might cause duplicate messages HOT 1
- nsbVersion can't be computed in single file deployments HOT 2
- Messages go into infinite immediate retries in case there are a lot of messages (over 100) with persistent issue while processing. HOT 5
- ChannelProvider Publish reconnection attempts continue forever after IEndpointInstance had been stopped HOT 12
- Suppress creation of `nsb.v2.verify-stream-flag-enabled` queue HOT 2
- Ability to not have the delayed delivery infrastructure created
- Should we expose a way to configure the Consumer Acknowledgement Timeout HOT 1
- Immediate retry count does not increase for rabbit messages which are sent to queue without "message_id" property after upgrade to NServiceBus 8 HOT 5
- Enhance code readability and using .NET 8 new features HOT 1
- Vulnerabilities in transitive dependencies HOT 1
- Easy way to configure Exchange names HOT 1
- How to break “RabbitMQ Delayed Delivery” for all endpoints HOT 4
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from nservicebus.rabbitmq.