InResponseHandler.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it).
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */
  20. package org.openspcoop2.pdd.core.handlers.transazioni;

  22. import java.io.ByteArrayOutputStream;
  23. import java.util.Date;

  25. import org.apache.commons.lang.StringUtils;
  26. import org.openspcoop2.core.constants.Costanti;
  27. import org.openspcoop2.core.constants.TipoPdD;
  28. import org.openspcoop2.message.OpenSPCoop2RestMessage;
  29. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  30. import org.openspcoop2.message.constants.MessageRole;
  31. import org.openspcoop2.message.constants.ServiceBinding;
  32. import org.openspcoop2.message.xml.MessageXMLUtils;
  33. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  34. import org.openspcoop2.pdd.core.CostantiPdD;
  35. import org.openspcoop2.pdd.core.connettori.ConnettoreBase;
  36. import org.openspcoop2.pdd.core.handlers.HandlerException;
  37. import org.openspcoop2.pdd.core.handlers.InResponseContext;
  38. import org.openspcoop2.pdd.core.transazioni.InResponseStatefulObject;
  39. import org.openspcoop2.pdd.core.transazioni.RepositoryGestioneStateful;
  40. import org.openspcoop2.pdd.core.transazioni.Transaction;
  41. import org.openspcoop2.pdd.core.transazioni.TransactionContext;
  42. import org.openspcoop2.pdd.core.transazioni.TransactionDeletedException;
  43. import org.openspcoop2.pdd.core.transazioni.TransactionNotExistsException;
  44. import org.openspcoop2.pdd.core.transazioni.TransactionStatefulNotSupportedException;
  45. import org.openspcoop2.pdd.logger.DumpUtility;
  46. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  47. import org.openspcoop2.utils.json.JSONUtils;
  48. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  49. import org.slf4j.Logger;

  51. import com.fasterxml.jackson.databind.JsonNode;

  53. /**     
  54.  * InResponseHandler
  55.  *
  56.  * @author Poli Andrea (poli@link.it)
  57.  * @author $Author$
  58.  * @version $Rev$, $Date$
  59.  */
  60. public class InResponseHandler extends FirstPositionHandler implements  org.openspcoop2.pdd.core.handlers.InResponseHandler{

  62.     @Override
  63.     public void invoke(InResponseContext context) throws HandlerException {
  64.         
  65.         OpenSPCoop2Properties op2Properties = OpenSPCoop2Properties.getInstance();
  66.         if(op2Properties.isTransazioniEnabled()==false) {
  67.             return;
  68.         }

  70.         String idTransazione = null;
  71.         if(context!=null && context.getPddContext()!=null) {
  72.             idTransazione = (String) context.getPddContext().getObject(Costanti.ID_TRANSAZIONE);
  73.         }
  74.         
  75.         //System.out.println("------------- InResponseHandler ("+idTransazione+")("+context.getTipoPorta().getTipo()+") -------------------");
  76.         
  77.         
  78.         
  79.         // Gestione FAULT
  80.         String fault = null;
  81.         String formatoFault = null;
  82.         try{
  83.             if(context!=null && context.getMessaggio()!=null){
  84.                 if(ServiceBinding.SOAP.equals(context.getMessaggio().getServiceBinding())) {
  85.                     OpenSPCoop2SoapMessage soapMsg = context.getMessaggio().castAsSoap();
  86.                     if(soapMsg.hasSOAPFault()){
  87.                         
  88.                         ByteArrayOutputStream bout = new ByteArrayOutputStream();
  89.                         bout.write(context.getMessaggio().getAsByte(soapMsg.getSOAPPart().getEnvelope(), false));
  90.                         bout.flush();
  91.                         bout.close();
  92.                         
  93.                         Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopTransazioni(op2Properties.isTransazioniDebug());
  94.                         if(op2Properties.isTransazioniFaultPrettyPrint()){
  95.                             // Faccio una pretty-print: potevo fare anche direttamente passando il fault a metodo prettyPrint,
  96.                             // Pero' non veniva stampato correttamente il SOAPFault. Mi appoggio allora a SoapUtils.
  97.                             //byte [] content = org.openspcoop2.message.soap.TunnelSoapUtils.sbustamentoMessaggio(context.getMessaggio());
  98.                             byte [] content = bout.toByteArray();
  99.                             fault = DumpUtility.toString(MessageXMLUtils.getInstance(soapMsg.getFactory()).newDocument(content), log, context.getMessaggio());
  100.                             //System.out.println("IMPOSTATO FAULT IN TRANSACTION ["+fault+"]");
  101.                         }
  102.                         else{
  103.                             
  104.                             fault = bout.toString();
  105.                         }
  106.                         
  107.                         formatoFault = soapMsg.getMessageType().name();
  108.                         
  109.                     }
  110.                 }
  111.                 else {
  112.                     OpenSPCoop2RestMessage<?> restMsg = context.getMessaggio().castAsRest();
  113.                     if(restMsg.isProblemDetailsForHttpApis_RFC7807() || MessageRole.FAULT.equals(restMsg.getMessageRole())) {
  114.                         switch (restMsg.getMessageType()) {
  115.                         case XML:
  116.                             
  117.                             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  118.                             restMsg.writeTo(bout, false);
  119.                             bout.flush();
  120.                             bout.close();
  121.                             
  122.                             Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopTransazioni(op2Properties.isTransazioniDebug());
  123.                             if(op2Properties.isTransazioniFaultPrettyPrint()){
  124.                                 // Faccio una pretty-print: potevo fare anche direttamente passando il fault a metodo prettyPrint,
  125.                                 // Pero' non veniva stampato correttamente il SOAPFault. Mi appoggio allora a SoapUtils.
  126.                                 //byte [] content = org.openspcoop2.message.soap.TunnelSoapUtils.sbustamentoMessaggio(context.getMessaggio());
  127.                                 byte [] content = bout.toByteArray();
  128.                                 fault = DumpUtility.toString(MessageXMLUtils.getInstance(restMsg.getFactory()).newDocument(content), log, context.getMessaggio());
  129.                                 //System.out.println("IMPOSTATO FAULT IN TRANSACTION ["+fault+"]");
  130.                             }
  131.                             else{
  132.                                 
  133.                                 fault = bout.toString();
  134.                             }
  135.                             
  136.                             formatoFault = restMsg.getMessageType().name();
  137.                             
  138.                             break;
  139.                             
  140.                         case JSON:
  141.                             
  142.                             bout = new ByteArrayOutputStream();
  143.                             restMsg.writeTo(bout, false);
  144.                             bout.flush();
  145.                             bout.close();
  146.                             
  147.                             if(op2Properties.isTransazioniFaultPrettyPrint()){
  148.                                 
  149.                                 JSONUtils jsonUtils = JSONUtils.getInstance(true);
  150.                                 byte [] content = bout.toByteArray();
  151.                                 JsonNode jsonNode = jsonUtils.getAsNode(content);
  152.                                 fault = jsonUtils.toString(jsonNode);
  153.                                 
  154.                             }
  155.                             else{
  156.                                 
  157.                                 fault = bout.toString();
  158.                             }
  159.                             
  160.                             formatoFault = restMsg.getMessageType().name();
  161.                             
  162.                             break;

  164.                         default:
  165.                             break;
  166.                         }
  167.                     }
  168.                 }
  169.             }
  170.         }catch(Exception e){
  171.             throw new HandlerException("Errore durante il dump del soap fault",e);
  172.         }
  173.         
  174.         
  175.         
  176.         
  177.         if(context!=null && context.getTransazioneApplicativoServer()!=null) {
  178.             
  179.             try{
  180.             
  181.                 // date             
  182.                 context.getTransazioneApplicativoServer().setDataAccettazioneRisposta(context.getDataAccettazioneRisposta());
  183.                 
  184.                 Date dataIngressoRisposta = context.getDataElaborazioneMessaggio();
  185.                 if(context.getDataTerminataInvocazioneConnettore()!=null) {
  186.                     dataIngressoRisposta = context.getDataTerminataInvocazioneConnettore(); // nella latenza porta deve rientrare anche la negoziazione della connessione
  187.                 }
  188.                 context.getTransazioneApplicativoServer().setDataIngressoRisposta(dataIngressoRisposta);
  189.                 
  190.                 if(context.getDataPrimaInvocazioneConnettore()!=null) {
  191.                     // aggiorno informazione sulla data, poiche' piu' precisa (nella latenza porta deve rientrare anche il dump ed il rilascio della connessione)
  192.                     context.getTransazioneApplicativoServer().setDataUscitaRichiesta(context.getDataPrimaInvocazioneConnettore());
  193.                 }
  194.                 
  195.                 if(context.getDataRichiestaInoltrata()!=null) {
  196.                     context.getTransazioneApplicativoServer().setDataUscitaRichiestaStream(context.getDataRichiestaInoltrata());
  197.                 }
  198.                 
  199.                 
  200.                 // return code
  201.                 context.getTransazioneApplicativoServer().setCodiceRisposta(context.getReturnCode()+"");
  202.                     
  203.                 // eventuali errori
  204.                 context.getTransazioneApplicativoServer().setUltimoErrore(context.getErroreConsegna());
  205.                 
  206.                 
  207.                 // aggiorno location
  208.                 if(context.getConnettore()!=null){
  209.                     context.getTransazioneApplicativoServer().setLocationConnettore(context.getConnettore().getLocation());
  210.                 }
  211.                 
  212.                 // fault
  213.                 if(fault!=null){
  214.                     context.getTransazioneApplicativoServer().setFault(fault);
  215.                     context.getTransazioneApplicativoServer().setFormatoFault(formatoFault);
  216.                 }
  217.                 
  218.             }catch(Exception e){
  219.                 throw new HandlerException("Errore durante il processamento delle informazioni relative alla consegna per l'applicativo '"+context.getTransazioneApplicativoServer().getServizioApplicativoErogatore()+"': "+e.getMessage(),e);
  220.             }
  221.             
  222.         }
  223.         else {
  224.         
  225.         
  226.             boolean gestioneStateful = false;
  227.             Transaction tr = null;
  228.             try{
  229.                 tr = TransactionContext.getTransaction(idTransazione);
  230.             }catch(TransactionNotExistsException e){
  231.                 gestioneStateful = true;
  232.             }
  233.             
  234.             try{
  235.             
  236.                 InResponseStatefulObject sObject = null;
  237.     
  238.                 if(tr==null && gestioneStateful){
  239.                     
  240.                     sObject = new InResponseStatefulObject();
  241.                     
  242.                     //System.out.println("@@@@@REPOSITORY@@@@@ InResponseHandler ID TRANSAZIONE ["+idTransazione+"] GESTIONE COMPLETA");
  243.                     
  244.                     Date dataRichiestaInoltrata = context.getDataRichiestaInoltrata();
  245.                     // La porta di dominio mi passa sempre questa informazione.
  246.                     // Nel PddMonitor, invece, la data deve essere visualizzata solo se la dimensione e' diverso da 0 e cioe' se c'e' un messaggio di risposta.
  247.                     //if(dimensione!=null && dimensione>0){
  248.                     // L'INFORMAZIONE DEVE INVECE ESSERE SEMPRE SALVATA PER LA SIMULAZIONE DEI MESSAGGI DIAGNOSTICI
  249.                     // INEFFICIENTE: RepositoryGestioneStateful.addDataAccettazioneRisposta(idTransazione, dataAccettazioneRisposta);
  250.                     sObject.setDataRichiestaInoltrata(dataRichiestaInoltrata);
  251.                     
  252.                     Date dataAccettazioneRisposta = context.getDataAccettazioneRisposta();
  253.                     // La porta di dominio mi passa sempre questa informazione.
  254.                     // Nel PddMonitor, invece, la data deve essere visualizzata solo se la dimensione e' diverso da 0 e cioe' se c'e' un messaggio di risposta.
  255.                     //if(dimensione!=null && dimensione>0){
  256.                     // L'INFORMAZIONE DEVE INVECE ESSERE SEMPRE SALVATA PER LA SIMULAZIONE DEI MESSAGGI DIAGNOSTICI
  257.                     // INEFFICIENTE: RepositoryGestioneStateful.addDataAccettazioneRisposta(idTransazione, dataAccettazioneRisposta);
  258.                     sObject.setDataAccettazioneRisposta(dataAccettazioneRisposta);
  259.                     
  260.                     Date dataIngressoRisposta = context.getDataElaborazioneMessaggio();
  261.                     if(context.getDataTerminataInvocazioneConnettore()!=null) {
  262.                         dataIngressoRisposta = context.getDataTerminataInvocazioneConnettore(); // nella latenza porta deve rientrare anche la negoziazione della connessione
  263.                     }
  264.                     // La porta di dominio mi passa sempre questa informazione.
  265.                     // Nel PddMonitor, invece, la data deve essere visualizzata solo se la dimensione e' diverso da 0 e cioe' se c'e' un messaggio di risposta.
  266.                     //if(dimensione!=null && dimensione>0){
  267.                     // L'INFORMAZIONE DEVE INVECE ESSERE SEMPRE SALVATA PER LA SIMULAZIONE DEI MESSAGGI DIAGNOSTICI
  268.                     // INEFFICIENTE: RepositoryGestioneStateful.addDataIngressoRisposta(idTransazione, dataElaborazioneMessaggio);
  269.                     sObject.setDataIngressoRisposta(dataIngressoRisposta);
  270.                     
  271.                     if(context.getDataPrimaInvocazioneConnettore()!=null) {
  272.                         // aggiorno informazione sulla data, poiche' piu' precisa (nella latenza porta deve rientrare anche il dump ed il rilascio della connessione)
  273.                         sObject.setDataUscitaRichiesta(context.getDataPrimaInvocazioneConnettore());
  274.                     }
  275.                     
  276.                     // INEFFICIENTE: RepositoryGestioneStateful.addCodiceTrasportoRichiesta(idTransazione, context.getReturnCode()+"");
  277.                     sObject.setReturnCode(context.getReturnCode()+"");
  278.                     
  279.                     if(context.getConnettore()!=null){
  280.                         
  281.                         // INEFFICIENTE: RepositoryGestioneStateful.addLocation(idTransazione, context.getConnettore().getLocation());
  282.                         sObject.setLocation(context.getConnettore().getLocation());
  283.                         
  284.                     }
  285.                     
  286.                     if(fault!=null){
  287.                         if(TipoPdD.APPLICATIVA.equals(context.getTipoPorta())){
  288.                             sObject.setFaultIntegrazione(fault);
  289.                             sObject.setFormatoFaultIntegrazione(formatoFault);
  290.                         }
  291.                         else{
  292.                             sObject.setFaultCooperazione(fault);
  293.                             sObject.setFormatoFaultCooperazione(formatoFault);
  294.                         }
  295.                     }
  296.                 
  297.                 }else{
  298.                         
  299.                     if(tr==null) {
  300.                         throw new HandlerException("Transaction is null");
  301.                     }
  302.                     if(context==null) {
  303.                         throw new HandlerException("Context is null");
  304.                     }
  305.                     
  306.                     Date dataRichiestaInoltrata = context.getDataRichiestaInoltrata();
  307.                     // La porta di dominio mi passa sempre questa informazione.
  308.                     // Nel PddMonitor, invece, la data deve essere visualizzata solo se la dimensione e' diverso da 0 e cioe' se c'e' un messaggio di risposta.
  309.                     //if(dimensione!=null && dimensione>0){
  310.                     // L'INFORMAZIONE DEVE INVECE ESSERE SEMPRE SALVATA PER LA SIMULAZIONE DEI MESSAGGI DIAGNOSTICI
  311.                     try{
  312.                         tr.setDataRichiestaInoltrata(dataRichiestaInoltrata);
  313.                         //System.out.println("SET DATA ("+dataAccettazioneRisposta.toString()+")");
  314.                     }catch(TransactionDeletedException e){
  315.                         //System.out.println("@@@@@REPOSITORY@@@@@ InResponseHandler SET DATA ("+dataAccettazioneRisposta.toString()+")");
  316.                         // INEFFICIENTE: RepositoryGestioneStateful.addDataAccettazioneRisposta(idTransazione, dataAccettazioneRisposta);
  317.                         if(sObject==null)
  318.                             sObject = new InResponseStatefulObject();
  319.                         sObject.setDataRichiestaInoltrata(dataRichiestaInoltrata);
  320.                     }
  321.                     
  322.                     Date dataAccettazioneRisposta = context.getDataAccettazioneRisposta();
  323.                     // La porta di dominio mi passa sempre questa informazione.
  324.                     // Nel PddMonitor, invece, la data deve essere visualizzata solo se la dimensione e' diverso da 0 e cioe' se c'e' un messaggio di risposta.
  325.                     //if(dimensione!=null && dimensione>0){
  326.                     // L'INFORMAZIONE DEVE INVECE ESSERE SEMPRE SALVATA PER LA SIMULAZIONE DEI MESSAGGI DIAGNOSTICI
  327.                     try{
  328.                         tr.setDataAccettazioneRisposta(dataAccettazioneRisposta);
  329.                         //System.out.println("SET DATA ("+dataAccettazioneRisposta.toString()+")");
  330.                     }catch(TransactionDeletedException e){
  331.                         //System.out.println("@@@@@REPOSITORY@@@@@ InResponseHandler SET DATA ("+dataAccettazioneRisposta.toString()+")");
  332.                         // INEFFICIENTE: RepositoryGestioneStateful.addDataAccettazioneRisposta(idTransazione, dataAccettazioneRisposta);
  333.                         if(sObject==null)
  334.                             sObject = new InResponseStatefulObject();
  335.                         sObject.setDataAccettazioneRisposta(dataAccettazioneRisposta);
  336.                     }
  337.                     
  338.                     Date dataIngressoRisposta = context.getDataElaborazioneMessaggio();
  339.                     if(context.getDataTerminataInvocazioneConnettore()!=null) {
  340.                         dataIngressoRisposta = context.getDataTerminataInvocazioneConnettore(); // nella latenza porta deve rientrare anche la negoziazione della connessione
  341.                     }
  342.                     // La porta di dominio mi passa sempre questa informazione.
  343.                     // Nel PddMonitor, invece, la data deve essere visualizzata solo se la dimensione e' diverso da 0 e cioe' se c'e' un messaggio di risposta.
  344.                     //if(dimensione!=null && dimensione>0){
  345.                     // L'INFORMAZIONE DEVE INVECE ESSERE SEMPRE SALVATA PER LA SIMULAZIONE DEI MESSAGGI DIAGNOSTICI
  346.                     try{
  347.                         tr.setDataIngressoRisposta(dataIngressoRisposta);
  348.                         //System.out.println("SET DATA ("+dataElaborazioneMessaggio.toString()+")");
  349.                     }catch(TransactionDeletedException e){
  350.                         //System.out.println("@@@@@REPOSITORY@@@@@ InResponseHandler SET DATA ("+dataElaborazioneMessaggio.toString()+")");
  351.                         // INEFFICIENTE: RepositoryGestioneStateful.addDataIngressoRisposta(idTransazione, dataElaborazioneMessaggio);
  352.                         if(sObject==null)
  353.                             sObject = new InResponseStatefulObject();
  354.                         sObject.setDataIngressoRisposta(dataIngressoRisposta);
  355.                     }
  356.                         
  357.                     if(context.getDataPrimaInvocazioneConnettore()!=null) {
  358.                         // aggiorno informazione sulla data, poiche' piu' precisa (nella latenza porta deve rientrare anche il dump ed il rilascio della connessione)
  359.                         try{
  360.                             tr.setDataUscitaRichiesta(context.getDataPrimaInvocazioneConnettore());
  361.                             //System.out.println("SET DATA ("+dataElaborazioneMessaggio.toString()+")");
  362.                         }catch(TransactionDeletedException e){
  363.                             //System.out.println("@@@@@REPOSITORY@@@@@ InResponseHandler SET DATA ("+dataElaborazioneMessaggio.toString()+")");
  364.                             // INEFFICIENTE: RepositoryGestioneStateful.addDataIngressoRisposta(idTransazione, dataElaborazioneMessaggio);
  365.                             if(sObject==null)
  366.                                 sObject = new InResponseStatefulObject();
  367.                             sObject.setDataUscitaRichiesta(context.getDataPrimaInvocazioneConnettore());
  368.                         }
  369.                     }
  370.                     
  371.                     try{
  372.                         //System.out.println("SET CODICE TRASPORTO RICHIESTA ["+context.getReturnCode()+"]");
  373.                         if(context!=null) {
  374.                             tr.setCodiceTrasportoRichiesta(context.getReturnCode()+"");
  375.                         }
  376.                     }catch(TransactionDeletedException e){
  377.                         //System.out.println("@@@@@REPOSITORY@@@@@ InResponseHandler SET CODICE TRASPORTO RICHIESTA ["+context.getReturnCode()+"]");
  378.                         // INEFFICIENTE: RepositoryGestioneStateful.addCodiceTrasportoRichiesta(idTransazione, context.getReturnCode()+"");
  379.                         if(sObject==null)
  380.                             sObject = new InResponseStatefulObject();
  381.                         sObject.setReturnCode(context.getReturnCode()+"");
  382.                     }
  383.                     
  384.                     try{
  385.                         // update location impostata nel OutRequest (location modificata dal connettore)
  386.                         //System.out.println("SET LOCATION ["+context.getConnettore().getLocation()+"]");
  387.                         String connettoreRequestUrl = null;
  388.                         String connettoreRequestMethod = null;
  389.                         if(context.getPddContext()!=null) {
  390.                             if(context.getPddContext().containsKey(CostantiPdD.CONNETTORE_REQUEST_URL)) {
  391.                                 connettoreRequestUrl = (String) context.getPddContext().getObject(CostantiPdD.CONNETTORE_REQUEST_URL);
  392.                             }
  393.                             if(context.getPddContext().containsKey(CostantiPdD.CONNETTORE_REQUEST_METHOD)) {
  394.                                 Object o = context.getPddContext().getObject(CostantiPdD.CONNETTORE_REQUEST_METHOD);
  395.                                 if(o instanceof String) {
  396.                                     connettoreRequestMethod = (String) o;
  397.                                 }
  398.                                 else if(o instanceof HttpRequestMethod) {
  399.                                     HttpRequestMethod oConnettoreRequestMethod = (HttpRequestMethod) o;
  400.                                     connettoreRequestMethod = oConnettoreRequestMethod.name();
  401.                                 }
  402.                             }
  403.                         }
  404.                         if(!StringUtils.isEmpty(connettoreRequestUrl) && !StringUtils.isEmpty(connettoreRequestMethod)) {
  405.                             String prefix = "";
  406.                             if(ConnettoreBase.LOCATION_CACHED.equals(context.getConnettore().getLocation())){
  407.                                 prefix = context.getConnettore().getLocation()+ConnettoreBase.LOCATION_CACHED_SEPARATOR_REQUEST_URL;
  408.                             }
  409.                             tr.setLocation(prefix+CostantiPdD.getConnettoreRequest(connettoreRequestUrl, connettoreRequestMethod));
  410.                         }
  411.                         else {
  412.                             if(context!=null && context.getConnettore()!=null) {
  413.                                 tr.setLocation(context.getConnettore().getLocation());
  414.                             }
  415.                         }
  416.                     }catch(TransactionDeletedException e){
  417.                         //System.out.println("@@@@@REPOSITORY@@@@@ OutRequestHandler SET LOCATION ["+context.getConnettore().getLocation()+"]");
  418.                         // INEFFICIENTE: RepositoryGestioneStateful.addLocation(idTransazione, context.getConnettore().getLocation());
  419.                         if(sObject==null)
  420.                             sObject = new InResponseStatefulObject();
  421.                         sObject.setLocation(context.getConnettore().getLocation());
  422.                     }
  423.                     
  424.                     try{
  425.                         if(fault!=null){
  426.                             if(TipoPdD.APPLICATIVA.equals(context.getTipoPorta())){
  427.                                 tr.setFaultIntegrazione(fault);
  428.                                 tr.setFormatoFaultIntegrazione(formatoFault);
  429.                             }
  430.                             else{
  431.                                 tr.setFaultCooperazione(fault);
  432.                                 tr.setFormatoFaultCooperazione(formatoFault);
  433.                             }
  434.                         }
  435.                     }catch(TransactionDeletedException e){
  436.                         if(fault!=null){
  437.                             if(sObject==null)
  438.                                 sObject = new InResponseStatefulObject();
  439.                             if(TipoPdD.APPLICATIVA.equals(context.getTipoPorta())){
  440.                                 sObject.setFaultIntegrazione(fault);
  441.                                 sObject.setFormatoFaultIntegrazione(formatoFault);
  442.                             }
  443.                             else{
  444.                                 sObject.setFaultCooperazione(fault);
  445.                                 sObject.setFormatoFaultCooperazione(formatoFault);
  446.                             }
  447.                         }
  448.                     }
  449.                 
  450.                 }
  451.                 
  452.                 if(sObject!=null){
  453.                     // Gestione stateful
  454.                     RepositoryGestioneStateful.addInResponseStatefulObject(context.getProtocolFactory().getProtocol(),idTransazione, sObject);
  455.                 }
  456.                 
  457.             }catch(TransactionStatefulNotSupportedException e){
  458.                 throw new HandlerException("Errore durante il processamento dell'handler: "+e.getMessage(),e);
  459.             }
  460.             
  461.         }
  462.         
  463.     }

  465. }
Created with JaCoCo 0.8.8.202204050719