Como descrito no Processamento por demanda, o processamento dos documentos é realizado através de um Pool de Threads onde os dados para processamento são obtidos em memória após o recebimento do processo pela camada de WS, ou seja, ao invés de buscar registros na base de dados, as rotinas de processamento recebem os dados através de parâmetros, enviados pelas rotinas de recepção dos documentos. Essa característica exige a criação uma contingência em casos de indisponibilidade de Threads ou em casos de falhas durante o processamento, pois todo o processo está sendo realizado com dados em memoria da aplicação.
A indisponibilidade de Threads para processamento pode ocorrer em casos de alta demanda de Processamento de requisições ou devido à falhas possam provocar a interrupção do processamento como falha de acesso a serviços externos de integração com a aplicação(como a indisponibilidade dos serviços do Fisco de documentos: Sefaz, Prefeituras etc... ) ou até mesmo pela queda(desligamento) do servidor da aplicação.
Para que haja a contingência do processamento, os Processos são persistidos na base de dados para que o Job de Contingência possa acessar e iniciar ou prosseguir com o processamento. O fato dos Processos serem sempre gravados na tabela de processos antes de iniciar o processamento por Demanda , faz com que o JOB filtre apenas os registros que não estejam em processamento. O filtro é realizado através do Status do processo.
Caso o pool de Threads possua Threads disponíveis para processamento, os processos são gravados com "Status = 2: ( Em processamento )", caso contrário serão registrados com STATUS=1(Aguardando processamento). A cada tentativa de processamento, o Processo é encerrado e o Status passa para "Status= 1(Aguardando Processamento)" para que o JOB possa dar continuidade no processamento.
Em casos onde a interrupção do processamento ocorra de forma involuntária, impossibilitando a atualização do STATUS do processo, o critério para filtro dos registros e dado em comparação na data e horário atual com a data e horário do início do processamento. Caso um processo esteja em processamento a mais de 5 minutos, o registro entrará no filtro e será reprocessado.
No exemplo abaixo temos uma ilustração de um processo de Emissao de NFe. onde o Processamento por Demanda foi interrompido no Sub Processo de Consulta de retorno do processamento na Sefaz. Neste caso o JOB de Contingência garante o reprocessamento a partir do Sub Processo que apresentou a falha.
Fluxo do Processo:
1 - Rotina de Recepção realiza a remessa do documento na Tabela de Negócio.
2 - Rotina de Recepção gera e grava o Processo na tabela de Processos
3 - Rotina de Recepção dispara a execução da Rotina de Processamento por Demanda
4 - Rotina de Processamento por Demanada executa Rotina responsável pela execução do Processo.
5 - O processamento por Demanda é interrompido no Sub Processo de Consulta do documento
6 - JOB realiza filtro dos registros pendentes de processamento.
7 - O JOB de Contingência reinicia o processamento a partir do Sub Processo que apresentou a falha.
