java.lang.AssertionError: Problema con el punto de prueba Camel Mock

Estoy teniendo problemas con la simulación de ruta de camello. No pudo contar los mensajes de la ruta y en su lugar devuelve “0” como contador de mensajes. Aquí está mi caso de prueba y ruta. ¿Alguien puede ayudarme con esto?

Archivo WatcherRouteTest.java:

@CamelSpringBootTest
@SpringBootTest
@MockEndpoints
@UseAdviceWith
public class RouteTest {

  @Autowired
  CamelContext camelContext;

  @Autowired
  ProducerTemplate producerTemplate;

  File resultFile;

  @EndpointInject("mock:azure-storage-blob")
  MockEndpoint storageMockEndpoint;


  @Test
  void testFlow() throws Exception {

    AdviceWith.adviceWith(camelContext, "uploadFile", a ->
        a.replaceFromWith("direct:start")
    );

    storageMockEndpoint.expectedMessageCount(1);
    storageMockEndpoint.message(0)
        .header(Exchange.FILE_NAME).isEqualTo("text.csv");

    InputStream body = fetchFileFromResourcesFolderAsStream("test-files/text.csv");
    Map<string, object=""> headers = new HashMap<>();
    headers.put(Exchange.FILE_NAME, "text.csv");
    headers.put("CamelAzureStorageBlobContainerName","abc");
    headers.put("header.CamelAzureStorageBlobSourceBlobAccountName","abcd");

    camelContext.start();
    producerTemplate.sendBodyAndHeaders("direct:start", body, headers);

    storageMockEndpoint.assertIsSatisfied();

    resultFile = fileCreationUtility( "text.csv");
    assertTrue(resultFile.exists());

  }
}

Aquí está mi implementación actual:

from("direct:upload")
        .routeId("uploadFile")
        .setHeader("CamelAzureStorageBlobSourceBlobAccountName",constant(storageAccountName))
        .toD(BLOB_URL)
        .log(LoggingLevel.INFO,"${header.CamelFileName} Uploaded to ${header.CamelAzureStorageBlobContainerName} Container Successfully")
        .end();

Excepción ocurrida:

java.lang.AssertionError: mock://azure-storage-blob Received message count. Expected: <1> but was: <0>
Expected :<1>
Actual :<0></string,>