ConnettoreStresstest.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.  */




  24. package org.openspcoop2.pdd.core.connettori;

  26. import java.io.ByteArrayInputStream;
  27. import java.sql.Connection;
  28. import java.util.ArrayList;

  30. import org.openspcoop2.core.config.ResponseCachingConfigurazione;
  31. import org.openspcoop2.core.constants.Costanti;
  32. import org.openspcoop2.core.constants.CostantiConnettori;
  33. import org.openspcoop2.core.constants.CostantiLabel;
  34. import org.openspcoop2.core.id.IDSoggetto;
  35. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  36. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  37. import org.openspcoop2.message.OpenSPCoop2MessageParseResult;
  38. import org.openspcoop2.message.constants.MessageRole;
  39. import org.openspcoop2.pdd.config.DBManager;
  40. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  41. import org.openspcoop2.pdd.config.Resource;
  42. import org.openspcoop2.pdd.mdb.ConsegnaContenutiApplicativi;
  43. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  44. import org.openspcoop2.protocol.engine.builder.Imbustamento;
  45. import org.openspcoop2.protocol.engine.driver.ProfiloDiCollaborazione;
  46. import org.openspcoop2.protocol.engine.driver.RepositoryBuste;
  47. import org.openspcoop2.protocol.sdk.Busta;
  48. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  49. import org.openspcoop2.protocol.sdk.Integrazione;
  50. import org.openspcoop2.protocol.sdk.config.ITraduttore;
  51. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  52. import org.openspcoop2.protocol.sdk.state.StatefulMessage;
  53. import org.openspcoop2.utils.Utilities;
  54. import org.openspcoop2.utils.date.DateManager;
  55. import org.openspcoop2.utils.random.RandomUtilities;





  61. /**
  62.  * ConnettoreStresstest
  63.  * 
  64.  * @author Andrea Poli (apoli@link.it)
  65.  * @author $Author$
  66.  * @version $Rev$, $Date$
  67.  */
  68. public class ConnettoreStresstest extends ConnettoreBase {

  70.     @Override
  71.     public String getProtocollo() {
  72.         return "HTTP";
  73.     }
  74.     
  75.     public static final String ENDPOINT_TYPE = "stresstest";
  76.     
  77.     public static final String LOCATION = "openspcoop2://stresstest";
  78.     

  80.     /* ********  F I E L D S  P R I V A T I  ******** */

  82.     private static final String HEADER_APPLICATIVO = "<thdr:headerApplicativo xmlns:thdr=\"http://example.org/test\" tipo=\"TEST\" soapenv:actor=\"http://example.org/test/actor\">\n"+
  83.                                                      "<identificativoDominio>ITALIA</identificativoDominio>\n"+
  84.                                                      "<thdr:identificatore>RISP@SERIAL@</thdr:identificatore>\n"+
  85.                                                      "</thdr:headerApplicativo>";
  86.     
  87.     private static final String SOAP_ENVELOPE_RISPOSTA = 
  88.         "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" " +
  89.         "   xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"><soapenv:Header>@HDR@</soapenv:Header>";
  90.     private static final String SOAP_ENVELOPE_RISPOSTA_END = 
  91.         "<soapenv:Body><prova>test</prova></soapenv:Body></soapenv:Envelope>";


  94.     private Resource resource = null;
  95.     private DBManager dbManager = null;
  96.    
  97.     public ConnettoreStresstest(){
  98.         super();
  99.         this.dbManager = DBManager.getInstance();
  100.     }
  101.     
  102.     
  103.     /* ********  METODI  ******** */

  105.     @Override
  106.     protected boolean initializePreSend(ResponseCachingConfigurazione responseCachingConfig, ConnettoreMsg request) {
  107.         
  108.         if(this.initialize(request, false, responseCachingConfig)==false){
  109.             return false;
  110.         }
  111.         
  112.         return true;
  113.         
  114.     }
  115.     
  116.     @Override
  117.     protected boolean send(ConnettoreMsg request) { 
  118.         
  119.         // - Header Applicativo nella risposta
  120.         boolean headerApplicativoRisposta = false;
  121.         if(this.properties.get(CostantiConnettori.CONNETTORE_STRESS_TEST_HEADER_APPLICATIVO)!=null){
  122.             if("true".equalsIgnoreCase(this.properties.get(CostantiConnettori.CONNETTORE_STRESS_TEST_HEADER_APPLICATIVO).trim()))
  123.                 headerApplicativoRisposta = true;
  124.         }
  125.             
  126.         this.codice = 200;
  127.                 
  128.         try{
  129.             
  130.             // SIMULAZIONE WRITE_TO
  131.             
  132.             org.apache.commons.io.output.NullOutputStream nullOutputStream = org.apache.commons.io.output.NullOutputStream.INSTANCE;
  133.             this.requestMsg.writeTo(nullOutputStream,true);
  134.             nullOutputStream.flush();
  135.             nullOutputStream.close();
  136.                 
  137.             //this.response = request.getRequestMessage();
  138.             //java.io.FileOutputStream fout = new java.io.FileOutputStream("/dev/null");
  139.             //request.getRequestMessage().writeTo(fout,true);
  140.             //fout.flush();
  141.             //fout.close();
  142.             
  143.             this.dataRichiestaInoltrata = DateManager.getDate();
  144.             
  145.             
  146.             
  147.             
  148.             /* ------------  PostOutRequestHandler ------------- */
  149.             this.postOutRequest();
  150.             
  151.             
  152.             
  153.             
  154.             
  155.             
  156.             
  157.             // SLEEP
  158.             // Connettore custom, impostare nei parametri i tempi di sleep
  159.             if(request.getConnectorProperties()!=null){
  160. //              java.util.Enumeration<String> enValues = request.getConnectorProperties().keys();
  161. //              while (enValues.hasMoreElements()) {
  162. //                  String key = (String) enValues.nextElement();
  163. //                  System.out.println("KEY["+key+"]=["+request.getConnectorProperties().get(key)+"]");
  164. //              }
  165.                 
  166.                 Object max = request.getConnectorProperties().get(CostantiConnettori.CONNETTORE_STRESS_TEST_SLEEP_MAX);
  167.                 Object min = request.getConnectorProperties().get(CostantiConnettori.CONNETTORE_STRESS_TEST_SLEEP_MIN);
  168.                 if(max!=null){
  169.                     int maxSleep = Integer.parseInt((String)max);
  170.                     int minSleep = 0;
  171.                     if(min!=null){
  172.                         minSleep = Integer.parseInt((String)min);
  173.                     }
  174.                     int sleep = minSleep + RandomUtilities.getRandom().nextInt(maxSleep-minSleep);
  175.                     if(sleep>1000){
  176.                         int count = sleep/1000;
  177.                         int resto = sleep%1000;
  178.                         this.logger.info("sleep "+sleep+"ms ...",false);
  179.                         for (int i = 0; i < count; i++) {
  180.                             Utilities.sleep(1000);
  181.                         }
  182.                         Utilities.sleep(resto);
  183.                         this.logger.info("sleep "+sleep+"ms terminated", false);
  184.                     }else{
  185.                         this.logger.info("sleep "+sleep+"ms ...", false);
  186.                         Utilities.sleep(sleep);
  187.                         this.logger.info("sleep "+sleep+"ms terminated", false);
  188.                     }
  189.                 }
  190.                 else{
  191.                     Object sleepConstant = request.getConnectorProperties().get(CostantiConnettori.CONNETTORE_STRESS_TEST_SLEEP);
  192.                     if(sleepConstant!=null){
  193.                         int millisecond = Integer.parseInt((String)sleepConstant);
  194.                         if(millisecond>1000){
  195.                             int count = millisecond/1000;
  196.                             int resto = millisecond%1000;
  197.                             this.logger.info("sleep "+millisecond+"ms ...", false);
  198.                             for (int i = 0; i < count; i++) {
  199.                                 Utilities.sleep(1000);
  200.                             }
  201.                             Utilities.sleep(resto);
  202.                             this.logger.info("sleep "+millisecond+"ms terminated", false);
  203.                         }else{
  204.                             this.logger.info("sleep "+millisecond+"ms ...", false);
  205.                             Utilities.sleep(millisecond);
  206.                             this.logger.info("sleep "+millisecond+"ms terminated", false);
  207.                         }
  208.                     }
  209.                 }
  210.             }
  211.             
  212.             
  213.             
  214.             
  215.             
  216.             
  217.             /* ------------  PreInResponseHandler ------------- */
  218.             this.preInResponse();
  219.             
  220.             
  221.             
  222.             // Lettura risposta parametri NotifierInputStream per la risposta
  223.             org.openspcoop2.utils.io.notifier.NotifierInputStreamParams notifierInputStreamParams = null;
  224.             if(this.preInResponseContext!=null){
  225.                 notifierInputStreamParams = this.preInResponseContext.getNotifierInputStreamParams();
  226.             }
  227.             
  228.             
  229.             if(org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione.ONEWAY.equals(request.getBusta().getProfiloDiCollaborazione())){
  230.                 // se non devo generare un riscontro, non e' prevista una risposta
  231.                 if ( ! (request.getBusta().isConfermaRicezione() &&
  232.                         this.openspcoopProperties.isGestioneRiscontri(CostantiRegistroServizi.IMPLEMENTAZIONE_STANDARD))){
  233.                     return true; // non devo generare alcuna risposta
  234.                 }
  235.             }
  236.             String protocolHeader = this.buildProtocolHeader(request);
  237.             if(headerApplicativoRisposta){
  238.                 String hdrApplicativo = HEADER_APPLICATIVO.replace("@SERIAL@", DateManager.getTimeMillis()+"");
  239.                 protocolHeader = hdrApplicativo + "\n" + protocolHeader;
  240.             }
  241.             String messaggio = SOAP_ENVELOPE_RISPOSTA.replace("@HDR@", protocolHeader) + SOAP_ENVELOPE_RISPOSTA_END;
  242.             byte [] messaggioArray = messaggio.getBytes();
  243.             
  244.             ByteArrayInputStream bin = new ByteArrayInputStream(messaggioArray);
  245.             OpenSPCoop2MessageFactory messageFactory = org.openspcoop2.pdd.core.Utilities.getOpenspcoop2MessageFactory(this.logger.getLogger(),this.requestMsg, this.requestInfo, MessageRole.RESPONSE);
  246.             OpenSPCoop2MessageParseResult pr = messageFactory.createMessage(this.requestMsg.getMessageType(),MessageRole.RESPONSE,
  247.                     this.requestMsg.getContentType(),
  248.                     bin,notifierInputStreamParams,
  249.                     this.openspcoopProperties.getAttachmentsProcessingMode());
  250.             // Non funziona con gli attachments: this.responseMsg = OpenSPCoop2MessageFactory.getMessageFactory().createMessage(request.getRequestMessage().getVersioneSoap(),(bout.toByteArray()),notifierInputStreamParams);
  251.             if(pr.getParseException()!=null){
  252.                 this.getPddContext().addObject(org.openspcoop2.core.constants.Costanti.CONTENUTO_RISPOSTA_NON_RICONOSCIUTO_PARSE_EXCEPTION, pr.getParseException());
  253.             }
  254.             this.responseMsg = pr.getMessage_throwParseException();
  255.                         
  256.             // content length
  257.             if(this.responseMsg!=null){
  258.                 this.contentLength = messaggioArray.length;
  259.             }
  260.             
  261.         }catch(Exception e){
  262.             this.eccezioneProcessamento = e;
  263.             this.logger.error("Riscontrato errore durante l'echo del msg soap",e);
  264.             this.errore = "Riscontrato errore durante l'echo del msg soap:" +this.readExceptionMessageFromException(e);
  265.             return false;
  266.         }finally{
  267.             // release database
  268.             this.dbManager.releaseResource(this.openspcoopProperties.getIdentitaPortaDefault(this.getProtocolFactory().getProtocol(), this.requestInfo),"ConnettoreStresstest", this.resource);
  269.         }
  270.         
  271.         return true;
  272.     }
  273.     
  274.     /**
  275.      * Ritorna l'informazione su dove il connettore sta spedendo il messaggio
  276.      * 
  277.      * @return location di inoltro del messaggio
  278.      */
  279.     @Override
  280.     public String getLocation() throws ConnettoreException {
  281.         return ConnettoreUtils.buildLocationWithURLBasedParameter(this.logger!=null ? this.logger.getLogger() : null, this.requestMsg, ConnettoreStresstest.ENDPOINT_TYPE, this.propertiesUrlBased, LOCATION,
  282.                 this.getProtocolFactory(), this.idModulo);
  283.     }
  284.  
  285.     
  286.     
  287.     private String buildProtocolHeader(ConnettoreMsg request) throws Exception{
  288.         Busta bustaRichiesta = request.getBusta();
  289.         if( CostantiLabel.SPCOOP_PROTOCOL_NAME.equals(bustaRichiesta.getProtocollo())){
  290.             return buildSPCoopProtocolHeader(request);
  291.         }
  292.         else{
  293.             return "";
  294.         }
  295.     }
  296.     

  298.     
  299.     private String buildSPCoopProtocolHeader(ConnettoreMsg request) throws Exception{   
  300.         
  301.         Busta bustaRichiesta = request.getBusta();
  302.         
  303.         StatefulMessage state = new StatefulMessage(null, this.logger.getLogger());
  304.         
  305.         Object id = this.getPddContext().getObject(Costanti.ID_TRANSAZIONE);
  306.         String idTransazione = null;
  307.         if(id!=null){
  308.             idTransazione = (String) id;
  309.         }
  310.                 
  311.         StringBuilder protocolHeader = new StringBuilder();
  312.         
  313.         if(bustaRichiesta!=null && (bustaRichiesta.sizeListaEccezioni()==0) && !ConsegnaContenutiApplicativi.ID_MODULO.equals(request.getIdModulo())){
  314.             // Creo busta di risposta solo se la busta di richiesta non conteneva una busta SPCoop Errore e se il profilo lo richiede.
  315.                         
  316.             String idRiscontro = null;  
  317.             
  318.             IProtocolFactory<?> protocolFactory = ProtocolFactoryManager.getInstance().getProtocolFactoryByName(bustaRichiesta.getProtocollo());
  319.             ITraduttore traduttore = protocolFactory.createTraduttore();
  320.             
  321.             protocolHeader.append("<eGov_IT:Intestazione SOAP_ENV:actor=\"http://www.cnipa.it/eGov_it/portadominio\" SOAP_ENV:mustUnderstand=\"1\" " +
  322.                     "xmlns:SOAP_ENV=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:eGov_IT=\"http://www.cnipa.it/schemas/2003/eGovIT/Busta1_0/\"><eGov_IT:IntestazioneMessaggio>");
  323.             
  324.             // mittente
  325.             protocolHeader.append("<eGov_IT:Mittente><eGov_IT:IdentificativoParte tipo=\""+traduttore.toProtocolOrganizationType(bustaRichiesta.getTipoDestinatario())+"\">"+bustaRichiesta.getDestinatario()+"</eGov_IT:IdentificativoParte></eGov_IT:Mittente>");
  326.         
  327.             // destinatario
  328.             protocolHeader.append("<eGov_IT:Destinatario><eGov_IT:IdentificativoParte tipo=\""+traduttore.toProtocolOrganizationType(bustaRichiesta.getTipoMittente())+"\">"+bustaRichiesta.getMittente()+"</eGov_IT:IdentificativoParte></eGov_IT:Destinatario>");
  329.         
  330.             // ProfiloCollaborazione
  331.             if(bustaRichiesta.getProfiloDiCollaborazione()!=null){

  333.                 
  334.                 if(org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione.ONEWAY.equals(bustaRichiesta.getProfiloDiCollaborazione()) &&
  335.                         bustaRichiesta.isConfermaRicezione() &&
  336.                         this.openspcoopProperties.isGestioneRiscontri(CostantiRegistroServizi.IMPLEMENTAZIONE_STANDARD)){
  337.                     
  338.                         protocolHeader.append("<eGov_IT:ProfiloCollaborazione>"+traduttore.toString(bustaRichiesta.getProfiloDiCollaborazione())+"</eGov_IT:ProfiloCollaborazione>");
  339.                         // Attendono riscontro
  340.                         idRiscontro = bustaRichiesta.getID();
  341.                 } else if(org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione.ASINCRONO_ASIMMETRICO.equals(bustaRichiesta.getProfiloDiCollaborazione()) &&
  342.                         bustaRichiesta.getRiferimentoMessaggio()==null){
  343.                     
  344.                         // devo generare ricevuta
  345.                         protocolHeader.append("<eGov_IT:ProfiloCollaborazione tipo=\""+traduttore.toProtocolServiceType(bustaRichiesta.getTipoServizio())+"\" servizioCorrelato=\""+
  346.                                 (bustaRichiesta.getServizio()+"Correlato")+"\" >"+traduttore.toString(bustaRichiesta.getProfiloDiCollaborazione())+"</eGov_IT:ProfiloCollaborazione>");
  347.                 } else if(org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione.ASINCRONO_SIMMETRICO.equals(bustaRichiesta.getProfiloDiCollaborazione()) &&
  348.                         bustaRichiesta.getRiferimentoMessaggio()==null){
  349.                 
  350.                     // salvo messaggio sul database asincrono/repositoryEGov
  351.                     // get database
  352.                     try{
  353.                         this.resource = this.dbManager.getResource(this.openspcoopProperties.getIdentitaPortaDefault(this.getProtocolFactory().getProtocol(), this.requestInfo),"ConnettoreStresstest",idTransazione);
  354.                     }catch(Exception e){
  355.                         throw new Exception("Risorsa non ottenibile",e);
  356.                     }
  357.                     if(this.resource==null)
  358.                         throw new Exception("Risorsa is null");
  359.                     if(this.resource.getResource() == null)
  360.                         throw new Exception("Connessione is null");
  361.                     Connection connectionDB = (Connection) this.resource.getResource();
  362.                     //POOL,TRANSACTIONISOLATION:connectionDB.setTransactionIsolation(DBManager.getTransactionIsolationLevel());
  363.                     
  364.                     state.setConnectionDB(connectionDB);
  365.                     
  366.                     // repository
  367.                     RepositoryBuste repositoryBuste = new RepositoryBuste(state, true,this.getProtocolFactory());
  368.                     repositoryBuste.registraBustaIntoInBox(bustaRichiesta, new ArrayList<>() ,
  369.                             OpenSPCoop2Properties.getInstance().getRepositoryIntervalloScadenzaMessaggi());
  370.                     Integrazione infoIntegrazione = new Integrazione();
  371.                     infoIntegrazione.setIdModuloInAttesa(null);
  372.                     repositoryBuste.aggiornaInfoIntegrazioneIntoInBox(bustaRichiesta.getID(),infoIntegrazione);
  373.                 
  374.                     // asincrono
  375.                     ProfiloDiCollaborazione profiloCollaborazione = new ProfiloDiCollaborazione(state,this.getProtocolFactory());
  376.                     profiloCollaborazione.asincronoSimmetrico_registraRichiestaRicevuta(bustaRichiesta.getID(),bustaRichiesta.getCollaborazione(),
  377.                             bustaRichiesta.getTipoServizioCorrelato(),bustaRichiesta.getServizioCorrelato(),bustaRichiesta.getVersioneServizioCorrelato(),true,
  378.                             this.openspcoopProperties.getRepositoryIntervalloScadenzaMessaggi());
  379.                 
  380.                     // commit
  381.                     try{
  382.                         connectionDB.setAutoCommit(false);
  383.                         state.executePreparedStatement(); 
  384.             
  385.                         connectionDB.commit();
  386.                         connectionDB.setAutoCommit(true);
  387.                     }catch (Exception e) {  
  388.                         this.logger.error("Riscontrato errore durante la gestione transazione del DB per la richiesta: "+e.getMessage(),e);
  389.                         // Rollback quanto effettuato (se l'errore e' avvenuto sul commit, o prima nell'execute delle PreparedStatement)
  390.                         try{
  391.                             connectionDB.rollback();
  392.                         }catch(Exception er){
  393.                             // ignore
  394.                         }
  395.                         state.closePreparedStatement(); // Chiude le PreparedStatement aperte(e non eseguite) per il save del Msg
  396.                     }finally {
  397.                         // Ripristino connessione
  398.                         try{
  399.                             connectionDB.setAutoCommit(true);
  400.                         }catch(Exception er){
  401.                             // ignore
  402.                         }
  403.                     }
  404.                     protocolHeader.append("<eGov_IT:ProfiloCollaborazione>"+traduttore.toString(bustaRichiesta.getProfiloDiCollaborazione())+"</eGov_IT:ProfiloCollaborazione>");
  405.                 }
  406.                 else{
  407.                     protocolHeader.append("<eGov_IT:ProfiloCollaborazione>"+traduttore.toString(bustaRichiesta.getProfiloDiCollaborazione())+"</eGov_IT:ProfiloCollaborazione>");
  408.                 }
  409.             }
  410.             
  411.             // servizio
  412.             if(bustaRichiesta.getTipoServizio()!=null && bustaRichiesta.getServizio()!=null)
  413.                 protocolHeader.append("<eGov_IT:Servizio tipo=\""+traduttore.toProtocolServiceType(bustaRichiesta.getTipoServizio())+"\">"+bustaRichiesta.getServizio()+"</eGov_IT:Servizio>");
  414.             
  415.             // azione
  416.             if(bustaRichiesta.getAzione()!=null)
  417.                 protocolHeader.append("<eGov_IT:Azione>"+bustaRichiesta.getAzione()+"</eGov_IT:Azione>");
  418.             
  419.             // Messaggio
  420.             protocolHeader.append("<eGov_IT:Messaggio>");
  421.             
  422.             // Identificativo egov
  423.             String dominio = null;
  424.             if(request.getConnectorProperties()!=null)
  425.                 dominio = request.getConnectorProperties().get("identificativo-porta");
  426.             if(dominio==null)
  427.                 dominio=bustaRichiesta.getDestinatario()+"SPCoopIT";
  428.             String idBustaRisposta = null;
  429.             Imbustamento imbustatore = new Imbustamento(this.logger.getLogger(), this.getProtocolFactory(),state);
  430.             try{
  431.                 idBustaRisposta = 
  432.                     imbustatore.buildID(new IDSoggetto(bustaRichiesta.getTipoDestinatario(), bustaRichiesta.getDestinatario(), dominio), 
  433.                             null, 
  434.                             this.openspcoopProperties.getGestioneSerializableDBAttesaAttiva(),
  435.                             this.openspcoopProperties.getGestioneSerializableDBCheckInterval(),
  436.                             RuoloMessaggio.RISPOSTA);
  437.             }catch(Exception e){
  438.                 // rilancio
  439.                 throw e;
  440.             }
  441.             protocolHeader.append("<eGov_IT:Identificatore>"+idBustaRisposta+"</eGov_IT:Identificatore>");
  442.         
  443.             // OraRegistrazione
  444.             String oraS = traduttore.getDate_protocolFormat(bustaRichiesta.getOraRegistrazione());
  445.             protocolHeader.append("<eGov_IT:OraRegistrazione tempo=\""+traduttore.toString(bustaRichiesta.getTipoOraRegistrazione())+"\">"+
  446.                     oraS+"</eGov_IT:OraRegistrazione>");
  447.             
  448.             // RiferimentoMessaggio
  449.             protocolHeader.append("<eGov_IT:RiferimentoMessaggio>"+bustaRichiesta.getID()+"</eGov_IT:RiferimentoMessaggio>");
  450.             
  451.             protocolHeader.append("</eGov_IT:Messaggio>");
  452.         
  453.             protocolHeader.append("</eGov_IT:IntestazioneMessaggio>");
  454.             
  455.             if(idRiscontro!=null){
  456.                 
  457.                 protocolHeader.append("<eGov_IT:ListaRiscontri><eGov_IT:Riscontro>" +
  458.                         "<eGov_IT:Identificatore>"+idRiscontro+"</eGov_IT:Identificatore>" +
  459.                         "<eGov_IT:OraRegistrazione tempo=\""+traduttore.toString(bustaRichiesta.getTipoOraRegistrazione())+"\">"+oraS+"</eGov_IT:OraRegistrazione>" +
  460.                                 "</eGov_IT:Riscontro> </eGov_IT:ListaRiscontri>");
  461.             }
  462.             
  463.             protocolHeader.append("</eGov_IT:Intestazione>");
  464.             
  465.         }
  466.         
  467.         return protocolHeader.toString();
  468.     }
  469.     
  470. }




Created with JaCoCo 0.8.8.202204050719