Help with setting up Deferred messages

[Claker]

Hi,

I am part of Visma e-conomic organization. It is the first time we try .Defer. When we send the message via Publish it works, however, when we use .Defer we get Rebus.Exceptions.MessageCouldNotBeDispatchedToAnyHandlersException: Message with ID 3a3297bc-8ed6-4999-a63a-e45af621b583 and type Economic.Messaging.Messages.ApprovalCancelEvent, Economic.Messaging.Messages could not be dispatched to any handlers (and will not be retried under the default fail-fast settings).

We did check and the correct bindings exist in the exchange we send the message to. This is also validated by the fact that it works with Publish. When we started using Defer, the only extra line we added to the subscriber was o.SetDueTimeoutsPollInteval(TimeSpan.FromSeconds(10));

Are we missing anything else to make this work or it should work?

I can provide even more details but I wanted to start with this just in case it is something obvious

builder.RegisterRebus((configurer, context) => configurer
	.Logging(l => l.UseEconomicLogProvider())
	.Transport(t => t
		.UseRabbitMq(
			connectionString: context.Resolve<IMessageHandlerConfiguration>().RabbitMqConnectionString,
			inputQueueName: context.Resolve<IMessageHandlerConfiguration>().RabbitMqInputQueueName
					)
		.ExchangeNames(topicExchangeName: context.Resolve<IMessageHandlerConfiguration>().RebusTopicExchangeName))
	.Timeouts(t => t
		.StoreInSqlServer(
			context.Resolve<IMessageHandlerConfiguration>().RebusSqlServerConnectionString,
			context.Resolve<IMessageHandlerConfiguration>().RebusSqlServerTableName,
			automaticallyCreateTables: true)
	)
	.Serialization(s => s.UseEconomicMessagingSerializer())
	.Routing(r => r.TypeBased())
	.Options(o =>
	{
		o.Decorate<IPipeline>(c =>
		{
			var pipeline = c.Get<IPipeline>();
			return new PipelineStepInjector(pipeline)
				.OnReceive(new ObservabilityStep(), PipelineRelativePosition.Before, typeof(DispatchIncomingMessageStep));
		});
		o.Decorate<IPipeline>(c =>
		{
			var pipeline = c.Get<IPipeline>();
			var step = new AssignEnvironmentTypeNameHeader(context.Resolve<IMetadataProvider>());
			return new PipelineStepInjector(pipeline)
				.OnSend(step, PipelineRelativePosition.After, typeof(AssignDefaultHeadersStep));
		});
		o.SetDueTimeoutsPollInteval(TimeSpan.FromSeconds(10));
		o.AddTracing(context.Resolve<IMessageHandlerConfiguration>().RebusTracingEnabled);
		o.SetNumberOfWorkers(context.Resolve<IMessageHandlerConfiguration>().RebusNumberOfWorkers);
		o.SetMaxParallelism(context.Resolve<IMessageHandlerConfiguration>().RebusMaxParallelism);
		o.RetryStrategy(
			errorQueueName: context.Resolve<IMessageHandlerConfiguration>().RebusRetryErrorQueueAddress,
			maxDeliveryAttempts: context.Resolve<IMessageHandlerConfiguration>().RebusRetryMaxDeliveryAttempts,
			secondLevelRetriesEnabled: context.Resolve<IMessageHandlerConfiguration>().RebusRetrySecondLevelRetriesEnabled);
		
	}));