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


  22. package org.openspcoop2.pdd.core.jmx;


  25. import java.util.Iterator;

  27. import javax.management.Attribute;
  28. import javax.management.AttributeList;
  29. import javax.management.AttributeNotFoundException;
  30. import javax.management.DynamicMBean;
  31. import javax.management.InvalidAttributeValueException;
  32. import javax.management.JMException;
  33. import javax.management.MBeanAttributeInfo;
  34. import javax.management.MBeanConstructorInfo;
  35. import javax.management.MBeanException;
  36. import javax.management.MBeanInfo;
  37. import javax.management.MBeanOperationInfo;
  38. import javax.management.MBeanParameterInfo;
  39. import javax.management.NotificationBroadcasterSupport;
  40. import javax.management.ReflectionException;

  42. import org.openspcoop2.core.config.TipoFiltroAbilitazioneServizi;
  43. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  44. import org.openspcoop2.pdd.core.StatoServiziPdD;
  45. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;


  48. /**
  49.  * Implementazione JMX per la gestione dell'autorizzazione
  50.  *   
  51.  * @author Poli Andrea (apoli@link.it)
  52.  * @author $Author$
  53.  * @version $Rev$, $Date$
  54.  */
  55. public class StatoServiziJMXResource extends NotificationBroadcasterSupport implements DynamicMBean {

  57.     /** Nomi proprieta' */
  58.     public static final String COMPONENTE_PD = "Servizio PortaDelegata";
  59.     public static final String COMPONENTE_PD_ABILITAZIONI = "Servizio PortaDelegata (Abilitazioni Puntuali)";
  60.     public static final String COMPONENTE_PD_DISABILITAZIONI = "Servizio PortaDelegata (Disabilitazioni Puntuali)";
  61.     public static final String COMPONENTE_PA = "Servizio PortaApplicativa";
  62.     public static final String COMPONENTE_PA_ABILITAZIONI = "Servizio PortaApplicativa (Abilitazioni Puntuali)";
  63.     public static final String COMPONENTE_PA_DISABILITAZIONI = "Servizio PortaApplicativa (Disabilitazioni Puntuali)";
  64.     public static final String COMPONENTE_IM = "Servizio IntegrationManager";

  66.     /** Nomi metodi */
  67.     public static final String ABILITA_COMPONENTE_PD = "abilitaServizioPortaDelegata"; 
  68.     public static final String ABILITA_COMPONENTE_PA = "abilitaServizioPortaApplicativa"; 
  69.     public static final String ABILITA_COMPONENTE_IM = "abilitaServizioIntegrationManager"; 
  70.     public static final String ABILITA_SERVIZI = "abilitazioneCompletaServizi";

  72.     public static final String DISABILITA_COMPONENTE_PD = "disabilitaServizioPortaDelegata"; 
  73.     public static final String DISABILITA_COMPONENTE_PA = "disabilitaServizioPortaApplicativa"; 
  74.     public static final String DISABILITA_COMPONENTE_IM = "disabilitaServizioIntegrationManager"; 
  75.     public static final String DISABILITA_SERVIZI = "disabilitazioneCompletaServizi";

  77.     public static final String ABILITA_ADD_FILTRO_ABILITAZIONE_PD = "addFiltroAbilitazioneServizioPortaDelegata";
  78.     public static final String ABILITA_ADD_FILTRO_DISABILITAZIONE_PD = "addFiltroDisabilitazioneServizioPortaDelegata";
  79.     public static final String ABILITA_ADD_FILTRO_ABILITAZIONE_PA = "addFiltroAbilitazioneServizioPortaApplicativa";
  80.     public static final String ABILITA_ADD_FILTRO_DISABILITAZIONE_PA = "addFiltroDisabilitazioneServizioPortaApplicativa";

  82.     public static final String ABILITA_REMOVE_FILTRO_ABILITAZIONE_PD = "removeFiltroAbilitazioneServizioPortaDelegata";
  83.     public static final String ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PD = "removeFiltroDisabilitazioneServizioPortaDelegata";
  84.     public static final String ABILITA_REMOVE_FILTRO_ABILITAZIONE_PA = "removeFiltroAbilitazioneServizioPortaApplicativa";
  85.     public static final String ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PA = "removeFiltroDisabilitazioneServizioPortaApplicativa";



  89. //  /** Attributi */
  90. //  private String componentePD = CostantiConfigurazione.ABILITATO.getValue();
  91. //  private String componentePD_abilitazioniPuntuali = "";
  92. //  private String componentePD_disabilitazioniPuntuali = "";
  93. //
  94. //  private String componentePA = CostantiConfigurazione.ABILITATO.getValue();
  95. //  private String componentePA_abilitazioniPuntuali = "";
  96. //  private String componentePA_disabilitazioniPuntuali = "";
  97. //
  98. //  private String componenteIM = CostantiConfigurazione.ABILITATO.getValue();
  99.     
  100.     // uso anzi sempre la lettura effettiva, altrimenti si creano situazioni di stallo quando una cache della configurazione media il salvataggio reale
  101.     public String getComponentePD(){
  102.         return StatoServiziPdD.isPDServiceActive() ? CostantiConfigurazione.ABILITATO.getValue() : CostantiConfigurazione.DISABILITATO.getValue();
  103.     }
  104.     public String getComponentePD_abilitazioniPuntuali(){
  105.         return visualizzaFiltriAbilitazioniServizioPortaDelegata();
  106.     }
  107.     public String getComponentePD_disabilitazioniPuntuali(){
  108.         return visualizzaFiltriDisabilitazioniServizioPortaDelegata();
  109.     }
  110.     
  111.     public String getComponentePA(){
  112.         return StatoServiziPdD.isPAServiceActive() ? CostantiConfigurazione.ABILITATO.getValue() : CostantiConfigurazione.DISABILITATO.getValue();
  113.     }
  114.     public String getComponentePA_abilitazioniPuntuali(){
  115.         return visualizzaFiltriAbilitazioniServizioPortaApplicativa();
  116.     }
  117.     public String getComponentePA_disabilitazioniPuntuali(){
  118.         return visualizzaFiltriDisabilitazioniServizioPortaApplicativa();
  119.     }
  120.     
  121.     public String getComponenteIM(){
  122.         return StatoServiziPdD.isIMServiceActive() ? CostantiConfigurazione.ABILITATO.getValue() : CostantiConfigurazione.DISABILITATO.getValue();
  123.     }



  127.     /** getAttribute */
  128.     @Override
  129.     public Object getAttribute(String attributeName) throws AttributeNotFoundException,MBeanException,ReflectionException{

  131.         if( (attributeName==null) || (attributeName.equals("")) )
  132.             throw new IllegalArgumentException("Il nome dell'attributo e' nullo o vuoto");

  134.         if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_PD))
  135.             return this.getComponentePD();
  136.         else if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_PD_ABILITAZIONI))
  137.             return this.getComponentePD_abilitazioniPuntuali();
  138.         else if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_PD_DISABILITAZIONI))
  139.             return this.getComponentePD_disabilitazioniPuntuali();

  141.         else if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_PA))
  142.             return this.getComponentePA();
  143.         else if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_PA_ABILITAZIONI))
  144.             return this.getComponentePA_abilitazioniPuntuali();
  145.         else if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_PA_DISABILITAZIONI))
  146.             return this.getComponentePA_disabilitazioniPuntuali();

  148.         else if(attributeName.equals(StatoServiziJMXResource.COMPONENTE_IM))
  149.             return this.getComponenteIM();

  151.         throw new AttributeNotFoundException("Attributo "+attributeName+" non trovato");
  152.     }

  154.     /** getAttributes */
  155.     @Override
  156.     public AttributeList getAttributes(String [] attributesNames){

  158.         if(attributesNames==null)
  159.             throw new IllegalArgumentException("Array nullo");

  161.         AttributeList list = new AttributeList();
  162.         for (int i=0; i<attributesNames.length; i++){
  163.             try{
  164.                 list.add(new Attribute(attributesNames[i],getAttribute(attributesNames[i])));
  165.             }catch(JMException ex){}
  166.         }
  167.         return list;
  168.     }

  170.     /** setAttribute */
  171.     @Override
  172.     public void setAttribute(Attribute attribute) throws AttributeNotFoundException, InvalidAttributeValueException, MBeanException, ReflectionException{

  174.         if( attribute==null )
  175.             throw new IllegalArgumentException("Il nome dell'attributo e' nullo");

  177.         try{

  179.             if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_PD)){
  180.                 String v = (String) attribute.getValue();
  181.                 if(CostantiConfigurazione.ABILITATO.equals(v)){
  182.                     this.abilitaServizioPortaDelegata();
  183.                 }else{
  184.                     this.disabilitaServizioPortaDelegata();
  185.                 }
  186.             }           
  187.             else if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_PA)){
  188.                 String v = (String) attribute.getValue();
  189.                 if(CostantiConfigurazione.ABILITATO.equals(v)){
  190.                     this.abilitaServizioPortaApplicativa();
  191.                 }else{
  192.                     this.disabilitaServizioPortaApplicativa();
  193.                 }
  194.             }

  196.             else if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_IM)){
  197.                 String v = (String) attribute.getValue();
  198.                 if(CostantiConfigurazione.ABILITATO.equals(v)){
  199.                     this.abilitaServizioIntegrationManager();
  200.                 }else{
  201.                     this.disabilitaServizioIntegrationManager();
  202.                 }
  203.             }

  205.             else if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_PD_ABILITAZIONI)){
  206.                 // nothing DO
  207.             }
  208.             else if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_PD_DISABILITAZIONI)){
  209.                 // nothing DO
  210.             }
  211.             else if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_PA_ABILITAZIONI)){
  212.                 // nothing DO
  213.             }
  214.             else if(attribute.getName().equals(StatoServiziJMXResource.COMPONENTE_PA_DISABILITAZIONI)){
  215.                 // nothing DO
  216.             }

  218.             else
  219.                 throw new AttributeNotFoundException("Attributo "+attribute.getName()+" non trovato");

  221.         }catch(ClassCastException ce){
  222.             throw new InvalidAttributeValueException("il tipo "+attribute.getValue().getClass()+" dell'attributo "+attribute.getName()+" non e' valido");
  223.         }catch(JMException j){
  224.             throw new MBeanException(j);
  225.         }

  227.     }

  229.     /** setAttributes */
  230.     @Override
  231.     public AttributeList setAttributes(AttributeList list){

  233.         if(list==null)
  234.             throw new IllegalArgumentException("Lista degli attributi e' nulla");

  236.         AttributeList ret = new AttributeList();
  237.         Iterator<?> it = ret.iterator();

  239.         while(it.hasNext()){
  240.             try{
  241.                 Attribute attribute = (Attribute) it.next();
  242.                 setAttribute(attribute);
  243.                 ret.add(attribute);
  244.             }catch(JMException ex){}
  245.         }

  247.         return ret;

  249.     }

  251.     /** invoke */
  252.     @Override
  253.     public Object invoke(String actionName, Object[]params, String[]signature) throws MBeanException,ReflectionException{

  255.         if( (actionName==null) || (actionName.equals("")) )
  256.             throw new IllegalArgumentException("Nessuna operazione definita");

  258.         if(actionName.equals(StatoServiziJMXResource.ABILITA_COMPONENTE_PD)){
  259.             return this.abilitaServizioPortaDelegata();
  260.         }
  261.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_COMPONENTE_PA)){
  262.             return this.abilitaServizioPortaApplicativa();
  263.         }
  264.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_COMPONENTE_IM)){
  265.             return this.abilitaServizioIntegrationManager();
  266.         }
  267.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_SERVIZI)){
  268.             return this.abilitazioneCompletaServizi();
  269.         }

  271.         else if(actionName.equals(StatoServiziJMXResource.DISABILITA_COMPONENTE_PD)){
  272.             return this.disabilitaServizioPortaDelegata();
  273.         }
  274.         else if(actionName.equals(StatoServiziJMXResource.DISABILITA_COMPONENTE_PA)){
  275.             return this.disabilitaServizioPortaApplicativa();
  276.         }
  277.         else if(actionName.equals(StatoServiziJMXResource.DISABILITA_COMPONENTE_IM)){
  278.             return this.disabilitaServizioIntegrationManager();
  279.         }
  280.         else if(actionName.equals(StatoServiziJMXResource.DISABILITA_SERVIZI)){
  281.             return this.disabilitazioneCompletaServizi();
  282.         }

  284.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_ADD_FILTRO_ABILITAZIONE_PD)){
  285.             if(params.length != 10)
  286.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_ADD_FILTRO_ABILITAZIONE_PD+"] Lunghezza parametri non corretta: "+params.length));
  287.             return addFiltroAbilitazioneServizioPortaDelegata(getTipoFiltroAbilitazioneServizi(params));
  288.         }
  289.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_ADD_FILTRO_DISABILITAZIONE_PD)){
  290.             if(params.length != 10)
  291.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_ADD_FILTRO_DISABILITAZIONE_PD+"] Lunghezza parametri non corretta: "+params.length));
  292.             return addFiltroDisabilitazioneServizioPortaDelegata(getTipoFiltroAbilitazioneServizi(params));
  293.         }
  294.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_ABILITAZIONE_PD)){
  295.             if(params.length != 10)
  296.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_ABILITAZIONE_PD+"] Lunghezza parametri non corretta: "+params.length));
  297.             return removeFiltroAbilitazioneServizioPortaDelegata(getTipoFiltroAbilitazioneServizi(params));
  298.         }
  299.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PD)){
  300.             if(params.length != 10)
  301.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PD+"] Lunghezza parametri non corretta: "+params.length));
  302.             return removeFiltroDisabilitazioneServizioPortaDelegata(getTipoFiltroAbilitazioneServizi(params));
  303.         }

  305.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_ADD_FILTRO_ABILITAZIONE_PA)){
  306.             if(params.length != 10)
  307.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_ADD_FILTRO_ABILITAZIONE_PA+"] Lunghezza parametri non corretta: "+params.length));
  308.             return addFiltroAbilitazioneServizioPortaApplicativa(getTipoFiltroAbilitazioneServizi(params));
  309.         }
  310.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_ADD_FILTRO_DISABILITAZIONE_PA)){
  311.             if(params.length != 10)
  312.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_ADD_FILTRO_DISABILITAZIONE_PA+"] Lunghezza parametri non corretta: "+params.length));
  313.             return addFiltroDisabilitazioneServizioPortaApplicativa(getTipoFiltroAbilitazioneServizi(params));
  314.         }
  315.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_ABILITAZIONE_PA)){
  316.             if(params.length != 10)
  317.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_ABILITAZIONE_PA+"] Lunghezza parametri non corretta: "+params.length));
  318.             return removeFiltroAbilitazioneServizioPortaApplicativa(getTipoFiltroAbilitazioneServizi(params));
  319.         }
  320.         else if(actionName.equals(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PA)){
  321.             if(params.length != 10)
  322.                 throw new MBeanException(new Exception("["+StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PA+"] Lunghezza parametri non corretta: "+params.length));
  323.             return removeFiltroDisabilitazioneServizioPortaApplicativa(getTipoFiltroAbilitazioneServizi(params));
  324.         }

  326.         throw new UnsupportedOperationException("Operazione "+actionName+" sconosciuta");
  327.     }

  329.     private TipoFiltroAbilitazioneServizi getTipoFiltroAbilitazioneServizi(Object [] params){
  330.         TipoFiltroAbilitazioneServizi tipo = new TipoFiltroAbilitazioneServizi();

  332.         int index = 0;

  334.         String tmp = (String) params[index];
  335.         if(tmp!=null && !"".equals(tmp)){
  336.             tipo.setTipoSoggettoFruitore(tmp);
  337.         }
  338.         index++;
  339.         tmp = (String) params[index];
  340.         if(tmp!=null && !"".equals(tmp)){
  341.             tipo.setSoggettoFruitore(tmp);
  342.         }
  343.         index++;
  344.         tmp = (String) params[index];
  345.         if(tmp!=null && !"".equals(tmp)){
  346.             tipo.setIdentificativoPortaFruitore(tmp);
  347.         }

  349.         index++;
  350.         tmp = (String) params[index];
  351.         if(tmp!=null && !"".equals(tmp)){
  352.             tipo.setTipoSoggettoErogatore(tmp);
  353.         }
  354.         index++;
  355.         tmp = (String) params[index];
  356.         if(tmp!=null && !"".equals(tmp)){
  357.             tipo.setSoggettoErogatore(tmp);
  358.         }
  359.         index++;
  360.         tmp = (String) params[index];
  361.         if(tmp!=null && !"".equals(tmp)){
  362.             tipo.setIdentificativoPortaErogatore(tmp);
  363.         }

  365.         index++;
  366.         tmp = (String) params[index];
  367.         if(tmp!=null && !"".equals(tmp)){
  368.             tipo.setTipoServizio(tmp);
  369.         }
  370.         index++;
  371.         tmp = (String) params[index];
  372.         if(tmp!=null && !"".equals(tmp)){
  373.             tipo.setServizio(tmp);
  374.         }
  375.         index++;
  376.         Integer tmpI = (Integer) params[index];
  377.         if(tmpI!=null){
  378.             tipo.setVersioneServizio(tmpI);
  379.         }

  381.         index++;
  382.         tmp = (String) params[index];
  383.         if(tmp!=null && !"".equals(tmp)){
  384.             tipo.setAzione(tmp);
  385.         }

  387.         return tipo;
  388.     }

  390.     /* MBean info */
  391.     @Override
  392.     public MBeanInfo getMBeanInfo(){

  394.         // Descrizione della classe nel MBean
  395.         String className = this.getClass().getName();
  396.         String description = "Stato dei servizi attivi";

  398.         // MetaData per gli attributi
  399.         MBeanAttributeInfo componentePD_VAR 
  400.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_PD,String.class.getName(),
  401.                 "Indicazione se e' il servizio PortaDelegata risulta abilitato",
  402.                 JMXUtils.JMX_ATTRIBUTE_READABLE,JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);
  403.         MBeanAttributeInfo componentePD_abilitazioni_VAR 
  404.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_PD_ABILITAZIONI,String.class.getName(),
  405.                 "Filtri puntuali che abilitano l'utilizzo del servizio PortaDelegata",
  406.                 JMXUtils.JMX_ATTRIBUTE_READABLE,!JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);
  407.         MBeanAttributeInfo componentePD_disabilitazioni_VAR 
  408.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_PD_DISABILITAZIONI,String.class.getName(),
  409.                 "Filtri puntuali che disabilitano l'utilizzo del servizio PortaDelegata",
  410.                 JMXUtils.JMX_ATTRIBUTE_READABLE,!JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);

  412.         MBeanAttributeInfo componentePA_VAR 
  413.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_PA,String.class.getName(),
  414.                 "Indicazione se e' il servizio PortaApplicativa risulta abilitato",
  415.                 JMXUtils.JMX_ATTRIBUTE_READABLE,JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);
  416.         MBeanAttributeInfo componentePA_abilitazioni_VAR 
  417.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_PA_ABILITAZIONI,String.class.getName(),
  418.                 "Filtri puntuali che abilitano l'utilizzo del servizio PortaApplicativa",
  419.                 JMXUtils.JMX_ATTRIBUTE_READABLE,!JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);
  420.         MBeanAttributeInfo componentePA_disabilitazioni_VAR 
  421.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_PA_DISABILITAZIONI,String.class.getName(),
  422.                 "Filtri puntuali che disabilitano l'utilizzo del servizio PortaApplicativa",
  423.                 JMXUtils.JMX_ATTRIBUTE_READABLE,!JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);

  425.         MBeanAttributeInfo componenteIM_VAR 
  426.         = new MBeanAttributeInfo(StatoServiziJMXResource.COMPONENTE_IM,String.class.getName(),
  427.                 "Indicazione se e' il servizio IntegrationManager risulta abilitato",
  428.                 JMXUtils.JMX_ATTRIBUTE_READABLE,JMXUtils.JMX_ATTRIBUTE_WRITABLE,!JMXUtils.JMX_ATTRIBUTE_IS_GETTER);


  431.         // MetaData per le operazioni
  432.         MBeanOperationInfo abilitaPD_OP 
  433.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_COMPONENTE_PD,"Abilita il servizio PortaDelegata",
  434.                 null,
  435.                 String.class.getName(),
  436.                 MBeanOperationInfo.ACTION);
  437.         MBeanOperationInfo abilitaPA_OP 
  438.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_COMPONENTE_PA,"Abilita il servizio PortaApplicativa",
  439.                 null,
  440.                 String.class.getName(),
  441.                 MBeanOperationInfo.ACTION);
  442.         MBeanOperationInfo abilitaIM_OP 
  443.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_COMPONENTE_IM,"Abilita il servizio IntegrationManager",
  444.                 null,
  445.                 String.class.getName(),
  446.                 MBeanOperationInfo.ACTION);
  447.         MBeanOperationInfo abilitazioneCompleta_OP 
  448.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_SERVIZI,"Abilitazione completa di tutti i servizi",
  449.                 null,
  450.                 String.class.getName(),
  451.                 MBeanOperationInfo.ACTION);

  453.         MBeanOperationInfo disabilitaPD_OP 
  454.         = new MBeanOperationInfo(StatoServiziJMXResource.DISABILITA_COMPONENTE_PD,"Disabilita il servizio PortaDelegata",
  455.                 null,
  456.                 String.class.getName(),
  457.                 MBeanOperationInfo.ACTION);
  458.         MBeanOperationInfo disabilitaPA_OP 
  459.         = new MBeanOperationInfo(StatoServiziJMXResource.DISABILITA_COMPONENTE_PA,"Disabilita il servizio PortaApplicativa",
  460.                 null,
  461.                 String.class.getName(),
  462.                 MBeanOperationInfo.ACTION);
  463.         MBeanOperationInfo disabilitaIM_OP 
  464.         = new MBeanOperationInfo(StatoServiziJMXResource.DISABILITA_COMPONENTE_IM,"Disabilita il servizio IntegrationManager",
  465.                 null,
  466.                 String.class.getName(),
  467.                 MBeanOperationInfo.ACTION);
  468.         MBeanOperationInfo disabilitazioneCompleta_OP 
  469.         = new MBeanOperationInfo(StatoServiziJMXResource.DISABILITA_SERVIZI,"Disabilitazione completa di tutti i servizi",
  470.                 null,
  471.                 String.class.getName(),
  472.                 MBeanOperationInfo.ACTION);

  474.         MBeanOperationInfo componentePD_addFiltroAbilitazione_VAR 
  475.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_ADD_FILTRO_ABILITAZIONE_PD,"Aggiunge un filtro puntuale che abilita l'utilizzo del servizio PortaDelegata",
  476.                 getMBeanParameterInfoFiltroAbilitazioni(),
  477.                 String.class.getName(),
  478.                 MBeanOperationInfo.ACTION);     
  479.         MBeanOperationInfo componentePD_addFiltroDisabilitazione_VAR 
  480.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_ADD_FILTRO_DISABILITAZIONE_PD,"Aggiunge un filtro puntuale che disabilita l'utilizzo del servizio PortaDelegata",
  481.                 getMBeanParameterInfoFiltroAbilitazioni(),
  482.                 String.class.getName(),
  483.                 MBeanOperationInfo.ACTION); 
  484.         MBeanOperationInfo componentePD_removeFiltroAbilitazione_VAR 
  485.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_ABILITAZIONE_PD,"Rimuove un filtro puntuale che abilita l'utilizzo del servizio PortaDelegata",
  486.                 getMBeanParameterInfoFiltroAbilitazioni(),
  487.                 String.class.getName(),
  488.                 MBeanOperationInfo.ACTION);     
  489.         MBeanOperationInfo componentePD_removeFiltroDisabilitazione_VAR 
  490.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PD,"Rimuove un filtro puntuale che disabilita l'utilizzo del servizio PortaDelegata",
  491.                 getMBeanParameterInfoFiltroAbilitazioni(),
  492.                 String.class.getName(),
  493.                 MBeanOperationInfo.ACTION); 

  495.         MBeanOperationInfo componentePA_addFiltroAbilitazione_VAR 
  496.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_ADD_FILTRO_ABILITAZIONE_PA,"Aggiunge un filtro puntuale che abilita l'utilizzo del servizio PortaApplicativa",
  497.                 getMBeanParameterInfoFiltroAbilitazioni(),
  498.                 String.class.getName(),
  499.                 MBeanOperationInfo.ACTION);     
  500.         MBeanOperationInfo componentePA_addFiltroDisabilitazione_VAR 
  501.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_ADD_FILTRO_DISABILITAZIONE_PA,"Aggiunge un filtro puntuale che disabilita l'utilizzo del servizio PortaApplicativa",
  502.                 getMBeanParameterInfoFiltroAbilitazioni(),
  503.                 String.class.getName(),
  504.                 MBeanOperationInfo.ACTION); 
  505.         MBeanOperationInfo componentePA_removeFiltroAbilitazione_VAR 
  506.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_ABILITAZIONE_PA,"Rimuove un filtro puntuale che abilita l'utilizzo del servizio PortaApplicativa",
  507.                 getMBeanParameterInfoFiltroAbilitazioni(),
  508.                 String.class.getName(),
  509.                 MBeanOperationInfo.ACTION);     
  510.         MBeanOperationInfo componentePA_removeFiltroDisabilitazione_VAR 
  511.         = new MBeanOperationInfo(StatoServiziJMXResource.ABILITA_REMOVE_FILTRO_DISABILITAZIONE_PA,"Rimuove un filtro puntuale che disabilita l'utilizzo del servizio PortaApplicativa",
  512.                 getMBeanParameterInfoFiltroAbilitazioni(),
  513.                 String.class.getName(),
  514.                 MBeanOperationInfo.ACTION); 


  517.         // Mbean costruttore
  518.         MBeanConstructorInfo defaultConstructor = new MBeanConstructorInfo("Default Constructor","Crea e inizializza una nuova istanza del MBean",null);

  520.         // Lista attributi
  521.         MBeanAttributeInfo[] attributes = new MBeanAttributeInfo[]{componentePD_VAR,componentePD_abilitazioni_VAR,componentePD_disabilitazioni_VAR,
  522.                 componentePA_VAR,componentePA_abilitazioni_VAR,componentePA_disabilitazioni_VAR,
  523.                 componenteIM_VAR};

  525.         // Lista Costruttori
  526.         MBeanConstructorInfo[] constructors = new MBeanConstructorInfo[]{defaultConstructor};

  528.         // Lista operazioni
  529.         MBeanOperationInfo[] operations = new MBeanOperationInfo[]{abilitaPD_OP,abilitaPA_OP,abilitaIM_OP,abilitazioneCompleta_OP,
  530.                 disabilitaPD_OP,disabilitaPA_OP,disabilitaIM_OP,disabilitazioneCompleta_OP,
  531.                 componentePD_addFiltroAbilitazione_VAR,componentePD_addFiltroDisabilitazione_VAR,
  532.                 componentePD_removeFiltroAbilitazione_VAR,componentePD_removeFiltroDisabilitazione_VAR,
  533.                 componentePA_addFiltroAbilitazione_VAR,componentePA_addFiltroDisabilitazione_VAR,
  534.                 componentePA_removeFiltroAbilitazione_VAR,componentePA_removeFiltroDisabilitazione_VAR};

  536.         return new MBeanInfo(className,description,attributes,constructors,operations,null);
  537.     }


  540.     private MBeanParameterInfo[] getMBeanParameterInfoFiltroAbilitazioni(){
  541.         MBeanParameterInfo[] m = new MBeanParameterInfo[]{

  543.                 new MBeanParameterInfo("tipoSoggettoFruitore",String.class.getName(),"Tipo del soggetto fruitore"),
  544.                 new MBeanParameterInfo("nomeSoggettoFruitore",String.class.getName(),"Nome del soggetto fruitore"),
  545.                 new MBeanParameterInfo("identificativoPortaSoggettoFruitore",String.class.getName(),"Identificativo della PdD del soggetto fruitore"),

  547.                 new MBeanParameterInfo("tipoSoggettoErogatore",String.class.getName(),"Tipo del soggetto erogatore"),
  548.                 new MBeanParameterInfo("nomeSoggettoErogatore",String.class.getName(),"Nome del soggetto erogatore"),
  549.                 new MBeanParameterInfo("identificativoPortaSoggettoErogatore",String.class.getName(),"Identificativo della PdD del soggetto erogatore"),

  551.                 new MBeanParameterInfo("tipoServizio",String.class.getName(),"Tipo del servizio"),
  552.                 new MBeanParameterInfo("nomeServizio",String.class.getName(),"Nome del servizio"),
  553.                 new MBeanParameterInfo("versioneServizio",Integer.class.getName(),"Versione del servizio"),

  555.                 new MBeanParameterInfo("azione",String.class.getName(),"azione")
  556.         };
  557.         return m;
  558.     }


  561.     /* Costruttore */
  562.     public StatoServiziJMXResource() {

  564.         
  565.     }

  567.     /* Metodi di management JMX */

  569.     public String abilitaServizioPortaDelegata(){
  570.         if(CostantiConfigurazione.ABILITATO.equals(this.getComponentePD())){
  571.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" il servizio PortaDelegata risulta già abilitato";
  572.         }else{
  573.             try{
  574.                 StatoServiziPdD.setPDServiceActive(true);
  575.                 return "Abilitazione del servizio PortaDelegata effettuata con successo";
  576.             }catch(Throwable e){
  577.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Abilitazione del servizio PortaDelegata non riuscita: "+e.getMessage(),e);
  578.                 return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  579.             }
  580.         }
  581.     }
  582.     public String abilitaServizioPortaApplicativa(){
  583.         if(CostantiConfigurazione.ABILITATO.equals(this.getComponentePA())){
  584.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" il servizio PortaApplicativa risulta già abilitato";
  585.         }else{
  586.             try{
  587.                 StatoServiziPdD.setPAServiceActive(true);
  588.                 return "Abilitazione del servizio PortaApplicativa effettuata con successo";
  589.             }catch(Throwable e){
  590.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Abilitazione del servizio PortaApplicativa non riuscita: "+e.getMessage(),e);
  591.                 return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  592.             }
  593.         }
  594.     }
  595.     public String abilitaServizioIntegrationManager(){
  596.         if(CostantiConfigurazione.ABILITATO.equals(this.getComponenteIM())){
  597.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" il servizio IntegrationManager risulta già abilitato";
  598.         }else{
  599.             try{
  600.                 StatoServiziPdD.setIMServiceActive(true);
  601.                 return "Abilitazione del servizio IntegrationManager effettuata con successo";
  602.             }catch(Throwable e){
  603.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Abilitazione del servizio IntegrationManager non riuscita: "+e.getMessage(),e);
  604.                 return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  605.             }
  606.         }
  607.     }
  608.     public String abilitazioneCompletaServizi(){
  609.         StringBuilder bf = new StringBuilder(); 
  610.         bf.append(this.abilitaServizioPortaDelegata()); 
  611.         bf.append("; ");
  612.         bf.append(this.abilitaServizioPortaApplicativa());  
  613.         bf.append("; ");
  614.         bf.append(this.abilitaServizioIntegrationManager());    
  615.         return bf.toString();
  616.     }




  621.     public String disabilitaServizioPortaDelegata(){
  622.         if(CostantiConfigurazione.DISABILITATO.equals(this.getComponentePD())){
  623.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" il servizio PortaDelegata risulta già disabilitato";
  624.         }else{
  625.             try{
  626.                 StatoServiziPdD.setPDServiceActive(false);
  627.                 return "Disabilitazione del servizio PortaDelegata effettuata con successo";
  628.             }catch(Throwable e){
  629.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Disabilitazione del servizio PortaDelegata non riuscita: "+e.getMessage(),e);
  630.                 return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  631.             }
  632.         }
  633.     }
  634.     public String disabilitaServizioPortaApplicativa(){
  635.         if(CostantiConfigurazione.DISABILITATO.equals(this.getComponentePA())){
  636.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" il servizio PortaApplicativa risulta già disabilitato";
  637.         }else{
  638.             try{
  639.                 StatoServiziPdD.setPAServiceActive(false);
  640.                 return "Disabilitazione del servizio PortaApplicativa effettuata con successo";
  641.             }catch(Throwable e){
  642.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Disabilitazione del servizio PortaApplicativa non riuscita: "+e.getMessage(),e);
  643.                 return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  644.             }
  645.         }
  646.     }
  647.     public String disabilitaServizioIntegrationManager(){
  648.         if(CostantiConfigurazione.DISABILITATO.equals(this.getComponenteIM())){
  649.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" il servizio IntegrationManager risulta già disabilitato";
  650.         }else{
  651.             try{
  652.                 StatoServiziPdD.setIMServiceActive(false);
  653.                 return "Disabilitazione del servizio IntegrationManager effettuata con successo";
  654.             }catch(Throwable e){
  655.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Disabilitazione del servizio IntegrationManager non riuscita: "+e.getMessage(),e);
  656.                 return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  657.             }
  658.         }
  659.     }
  660.     public String disabilitazioneCompletaServizi(){
  661.         StringBuilder bf = new StringBuilder(); 
  662.         bf.append(this.disabilitaServizioPortaDelegata());  
  663.         bf.append("; ");
  664.         bf.append(this.disabilitaServizioPortaApplicativa());   
  665.         bf.append("; ");
  666.         bf.append(this.disabilitaServizioIntegrationManager()); 
  667.         return bf.toString();
  668.     }





  674.     public String visualizzaFiltriAbilitazioniServizioPortaDelegata(){
  675.         try{
  676.             return StatoServiziPdD.getPDServiceFiltriAbilitazioneAttivi();
  677.         }catch(Throwable e){
  678.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione visualizzaFiltriAbilitazioniServizioPortaDelegata non riuscita: "+e.getMessage(),e);
  679.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  680.         }
  681.     }
  682.     public String visualizzaFiltriDisabilitazioniServizioPortaDelegata(){
  683.         try{
  684.             return StatoServiziPdD.getPDServiceFiltriDisabilitazioneAttivi();
  685.         }catch(Throwable e){
  686.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione visualizzaFiltriDisabilitazioniServizioPortaDelegata non riuscita: "+e.getMessage(),e);
  687.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  688.         }
  689.     }
  690.     public String addFiltroAbilitazioneServizioPortaDelegata(TipoFiltroAbilitazioneServizi tipo){
  691.         try{
  692.             StatoServiziPdD.addFiltroAbilitazionePD(tipo);
  693.             return "Operazione effettuata con successo";
  694.         }catch(Throwable e){
  695.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione addFiltroAbilitazioneServizioPortaDelegata non riuscita: "+e.getMessage(),e);
  696.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  697.         }
  698.     }
  699.     public String addFiltroDisabilitazioneServizioPortaDelegata(TipoFiltroAbilitazioneServizi tipo){
  700.         try{
  701.             StatoServiziPdD.addFiltroDisabilitazionePD(tipo);
  702.             return "Operazione effettuata con successo";
  703.         }catch(Throwable e){
  704.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione addFiltroDisabilitazioneServizioPortaDelegata non riuscita: "+e.getMessage(),e);
  705.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  706.         }
  707.     }
  708.     public String removeFiltroAbilitazioneServizioPortaDelegata(TipoFiltroAbilitazioneServizi tipo){
  709.         try{
  710.             StatoServiziPdD.removeFiltroAbilitazionePD(tipo);
  711.             return "Operazione effettuata con successo";
  712.         }catch(Throwable e){
  713.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione removeFiltroAbilitazioneServizioPortaDelegata non riuscita: "+e.getMessage(),e);
  714.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  715.         }
  716.     }
  717.     public String removeFiltroDisabilitazioneServizioPortaDelegata(TipoFiltroAbilitazioneServizi tipo){
  718.         try{
  719.             StatoServiziPdD.removeFiltroDisabilitazionePD(tipo);
  720.             return "Operazione effettuata con successo";
  721.         }catch(Throwable e){
  722.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione removeFiltroDisabilitazioneServizioPortaDelegata non riuscita: "+e.getMessage(),e);
  723.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  724.         }
  725.     }

  727.     public String visualizzaFiltriAbilitazioniServizioPortaApplicativa(){
  728.         try{
  729.             return StatoServiziPdD.getPAServiceFiltriAbilitazioneAttivi();
  730.         }catch(Throwable e){
  731.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione visualizzaFiltriAbilitazioniServizioPortaApplicativa non riuscita: "+e.getMessage(),e);
  732.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  733.         }
  734.     }
  735.     public String visualizzaFiltriDisabilitazioniServizioPortaApplicativa(){
  736.         try{
  737.             return StatoServiziPdD.getPAServiceFiltriDisabilitazioneAttivi();
  738.         }catch(Throwable e){
  739.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione visualizzaFiltriDisabilitazioniServizioPortaApplicativa non riuscita: "+e.getMessage(),e);
  740.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  741.         }
  742.     }
  743.     public String addFiltroAbilitazioneServizioPortaApplicativa(TipoFiltroAbilitazioneServizi tipo){
  744.         try{
  745.             StatoServiziPdD.addFiltroAbilitazionePA(tipo);
  746.             return "Operazione effettuata con successo";
  747.         }catch(Throwable e){
  748.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione addFiltroAbilitazioneServizioPortaApplicativa non riuscita: "+e.getMessage(),e);
  749.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  750.         }
  751.     }
  752.     public String addFiltroDisabilitazioneServizioPortaApplicativa(TipoFiltroAbilitazioneServizi tipo){
  753.         try{
  754.             StatoServiziPdD.addFiltroDisabilitazionePA(tipo);
  755.             return "Operazione effettuata con successo";
  756.         }catch(Throwable e){
  757.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione addFiltroDisabilitazioneServizioPortaApplicativa non riuscita: "+e.getMessage(),e);
  758.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  759.         }
  760.     }
  761.     public String removeFiltroAbilitazioneServizioPortaApplicativa(TipoFiltroAbilitazioneServizi tipo){
  762.         try{
  763.             StatoServiziPdD.removeFiltroAbilitazionePA(tipo);
  764.             return "Operazione effettuata con successo";
  765.         }catch(Throwable e){
  766.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione removeFiltroAbilitazioneServizioPortaApplicativa non riuscita: "+e.getMessage(),e);
  767.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  768.         }
  769.     }
  770.     public String removeFiltroDisabilitazioneServizioPortaApplicativa(TipoFiltroAbilitazioneServizi tipo){
  771.         try{
  772.             StatoServiziPdD.removeFiltroDisabilitazionePA(tipo);
  773.             return "Operazione effettuata con successo";
  774.         }catch(Throwable e){
  775.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().error("Operazione removeFiltroDisabilitazioneServizioPortaApplicativa non riuscita: "+e.getMessage(),e);
  776.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+" sistema non disponibile";
  777.         }
  778.     }
  779. }
Created with JaCoCo 0.8.8.202204050719