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

  21. package org.openspcoop2.pdd.core.state;

  23. import java.io.Serializable;

  25. import org.openspcoop2.message.OpenSPCoop2Message;
  26. import org.openspcoop2.pdd.core.DimensioneMessaggiAttraversamentoPdD;
  27. import org.openspcoop2.pdd.core.PdDContext;
  28. import org.openspcoop2.pdd.core.TempiAttraversamentoPDD;
  29. import org.openspcoop2.protocol.sdk.Busta;
  30. import org.openspcoop2.protocol.sdk.state.StateMap;
  31. import org.openspcoop2.protocol.sdk.state.StatelessMessage;
  32. import org.openspcoop2.utils.UtilsException;

  34. /**
  35.  * Oggetto che rappresenta lo stato di una richiesta/risposta all'interno della PdD
  36.  *
  37.  * @author Poli Andrea (apoli@link.it)
  38.  * @author Fabio Tronci (tronci@link.it)
  39.  * @author $Author$
  40.  * @version $Rev$, $Date$
  41.  */
  42. public class OpenSPCoopStateless extends OpenSPCoopState implements Serializable {

  44.     /**
  45.      * 
  46.      */
  47.     private static final long serialVersionUID = 1L;
  48.     
  49.     /* ---------- Messaggi  ----------*/
  50.     private OpenSPCoop2Message richiestaMsg = null;
  51.     private OpenSPCoop2Message rispostaMsg = null;
  52.     
  53.     /* ---------- Contiene i proprietari dei messaggi  ----------*/
  54.     private String destinatarioRequestMsgLib;
  55.     private String destinatarioResponseMsgLib;
  56.     
  57.     /* ---------- Contiene i tempi di attraversamento  ----------*/
  58.     private TempiAttraversamentoPDD tempiAttraversamentoPDD = null;
  59.     
  60.     /* ---------- Contiene la dimensione dei messaggi  ----------*/
  61.     private DimensioneMessaggiAttraversamentoPdD dimensioneMessaggiAttraversamentoPDD = null;

  63.     /* ---------- ID di Correlazione Applicativa ------------ */
  64.     private String idCorrelazioneApplicativa = null;
  65.     private String idCorrelazioneApplicativaRisposta = null;

  67.     /* ---------- PdDContext -------------*/
  68.     private PdDContext pddContext = null;
  69.     
  70.     
  71.     
  72.     
  73.     /* ---------- Costruttori  ----------*/
  74.     public OpenSPCoopStateless(StatelessMessage richiesta,OpenSPCoop2Message richiestaMsg,
  75.             StatelessMessage risposta,OpenSPCoop2Message rispostaMsg){
  76.         this.richiestaStato = richiesta;
  77.         this.richiestaMsg = richiestaMsg;
  78.         this.rispostaStato = risposta;
  79.         this.rispostaMsg = rispostaMsg;
  80.         this.useConnection = false;
  81.         this.tempiAttraversamentoPDD = new TempiAttraversamentoPDD();
  82.         this.dimensioneMessaggiAttraversamentoPDD = new DimensioneMessaggiAttraversamentoPdD();
  83.     }
  84.     
  85.     public OpenSPCoopStateless(StatelessMessage richiesta,OpenSPCoop2Message richiestaMsg){
  86.         this.richiestaStato = richiesta;
  87.         this.richiestaMsg = richiestaMsg;
  88.         this.useConnection = false;
  89.         this.tempiAttraversamentoPDD = new TempiAttraversamentoPDD();
  90.         this.dimensioneMessaggiAttraversamentoPDD = new DimensioneMessaggiAttraversamentoPdD();
  91.     }
  92.     
  93.     public OpenSPCoopStateless(){
  94.         this.useConnection = false;
  95.         this.tempiAttraversamentoPDD = new TempiAttraversamentoPDD();
  96.         this.dimensioneMessaggiAttraversamentoPDD = new DimensioneMessaggiAttraversamentoPdD();
  97.     }

  99.     
  100.     
  101.     
  102.     
  103.     
  104.     /* ----------- Init resource ------------*/
  105.     @Override
  106.     public void updateStatoRichiesta() throws UtilsException{
  107.         
  108.         StateMap pstmt = null;
  109.         Busta bustaTmp = null;
  110.         Busta bustaCorrelataTmp = null;
  111.         if(this.richiestaStato!=null){
  112.             if(this.richiestaStato.getPreparedStatement()!=null)
  113.                 pstmt = this.richiestaStato.getPreparedStatement();
  114.             StatelessMessage statelessMessage = (StatelessMessage) this.richiestaStato;
  115.             bustaTmp = statelessMessage.getBusta();
  116.             bustaCorrelataTmp = statelessMessage.getBustaCorrelata();
  117.         }
  118.         
  119.         this.richiestaStato = new StatelessMessage(this.connectionDB,this.logger);
  120.         if(pstmt!=null){
  121.             this.richiestaStato.addPreparedStatement(pstmt.getPreparedStatement());
  122.         }
  123.         if(bustaTmp!=null){
  124.             ((StatelessMessage) this.richiestaStato).setBusta(bustaTmp);
  125.         }
  126.         if(bustaCorrelataTmp!=null){
  127.             ((StatelessMessage) this.richiestaStato).setBustaCorrelata(bustaCorrelataTmp);
  128.         }
  129.         
  130.     }
  131.     @Override
  132.     public void updateStatoRisposta() throws UtilsException{
  133.         
  134.         StateMap pstmt = null;
  135.         Busta bustaTmp = null;
  136.         Busta bustaCorrelataTmp = null;
  137.         if(this.rispostaStato!=null){
  138.             if(this.rispostaStato.getPreparedStatement()!=null)
  139.                 pstmt = this.rispostaStato.getPreparedStatement();
  140.             StatelessMessage statelessMessage = (StatelessMessage) this.rispostaStato;
  141.             bustaTmp = statelessMessage.getBusta();
  142.             bustaCorrelataTmp = statelessMessage.getBustaCorrelata();
  143.         }
  144.         
  145.         this.rispostaStato = new StatelessMessage(this.connectionDB,this.logger);
  146.         if(pstmt!=null){
  147.             this.rispostaStato.addPreparedStatement(pstmt.getPreparedStatement());
  148.         }
  149.         if(bustaTmp!=null){
  150.             ((StatelessMessage) this.rispostaStato).setBusta(bustaTmp);
  151.         }
  152.         if(bustaCorrelataTmp!=null){
  153.             ((StatelessMessage) this.rispostaStato).setBustaCorrelata(bustaCorrelataTmp);
  154.         }

  156.     }
  157.     
  158.     
  159.     
  160.     

  162.     
  163.     

  165.     
  166.     
  167.     
  168.     
  169.     /* ----------- Serializzazione ------------*/

  171.     public OpenSPCoopStateless rendiSerializzabile() {
  172.         OpenSPCoopStateless stato = new OpenSPCoopStateless();
  173.         StatelessMessage statoRichiesta = new StatelessMessage(null, null);
  174.         StatelessMessage statoRisposta = new StatelessMessage(null, null);
  175.         statoRichiesta.setBusta(((StatelessMessage)this.richiestaStato).getBusta());
  176.         statoRisposta.setBusta(((StatelessMessage)this.rispostaStato).getBusta());
  177.         stato.setStatoRichiesta(statoRichiesta);
  178.         stato.setStatoRisposta(statoRisposta);
  179.         stato.setTempiAttraversamentoPDD(this.getTempiAttraversamentoPDD());
  180.         stato.setDimensioneMessaggiAttraversamentoPDD(this.getDimensioneMessaggiAttraversamentoPDD());
  181.         return stato;
  182.     }
  183.     
  184.     
  185.     
  186.     
  187.     
  188.     
  189.     
  190.     
  191.     /* ----------- GET / SET ------------*/
  192.     
  193.     public void setDestinatarioRequestMsgLib(String nextLib) {
  194.         this.destinatarioRequestMsgLib = nextLib;
  195.     }

  197.     public String getDestinatarioRequestMsgLib(){
  198.         return this.destinatarioRequestMsgLib;
  199.     }

  201.     public String getDestinatarioResponseMsgLib() {
  202.         return this.destinatarioResponseMsgLib;
  203.     }

  205.     public void setDestinatarioResponseMsgLib(String destinatarioResponseMsgLib) {
  206.         this.destinatarioResponseMsgLib = destinatarioResponseMsgLib;
  207.     }
  208.     
  209.     public void setRichiestaMsg(OpenSPCoop2Message richiestaMsg) {
  210.         this.richiestaMsg = richiestaMsg;
  211.     }
  212.     
  213.     public OpenSPCoop2Message getRichiestaMsg() {
  214.         return this.richiestaMsg;
  215.     }

  217.     public void setRispostaMsg(OpenSPCoop2Message rispostaMsg) {
  218.         this.rispostaMsg = rispostaMsg;
  219.     }
  220.     
  221.     public OpenSPCoop2Message getRispostaMsg() {
  222.         return this.rispostaMsg;
  223.     }
  224.     
  225.     public TempiAttraversamentoPDD getTempiAttraversamentoPDD() {
  226.         return this.tempiAttraversamentoPDD;
  227.     }
  228.     
  229.     public void setTempiAttraversamentoPDD(TempiAttraversamentoPDD tempiAttraversamentoPDD) {
  230.         this.tempiAttraversamentoPDD = tempiAttraversamentoPDD;
  231.     }
  232.     
  233.     public DimensioneMessaggiAttraversamentoPdD getDimensioneMessaggiAttraversamentoPDD() {
  234.         return this.dimensioneMessaggiAttraversamentoPDD;
  235.     }

  237.     public void setDimensioneMessaggiAttraversamentoPDD(
  238.             DimensioneMessaggiAttraversamentoPdD dimensioneMessaggiAttraversamentoPDD) {
  239.         this.dimensioneMessaggiAttraversamentoPDD = dimensioneMessaggiAttraversamentoPDD;
  240.     }
  241.     
  242.     public String getIDCorrelazioneApplicativa() {
  243.         return this.idCorrelazioneApplicativa;
  244.     }

  246.     public void setIDCorrelazioneApplicativa(String idCorrelazioneApplicativa) {
  247.         this.idCorrelazioneApplicativa = idCorrelazioneApplicativa;
  248.     }

  250.     public PdDContext getPddContext() {
  251.         return this.pddContext;
  252.     }

  254.     public void setPddContext(PdDContext pddContext) {
  255.         this.pddContext = pddContext;
  256.     }

  258.     public String getIDCorrelazioneApplicativaRisposta() {
  259.         return this.idCorrelazioneApplicativaRisposta;
  260.     }

  262.     public void setIDCorrelazioneApplicativaRisposta(
  263.             String idCorrelazioneApplicativaRisposta) {
  264.         this.idCorrelazioneApplicativaRisposta = idCorrelazioneApplicativaRisposta;
  265.     }

  267. }
Created with JaCoCo 0.8.8.202204050719