Unit test DQL topic name used in Error Policy

[cookie-bytes]

Is there a way to unit test the topic name a move to DLQ error policy will use?

Thanks

[BEagle1984]

I assume you mean the MoveMessageErrorPolicy but what are you willing to unit test exactly?

[cookie-bytes]

It is to assert the DLQ name used in the error policy.

 private static IProducerEndpoint GetMoveEventErrorPolicyProducerEndpoint(KafkaConsumerEndpoint endpoint)
    {
        var chain = (ErrorPolicyChain)endpoint.ErrorPolicy;
        var errorPolicies = (IReadOnlyCollection<ErrorPolicyBase>)GetProperty(typeof(ErrorPolicyChain), chain, "Policies");
        var moveMessageErrorPolicy = errorPolicies.OfType<MoveMessageErrorPolicy>().Single();
        var errorPolicyProducerEndpoint = (IProducerEndpoint)GetProperty(typeof(MoveMessageErrorPolicy), moveMessageErrorPolicy, "Endpoint");
        return errorPolicyProducerEndpoint;
    }

    private static object GetProperty(Type type, object instance, string propertyName)
    {
        var pi = type.GetProperty(propertyName, System.Reflection.BindingFlags.Instance | System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Public);
        return pi!.GetValue(instance)!;
    }

We used the above to get the Producer Endpoint for the Error Policy and it seems to work.