MonitoraggioRisorse.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;

  24. import java.util.ArrayList;
  25. import java.util.Iterator;
  26. import java.util.List;
  27. import java.util.Map;

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

  44. import org.openspcoop2.pdd.config.DBConsegneMessageBoxManager;
  45. import org.openspcoop2.pdd.config.DBConsegnePreseInCaricoManager;
  46. import org.openspcoop2.pdd.config.DBManager;
  47. import org.openspcoop2.pdd.config.DBStatisticheManager;
  48. import org.openspcoop2.pdd.config.DBTransazioniManager;
  49. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  50. import org.openspcoop2.pdd.config.QueueManager;
  51. import org.openspcoop2.pdd.core.connettori.IConnettore;
  52. import org.openspcoop2.pdd.core.connettori.RepositoryConnettori;
  53. import org.openspcoop2.pdd.core.transazioni.Transaction;
  54. import org.openspcoop2.pdd.core.transazioni.TransactionContext;
  55. import org.openspcoop2.pdd.core.transazioni.TransactionNotExistsException;
  56. import org.openspcoop2.pdd.logger.Dump;
  57. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  58. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  59. import org.openspcoop2.pdd.logger.Tracciamento;
  60. import org.openspcoop2.pdd.monitor.StatoPdd;
  61. import org.openspcoop2.pdd.monitor.driver.DriverMonitoraggio;
  62. import org.openspcoop2.pdd.monitor.driver.FilterSearch;
  63. import org.openspcoop2.pdd.timers.TimerMonitoraggioRisorseThread;
  64. import org.openspcoop2.pdd.timers.TimerThresholdThread;
  65. import org.openspcoop2.utils.Utilities;
  66. import org.openspcoop2.utils.cache.Cache;
  67. import org.openspcoop2.utils.date.DateManager;
  68. import org.slf4j.Logger;




  73. /**
  74.  * Implementazione JMX per la gestione delle risorse
  75.  *   
  76.  * @author Poli Andrea (apoli@link.it)
  77.  * @author $Author$
  78.  * @version $Rev$, $Date$
  79.  */
  80. public class MonitoraggioRisorse extends NotificationBroadcasterSupport implements DynamicMBean {

  82.     /** Nomi attributi */
  83.     public static final String NUMERO_MSG_IN_CONSEGNA = "numMsgInConsegna";
  84.     public static final String TEMPO_MEDIO_ATTESA_IN_CONSEGNA = "tempoMedioAttesaInConsegna";
  85.     public static final String TEMPO_MAX_ATTESA_IN_CONSEGNA = "tempoMaxAttesaInConsegna";
  86.     public static final String NUMERO_MSG_IN_SPEDIZIONE = "numMsgInSpedizione";
  87.     public static final String TEMPO_MEDIO_ATTESA_IN_SPEDIZIONE = "tempoMedioAttesaInSpedizione";
  88.     public static final String TEMPO_MAX_ATTESA_IN_SPEDIZIONE = "tempoMaxAttesaInSpedizione";
  89.     public static final String NUMERO_MSG_IN_PROCESSAMENTO = "numMsgInProcessamento";
  90.     public static final String TEMPO_MEDIO_ATTESA_IN_PROCESSAMENTO = "tempoMedioAttesaInProcessamento";
  91.     public static final String TEMPO_MAX_ATTESA_IN_PROCESSAMENTO = "tempoMaxAttesaInProcessamento";
  92.     public static final String NUMERO_MSG_TOTALI = "totMessaggi";
  93.     public static final String TEMPO_MEDIO_ATTESA_MSG_TOTALI = "tempoMedioAttesa";
  94.     public static final String TEMPO_MAX_ATTESA_MSG_TOTALI = "tempoMaxAttesa";
  95.     public static final String TOT_MSG_DUPLICATI = "totMessaggiDuplicati";
  96.     public static final String STATO_DATI_MONITORAGGIO = "statoDatiMonitoraggioPdD";
  97.     public static final String RISORSE_DI_SISTEMA = "risorseDiSistema";
  98.     
  99.     /** Nomi metodi */
  100.     public static final String GET_STATO_RISORSE_DI_SISTEMA = "getStatoRisorseSistema";
  101.     public static final String GET_STATO_RISORSE_DI_SISTEMA_METHOD2 = "listStatoRisorseSistema"; // per farlo comparire in jmx-console
  102.     public static final String GET_STATO_CACHES = "getStatoCache";
  103.     public static final String GET_STATO_CACHES_METHOD2 = "listStatoCache"; // per farlo comparire in jmx-console
  104.     public static final String CONNESSIONI_ALLOCATE_DB_MANAGER = "getUsedDBConnections";
  105.     public static final String CONNESSIONI_ALLOCATE_DB_MANAGER_METHOD2 = "listUsedDBConnections"; // per farlo comparire in jmx-console
  106.     public static final String CONNESSIONI_ALLOCATE_QUEUE_MANAGER = "getUsedQueueConnections";
  107.     public static final String CONNESSIONI_ALLOCATE_QUEUE_MANAGER_METHOD2 = "listUsedQueueConnections"; // per farlo comparire in jmx-console
  108.     public static final String TRANSAZIONI_ATTIVE_ID = "getActiveTransactions";
  109.     public static final String TRANSAZIONI_ATTIVE_ID_METHOD2 = "listActiveTransactions"; // per farlo comparire in jmx-console
  110.     public static final String TRANSAZIONI_ATTIVE_ID_PROTOCOLLO = "getActiveProtocolIds";
  111.     public static final String TRANSAZIONI_ATTIVE_ID_PROTOCOLLO_METHOD2 = "listActiveProtocolIds"; // per farlo comparire in jmx-console
  112.     public static final String GET_DETTAGLIO_TRANSAZIONE_ATTIVA = "getActiveTransactionDetails";
  113.     public static final String CONNESSIONI_ALLOCATE_CONNETTORI_PD = "getActivePDConnections";
  114.     public static final String CONNESSIONI_ALLOCATE_CONNETTORI_PD_METHOD2 = "listActivePDConnections"; // per farlo comparire in jmx-console
  115.     public static final String CONNESSIONI_ALLOCATE_CONNETTORI_PA = "getActivePAConnections";
  116.     public static final String CONNESSIONI_ALLOCATE_CONNETTORI_PA_METHOD2 = "listActivePAConnections"; // per farlo comparire in jmx-console
  117.     
  118.     
  119.     
  120.     /** Attributi */
  121.     // Messaggi in consegna
  122.     private long numMsgInConsegna = 0;
  123.     // Secondi
  124.     private String tempoMedioAttesaInConsegna = "";
  125.     private String tempoMaxAttesaInConsegna = "";  
  126.     //  Messaggi in spedizione
  127.     private long numMsgInSpedizione = 0;
  128.     //  Secondi
  129.     private String tempoMedioAttesaInSpedizione = "";
  130.     private String tempoMaxAttesaInSpedizione = ""; 
  131.     //  Messaggi in processamento
  132.     private long numMsgInProcessamento=0;
  133.     //  Secondi
  134.     private String tempoMedioAttesaInProcessamento = "";
  135.     private String tempoMaxAttesaInProcessamento = "";
  136.     // Messaggi totali
  137.     private long totMessaggi=0;
  138.     // Secondi
  139.     private String tempoMedioAttesa = "";
  140.     private String tempoMaxAttesa = "";
  141.     // Messaggi duplicati
  142.     private long totMessaggiDuplicati=0;
  143.     
  144.     //  Risorse di sistema non disponibili o disponibili ad un livello critico
  145.     private String risorseDiSistema ="Lettura dati non effettuata         ";
  146.     
  147.     // Stato dati MonitoraggioPdD
  148.     private String datiMonitoraggioPdD = "Non disponibili";
  149.     
  150.     /** getAttribute */
  151.     @Override
  152.     public Object getAttribute(String attributeName) throws AttributeNotFoundException,MBeanException,ReflectionException{
  153.         
  154.         if( (attributeName==null) || (attributeName.equals("")) )
  155.             throw new IllegalArgumentException("Il nome dell'attributo e' nullo o vuoto");
  156.         
  157.         if(attributeName.equals(MonitoraggioRisorse.NUMERO_MSG_IN_CONSEGNA))
  158.             return this.numMsgInConsegna;
  159.         
  160.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_CONSEGNA))
  161.             return this.tempoMedioAttesaInConsegna;
  162.         
  163.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_CONSEGNA))
  164.             return this.tempoMaxAttesaInConsegna;
  165.         
  166.         if(attributeName.equals(MonitoraggioRisorse.NUMERO_MSG_IN_SPEDIZIONE))
  167.             return this.numMsgInSpedizione;
  168.         
  169.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_SPEDIZIONE))
  170.             return this.tempoMedioAttesaInSpedizione;
  171.         
  172.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_SPEDIZIONE))
  173.             return this.tempoMaxAttesaInSpedizione;
  174.         
  175.         if(attributeName.equals(MonitoraggioRisorse.NUMERO_MSG_IN_PROCESSAMENTO))
  176.             return this.numMsgInProcessamento;
  177.         
  178.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_PROCESSAMENTO))
  179.             return this.tempoMedioAttesaInProcessamento;
  180.         
  181.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_PROCESSAMENTO))
  182.             return this.tempoMaxAttesaInProcessamento;
  183.         
  184.         if(attributeName.equals(MonitoraggioRisorse.NUMERO_MSG_TOTALI))
  185.             return this.totMessaggi;
  186.         
  187.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_MSG_TOTALI))
  188.             return this.tempoMedioAttesa;
  189.         
  190.         if(attributeName.equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_MSG_TOTALI))
  191.             return this.tempoMaxAttesa;
  192.         
  193.         if(attributeName.equals(MonitoraggioRisorse.TOT_MSG_DUPLICATI))
  194.             return this.totMessaggiDuplicati;
  195.         
  196.         if(attributeName.equals(MonitoraggioRisorse.RISORSE_DI_SISTEMA))
  197.             return this.risorseDiSistema;
  198.         
  199.         if(attributeName.equals(MonitoraggioRisorse.STATO_DATI_MONITORAGGIO))
  200.             return this.datiMonitoraggioPdD;
  201.         
  202.         throw new AttributeNotFoundException("Attributo "+attributeName+" non trovato");
  203.     }
  204.     
  205.     /** getAttributes */
  206.     @Override
  207.     public AttributeList getAttributes(String [] attributesNames){
  208.         
  209.         if(attributesNames==null)
  210.             throw new IllegalArgumentException("Array nullo");
  211.         
  212.         AttributeList list = new AttributeList();
  213.         for (int i=0; i<attributesNames.length; i++){
  214.             try{
  215.                 list.add(new Attribute(attributesNames[i],getAttribute(attributesNames[i])));
  216.             }catch(JMException ex){}
  217.         }
  218.         return list;
  219.     }
  220.     
  221.     /** setAttribute */
  222.     @Override
  223.     public void setAttribute(Attribute attribute) throws AttributeNotFoundException, InvalidAttributeValueException, MBeanException, ReflectionException{
  224.         
  225.         if( attribute==null )
  226.             throw new IllegalArgumentException("Il nome dell'attributo e' nullo");
  227.         
  228.         try{
  229.             
  230.             if(attribute.getName().equals(MonitoraggioRisorse.NUMERO_MSG_IN_CONSEGNA))
  231.                 this.numMsgInConsegna = (Long) attribute.getValue();
  232.             
  233.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_CONSEGNA))
  234.                 this.tempoMedioAttesaInConsegna = (String) attribute.getValue();
  235.             
  236.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_CONSEGNA))
  237.                 this.tempoMaxAttesaInConsegna = (String) attribute.getValue();
  238.             
  239.             else if(attribute.getName().equals(MonitoraggioRisorse.NUMERO_MSG_IN_SPEDIZIONE))
  240.                 this.numMsgInSpedizione = (Long) attribute.getValue();
  241.             
  242.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_SPEDIZIONE))
  243.                 this.tempoMedioAttesaInSpedizione = (String) attribute.getValue();
  244.             
  245.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_SPEDIZIONE))
  246.                 this.tempoMaxAttesaInSpedizione = (String) attribute.getValue();
  247.             
  248.             else if(attribute.getName().equals(MonitoraggioRisorse.NUMERO_MSG_IN_PROCESSAMENTO))
  249.                 this.numMsgInProcessamento = (Long) attribute.getValue();
  250.             
  251.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_PROCESSAMENTO))
  252.                 this.tempoMedioAttesaInProcessamento = (String) attribute.getValue();
  253.             
  254.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_PROCESSAMENTO))
  255.                 this.tempoMaxAttesaInProcessamento = (String) attribute.getValue();
  256.             
  257.             else if(attribute.getName().equals(MonitoraggioRisorse.NUMERO_MSG_TOTALI))
  258.                 this.totMessaggi = (Long) attribute.getValue();
  259.             
  260.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_MSG_TOTALI))
  261.                 this.tempoMedioAttesa = (String) attribute.getValue();
  262.             
  263.             else if(attribute.getName().equals(MonitoraggioRisorse.TEMPO_MAX_ATTESA_MSG_TOTALI))
  264.                 this.tempoMaxAttesa = (String) attribute.getValue();
  265.             
  266.             else if(attribute.getName().equals(MonitoraggioRisorse.TOT_MSG_DUPLICATI))
  267.                 this.totMessaggiDuplicati = (Long) attribute.getValue();
  268.             
  269.             else if(attribute.getName().equals(MonitoraggioRisorse.RISORSE_DI_SISTEMA))
  270.                 this.risorseDiSistema = (String) attribute.getValue();
  271.             
  272.             else if(attribute.getName().equals(MonitoraggioRisorse.STATO_DATI_MONITORAGGIO))
  273.                 this.refreshDatiMonitoraggioPdD();
  274.             
  275.             else
  276.                 throw new AttributeNotFoundException("Attributo "+attribute.getName()+" non trovato");
  277.             
  278.         }catch(ClassCastException ce){
  279.             throw new InvalidAttributeValueException("il tipo "+attribute.getValue().getClass()+" dell'attributo "+attribute.getName()+" non e' valido");
  280.         }catch(JMException j){
  281.             throw new MBeanException(j);
  282.         }
  283.         
  284.     }
  285.     
  286.     /** setAttributes */
  287.     @Override
  288.     public AttributeList setAttributes(AttributeList list){
  289.         
  290.         if(list==null)
  291.             throw new IllegalArgumentException("Lista degli attributi e' nulla");
  292.         
  293.         AttributeList ret = new AttributeList();
  294.         Iterator<?> it = ret.iterator();
  295.         
  296.         while(it.hasNext()){
  297.             try{
  298.                 Attribute attribute = (Attribute) it.next();
  299.                 setAttribute(attribute);
  300.                 ret.add(attribute);
  301.             }catch(JMException ex){}
  302.         }
  303.         
  304.         return ret;
  305.         
  306.     }
  307.     
  308.     /** invoke */
  309.     @Override
  310.     public Object invoke(String actionName, Object[]params, String[]signature) throws MBeanException,ReflectionException{
  311.         
  312.         if( (actionName==null) || (actionName.equals("")) )
  313.             throw new IllegalArgumentException("Nessuna operazione definita");
  314.         
  315.         if(actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_DB_MANAGER) || actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_DB_MANAGER_METHOD2)){
  316.             return this.getUsedDBConnections();
  317.         }
  318.         
  319.         else if(actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_QUEUE_MANAGER) || actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_QUEUE_MANAGER_METHOD2)){
  320.             return this.getUsedQueueConnections();
  321.         }
  322.         
  323.         else if(actionName.equals(MonitoraggioRisorse.TRANSAZIONI_ATTIVE_ID) || actionName.equals(MonitoraggioRisorse.TRANSAZIONI_ATTIVE_ID_METHOD2)){
  324.             return this.getTransazioniAttiveId();
  325.         }
  326.         
  327.         else if(actionName.equals(MonitoraggioRisorse.GET_DETTAGLIO_TRANSAZIONE_ATTIVA)){
  328.             
  329.             if(params.length != 1)
  330.                 throw new MBeanException(new Exception("["+MonitoraggioRisorse.GET_DETTAGLIO_TRANSAZIONE_ATTIVA+"] Lunghezza parametri non corretta: "+params.length));
  331.             
  332.             String param1 = null;
  333.             if(params[0]!=null && !"".equals(params[0])){
  334.                 param1 = (String)params[0];
  335.             }
  336.             
  337.             return this.getDettaglioTransazioneAttivaId(param1);
  338.         }
  339.         
  340.         else if(actionName.equals(MonitoraggioRisorse.TRANSAZIONI_ATTIVE_ID_PROTOCOLLO) || actionName.equals(MonitoraggioRisorse.TRANSAZIONI_ATTIVE_ID_PROTOCOLLO_METHOD2)){
  341.             return this.getTransazioniAttiveIdProtocollo();
  342.         }
  343.         
  344.         else if(actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PD) || actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PD_METHOD2)){
  345.             return this.getActivePDConnections();
  346.         }
  347.         
  348.         else if(actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PA) || actionName.equals(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PA_METHOD2)){
  349.             return this.getActivePAConnections();
  350.         }
  351.         
  352.         else if(actionName.equals(MonitoraggioRisorse.GET_STATO_RISORSE_DI_SISTEMA) || actionName.equals(MonitoraggioRisorse.GET_STATO_RISORSE_DI_SISTEMA_METHOD2)){
  353.             this.refreshDatiMonitoraggioPdD();
  354.             return this.risorseDiSistema;
  355.         }
  356.         
  357.         else if(actionName.equals(MonitoraggioRisorse.GET_STATO_CACHES) || actionName.equals(MonitoraggioRisorse.GET_STATO_CACHES_METHOD2)){
  358.             return this.getStatoCaches();
  359.         }
  360.         
  361.         throw new UnsupportedOperationException("Operazione "+actionName+" sconosciuta");
  362.     }
  363.     
  364.     /* MBean info */
  365.     @Override
  366.     public MBeanInfo getMBeanInfo(){
  367.         
  368.         /*
  369.         if(OpenSPCoopStartup.initialize){
  370.             this.refresh();
  371.         }
  372.         */
  373.         
  374.         // Per determinare se l'attributo e' leggibile/scrivibile
  375.         final boolean READABLE = true;
  376.         final boolean WRITABLE = true;
  377.         
  378.         // Per determinare se l'attributo e' ricavabile nella forma booleana isAttribute()
  379.         final boolean IS_GETTER = true;
  380.         
  381.         // Descrizione della classe nel MBean
  382.         String className = this.getClass().getName();
  383.         String description = "Monitoraggio delle risorse utilizzate ("+OpenSPCoop2Properties.getInstance().getVersione()+"), premi pulsante (apply changes) per aggiornare i dati";

  385.         // MetaData per l'attributo numMsgInConsegna
  386.         MBeanAttributeInfo numMsgInConsegnaVAR 
  387.             = new MBeanAttributeInfo(MonitoraggioRisorse.NUMERO_MSG_IN_CONSEGNA,long.class.getName(),
  388.                         "Numero di Messaggi in gestione nel modulo 'ConsegnaContenutiApplicativi'",
  389.                             READABLE,!WRITABLE,!IS_GETTER);
  390.         
  391.         // MetaData per l'attributo tempoMedioAttesaInConsegna
  392.         MBeanAttributeInfo tempoMedioAttesaInConsegnaVAR 
  393.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_CONSEGNA,String.class.getName(),
  394.                         "Tempo medio di attesa dei Messaggi prima di essere stati consegnati ai servizi applicativi dal modulo 'ConsegnaContenutiApplicativi'",
  395.                             READABLE,!WRITABLE,!IS_GETTER);
  396.         
  397.         // MetaData per l'attributo tempoMaxAttesaInConsegna
  398.         MBeanAttributeInfo tempoMaxAttesaInConsegnaVAR 
  399.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_CONSEGNA,String.class.getName(),
  400.                         "Tempo massimo di attesa dei Messaggi prima di essere stati consegnati ai servizi applicativi dal modulo 'ConsegnaContenutiApplicativi'",
  401.                             READABLE,!WRITABLE,!IS_GETTER);
  402.         
  403.         // MetaData per l'attributo numMsgInSpedizione
  404.         MBeanAttributeInfo numMsgInSpedizioneVAR 
  405.             = new MBeanAttributeInfo(MonitoraggioRisorse.NUMERO_MSG_IN_SPEDIZIONE,long.class.getName(),
  406.                         "Numero di Messaggi in gestione nei moduli 'InoltroBuste'",
  407.                             READABLE,!WRITABLE,!IS_GETTER);
  408.         
  409.         // MetaData per l'attributo tempoMedioAttesaInSpedizione
  410.         MBeanAttributeInfo tempoMedioAttesaInSpedizioneVAR 
  411.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_SPEDIZIONE,String.class.getName(),
  412.                         "Tempo medio di attesa dei Messaggi prima di essere stati inoltrate alle porte di dominio destinatarie dai moduli 'InoltroBuste'",
  413.                             READABLE,!WRITABLE,!IS_GETTER);
  414.         
  415.         // MetaData per l'attributo tempoMaxAttesaInSpedizione
  416.         MBeanAttributeInfo tempoMaxAttesaInSpedizioneVAR 
  417.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_SPEDIZIONE,String.class.getName(),
  418.                         "Tempo massimo di attesa dei Messaggi prima di essere stati inoltrate alle porte di dominio destinatarie dai moduli 'InoltroBuste'",
  419.                             READABLE,!WRITABLE,!IS_GETTER);
  420.         
  421.         // MetaData per l'attributo numMsgInProcessamento
  422.         MBeanAttributeInfo numMsgInProcessamentoVAR 
  423.             = new MBeanAttributeInfo(MonitoraggioRisorse.NUMERO_MSG_IN_PROCESSAMENTO,long.class.getName(),
  424.                         "Numero di Messaggi in gestione nei moduli interni all'infrastruttura della porta di dominio",
  425.                             READABLE,!WRITABLE,!IS_GETTER);
  426.         
  427.         // MetaData per l'attributo tempoMedioAttesaInProcessamento
  428.         MBeanAttributeInfo tempoMedioAttesaInProcessamentoVAR 
  429.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_IN_PROCESSAMENTO,String.class.getName(),
  430.                         "Tempo medio di attesa in gestione nei moduli interni all'infrastruttura della porta di dominio",
  431.                             READABLE,!WRITABLE,!IS_GETTER);
  432.         
  433.         // MetaData per l'attributo tempoMaxAttesaInProcessamento
  434.         MBeanAttributeInfo tempoMaxAttesaInProcessamentoVAR 
  435.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MAX_ATTESA_IN_PROCESSAMENTO,String.class.getName(),
  436.                         "Tempo massimo di attesa in gestione nei moduli interni all'infrastruttura della porta di dominio",
  437.                             READABLE,!WRITABLE,!IS_GETTER);
  438.         
  439.         // MetaData per l'attributo totMessaggi
  440.         MBeanAttributeInfo totMessaggiVAR 
  441.             = new MBeanAttributeInfo(MonitoraggioRisorse.NUMERO_MSG_TOTALI,long.class.getName(),
  442.                         "Numero di Messaggi totali in gestione nella porta di dominio",
  443.                             READABLE,!WRITABLE,!IS_GETTER);
  444.         
  445.         // MetaData per l'attributo tempoMedioAttesa
  446.         MBeanAttributeInfo tempoMedioAttesaVAR 
  447.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MEDIO_ATTESA_MSG_TOTALI,String.class.getName(),
  448.                         "Tempo medio di attesa dei Messaggi gestiti nella porta di dominio",
  449.                             READABLE,!WRITABLE,!IS_GETTER);
  450.         
  451.         // MetaData per l'attributo tempoMaxAttesa
  452.         MBeanAttributeInfo tempoMaxAttesaVAR 
  453.             = new MBeanAttributeInfo(MonitoraggioRisorse.TEMPO_MAX_ATTESA_MSG_TOTALI,String.class.getName(),
  454.                         "Tempo massimo di attesa dei Messaggi gestiti nella porta di dominio",
  455.                             READABLE,!WRITABLE,!IS_GETTER);
  456.         
  457.         // MetaData per l'attributo totMessaggiDuplicati
  458.         MBeanAttributeInfo totMessaggiDuplicatiVAR 
  459.             = new MBeanAttributeInfo(MonitoraggioRisorse.TOT_MSG_DUPLICATI,long.class.getName(),
  460.                         "Numero di Messaggi duplicati gestiti nella porta di dominio",
  461.                             READABLE,!WRITABLE,!IS_GETTER);
  462.         
  463.         // MetaData per l'attributo risorseDisponibili
  464.         MBeanAttributeInfo risorseDisponibiliVAR 
  465.             = new MBeanAttributeInfo(MonitoraggioRisorse.RISORSE_DI_SISTEMA,String.class.getName(),
  466.                         "Indicazione sullo stato delle risorse disponibili per la porta di dominio",
  467.                             READABLE,!WRITABLE,!IS_GETTER);
  468.         
  469.         // MetaData per l'attributo risorseDisponibili
  470.         MBeanAttributeInfo monitoraggioPdDVAR 
  471.             = new MBeanAttributeInfo(MonitoraggioRisorse.STATO_DATI_MONITORAGGIO,String.class.getName(),
  472.                         "Monitoraggio della porta di dominio, premi pulsante (apply changes) per aggiornare i dati",
  473.                             READABLE,WRITABLE,!IS_GETTER);
  474.         
  475.         // MetaData per l'operazione 
  476.         MBeanOperationInfo getConnessioneAllocateDBManagerOP 
  477.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_DB_MANAGER,"Moduli funzionali che dispongono di una connessione verso il database dei messaggi",
  478.                     null,
  479.                     String.class.getName(),
  480.                     MBeanOperationInfo.ACTION);
  481.         
  482.         // MetaData per l'operazione 
  483.         MBeanOperationInfo getConnessioneAllocateDBManagerOP_method2
  484.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_DB_MANAGER_METHOD2,"Moduli funzionali che dispongono di una connessione verso il database dei messaggi",
  485.                     null,
  486.                     String.class.getName(),
  487.                     MBeanOperationInfo.ACTION);
  488.         
  489.         // MetaData per l'operazione 
  490.         MBeanOperationInfo getConnessioneAllocateQueueManagerOP 
  491.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_QUEUE_MANAGER,"Moduli funzionali che dispongono di una connessione verso il Broker JMS",
  492.                     null,
  493.                     String.class.getName(),
  494.                     MBeanOperationInfo.ACTION);
  495.         
  496.         // MetaData per l'operazione 
  497.         MBeanOperationInfo getConnessioneAllocateQueueManagerOP_method2 
  498.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_QUEUE_MANAGER_METHOD2,"Moduli funzionali che dispongono di una connessione verso il Broker JMS",
  499.                     null,
  500.                     String.class.getName(),
  501.                     MBeanOperationInfo.ACTION);
  502.         
  503.         // MetaData per l'operazione 
  504.         MBeanOperationInfo getTransazioniAttiveOP 
  505.         = new MBeanOperationInfo(TRANSAZIONI_ATTIVE_ID,"Transazioni attive",
  506.             null,
  507.             String.class.getName(),
  508.             MBeanOperationInfo.ACTION);
  509.         
  510.         // MetaData per l'operazione 
  511.         MBeanOperationInfo getTransazioniAttiveOP_method2 
  512.         = new MBeanOperationInfo(TRANSAZIONI_ATTIVE_ID_METHOD2,"Transazioni attive",
  513.             null,
  514.             String.class.getName(),
  515.             MBeanOperationInfo.ACTION);
  516.         
  517.         // MetaData per l'operazione 
  518.         MBeanOperationInfo getDettaglioTransazioneAttiva 
  519.         = new MBeanOperationInfo(GET_DETTAGLIO_TRANSAZIONE_ATTIVA,"Recupera i dettagli della transazione con id fornito come parametro",
  520.             new MBeanParameterInfo[]{
  521.                 new MBeanParameterInfo("idTransazione",String.class.getName(),"Identificativo della transazione"),
  522.             },
  523.             String.class.getName(),
  524.             MBeanOperationInfo.ACTION);
  525.         
  526.         // MetaData per l'operazione 
  527.         MBeanOperationInfo getTransazioniIdProtocolloAttiviOP 
  528.             = new MBeanOperationInfo(MonitoraggioRisorse.TRANSAZIONI_ATTIVE_ID_PROTOCOLLO,"Identificativi di Protocollo attivi sulla Porta",
  529.                     null,
  530.                     String.class.getName(),
  531.                     MBeanOperationInfo.ACTION);
  532.         
  533.         // MetaData per l'operazione 
  534.         MBeanOperationInfo getTransazioniIdProtocolloAttiviOP_method2  
  535.             = new MBeanOperationInfo(MonitoraggioRisorse.TRANSAZIONI_ATTIVE_ID_PROTOCOLLO_METHOD2,"Identificativi di Protocollo attivi sulla Porta",
  536.                     null,
  537.                     String.class.getName(),
  538.                     MBeanOperationInfo.ACTION);
  539.                 
  540.         // MetaData per l'operazione 
  541.         MBeanOperationInfo getActiveConnectionsPD_OP 
  542.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PD,"Connessioni attive su cui e' in corso un inoltro di busta (PortaDelegata)",
  543.                     null,
  544.                     String.class.getName(),
  545.                     MBeanOperationInfo.ACTION);
  546.         
  547.         // MetaData per l'operazione 
  548.         MBeanOperationInfo getActiveConnectionsPD_OP_method2   
  549.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PD_METHOD2,"Connessioni attive su cui e' in corso un inoltro di busta (PortaDelegata)",
  550.                     null,
  551.                     String.class.getName(),
  552.                     MBeanOperationInfo.ACTION);
  553.         
  554.         // MetaData per l'operazione 
  555.         MBeanOperationInfo getActiveConnectionsPA_OP 
  556.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PA,"Connessioni attive su cui e' in corso una consegna di contenuti applicativi (PortaApplicativa)",
  557.                     null,
  558.                     String.class.getName(),
  559.                     MBeanOperationInfo.ACTION);
  560.         
  561.         // MetaData per l'operazione 
  562.         MBeanOperationInfo getActiveConnectionsPA_OP_method2    
  563.             = new MBeanOperationInfo(MonitoraggioRisorse.CONNESSIONI_ALLOCATE_CONNETTORI_PA_METHOD2,"Connessioni attive su cui e' in corso una consegna di contenuti applicativi (PortaApplicativa)",
  564.                     null,
  565.                     String.class.getName(),
  566.                     MBeanOperationInfo.ACTION);
  567.         
  568.         // MetaData per l'operazione 
  569.         MBeanOperationInfo getRisorseSistema_OP 
  570.             = new MBeanOperationInfo(MonitoraggioRisorse.GET_STATO_RISORSE_DI_SISTEMA,"Ritorna lo stato delle risorse di sistema",
  571.                     null,
  572.                     String.class.getName(),
  573.                     MBeanOperationInfo.ACTION);
  574.         
  575.         // MetaData per l'operazione 
  576.         MBeanOperationInfo getRisorseSistema_OP_method2   
  577.             = new MBeanOperationInfo(MonitoraggioRisorse.GET_STATO_RISORSE_DI_SISTEMA_METHOD2,"Ritorna lo stato delle risorse di sistema",
  578.                     null,
  579.                     String.class.getName(),
  580.                     MBeanOperationInfo.ACTION);
  581.         
  582.         // MetaData per l'operazione 
  583.         MBeanOperationInfo getRisorseCache_OP 
  584.             = new MBeanOperationInfo(MonitoraggioRisorse.GET_STATO_CACHES,"Ritorna lo stato delle cache utilizzate dalla Porta",
  585.                     null,
  586.                     String.class.getName(),
  587.                     MBeanOperationInfo.ACTION);
  588.         
  589.         // MetaData per l'operazione 
  590.         MBeanOperationInfo getRisorseCache_OP_method2  
  591.             = new MBeanOperationInfo(MonitoraggioRisorse.GET_STATO_CACHES_METHOD2,"Ritorna lo stato delle cache utilizzate dalla Porta",
  592.                     null,
  593.                     String.class.getName(),
  594.                     MBeanOperationInfo.ACTION);
  595.         
  596.         // Mbean costruttore
  597.         MBeanConstructorInfo defaultConstructor = new MBeanConstructorInfo("Default Constructor","Crea e inizializza una nuova istanza del MBean",null);

  599.         // Lista attributi
  600.         MBeanAttributeInfo[] attributes = new MBeanAttributeInfo[]{monitoraggioPdDVAR,risorseDisponibiliVAR,
  601.                 numMsgInConsegnaVAR,tempoMedioAttesaInConsegnaVAR,tempoMaxAttesaInConsegnaVAR,
  602.                 numMsgInSpedizioneVAR,tempoMedioAttesaInSpedizioneVAR,tempoMaxAttesaInSpedizioneVAR,
  603.                 numMsgInProcessamentoVAR,tempoMedioAttesaInProcessamentoVAR,tempoMaxAttesaInProcessamentoVAR,
  604.                 totMessaggiVAR,tempoMedioAttesaVAR,tempoMaxAttesaVAR,totMessaggiDuplicatiVAR};
  605.         
  606.         // Lista Costruttori
  607.         MBeanConstructorInfo[] constructors = new MBeanConstructorInfo[]{defaultConstructor};
  608.         
  609.         // Lista operazioni
  610.         MBeanOperationInfo[] operations = new MBeanOperationInfo[]{getRisorseSistema_OP,getRisorseSistema_OP_method2,getRisorseCache_OP,getRisorseCache_OP_method2,
  611.                 getConnessioneAllocateDBManagerOP,getConnessioneAllocateDBManagerOP_method2,getConnessioneAllocateQueueManagerOP,getConnessioneAllocateQueueManagerOP_method2,
  612.                 getTransazioniAttiveOP,getTransazioniAttiveOP_method2, getDettaglioTransazioneAttiva, getTransazioniIdProtocolloAttiviOP,getTransazioniIdProtocolloAttiviOP_method2,
  613.                 getActiveConnectionsPD_OP,getActiveConnectionsPD_OP_method2,getActiveConnectionsPA_OP,getActiveConnectionsPA_OP_method2};
  614.         
  615.         return new MBeanInfo(className,description,attributes,constructors,operations,null);
  616.     }
  617.     
  618.     
  619.     /* Variabili per la gestione JMX */
  620.     private Logger log;

  622.     /* Costruttore */
  623.     public MonitoraggioRisorse(){
  624.         this.log = OpenSPCoop2Logger.getLoggerOpenSPCoopCore();
  625.     }
  626.     
  627.     public static final String MESSAGGIO_RISORSE_ADEGUATE = "GovWay possiede le adeguate risorse di sistema";
  628.     
  629.     public void refreshDatiMonitoraggioPdD(){

  631.         StringBuilder bf = new StringBuilder();
  632.         if( !TimerMonitoraggioRisorseThread.isRisorseDisponibili()){
  633.             bf.append("Risorse di sistema non disponibili: "+TimerMonitoraggioRisorseThread.getRisorsaNonDisponibile().getMessage());
  634.         }
  635.         if( !TimerThresholdThread.freeSpace){
  636.             if(bf.length()>0){
  637.                 bf.append("\n");
  638.             }
  639.             bf.append("[ThresholdCheck] Non sono disponibili abbastanza risorse per la gestione delle richieste");
  640.         }
  641.         if( !Tracciamento.tracciamentoDisponibile){
  642.             if(bf.length()>0){
  643.                 bf.append("\n");
  644.             }
  645.             bf.append("Tracciamento non disponibile: "+Tracciamento.motivoMalfunzionamentoTracciamento.getMessage());
  646.         }
  647.         if( !MsgDiagnostico.gestoreDiagnosticaDisponibile){
  648.             if(bf.length()>0){
  649.                 bf.append("\n");
  650.             }
  651.             bf.append("Sistema di diagnostica non disponibile: "+MsgDiagnostico.motivoMalfunzionamentoDiagnostici.getMessage());
  652.         }
  653.         if( !Dump.isSistemaDumpDisponibile()){
  654.             if(bf.length()>0){
  655.                 bf.append("\n");
  656.             }
  657.             bf.append("Sistema di dump dei contenuti applicativi non disponibile: "+Dump.getMotivoMalfunzionamentoDump().getMessage());
  658.         }
  659.         if(bf.length()==0){
  660.             bf.append(MonitoraggioRisorse.MESSAGGIO_RISORSE_ADEGUATE);
  661.         }
  662.         this.risorseDiSistema = bf.toString();
  663.         
  664.         try{
  665.             OpenSPCoop2Properties properties = OpenSPCoop2Properties.getInstance();
  666.             if(properties.getDatabaseType()!=null){
  667.                 DriverMonitoraggio driver = new DriverMonitoraggio(properties.getJNDIName_DataSource(),
  668.                         properties.getDatabaseType(),properties.getJNDIContext_DataSource(),this.log);
  669.                 StatoPdd stato = driver.getStatoRichiestePendenti(new FilterSearch());
  670.                 this.numMsgInConsegna = stato.getNumMsgInConsegna();
  671.                 this.numMsgInSpedizione = stato.getNumMsgInSpedizione();
  672.                 this.numMsgInProcessamento = stato.getNumMsgInProcessamento();
  673.                 this.totMessaggi = stato.getTotMessaggi();
  674.                 this.totMessaggiDuplicati = stato.getTotMessaggiDuplicati();
  675.                 if(stato.getTempoMaxAttesa()>0)
  676.                     this.tempoMaxAttesa = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMaxAttesa()*1000, false);
  677.                 if(stato.getTempoMaxAttesaInConsegna()>0)
  678.                     this.tempoMaxAttesaInConsegna = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMaxAttesaInConsegna()*1000, false);
  679.                 if(stato.getTempoMaxAttesaInSpedizione()>0)
  680.                     this.tempoMaxAttesaInSpedizione = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMaxAttesaInSpedizione()*1000, false);
  681.                 if(stato.getTempoMaxAttesaInProcessamento()>0)
  682.                     this.tempoMaxAttesaInProcessamento = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMaxAttesaInProcessamento()*1000, false);
  683.                 if(stato.getTempoMedioAttesa()>0)
  684.                     this.tempoMedioAttesa = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMedioAttesa()*1000, false);
  685.                 if(stato.getTempoMedioAttesaInConsegna()>0)
  686.                     this.tempoMedioAttesaInConsegna = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMedioAttesaInConsegna()*1000, false);
  687.                 if(stato.getTempoMedioAttesaInSpedizione()>0)
  688.                     this.tempoMedioAttesaInSpedizione = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMedioAttesaInSpedizione()*1000, false);
  689.                 if(stato.getTempoMedioAttesaInProcessamento()>0)
  690.                     this.tempoMedioAttesaInProcessamento = Utilities.convertSystemTimeIntoStringMillisecondi(stato.getTempoMedioAttesaInProcessamento()*1000, false);
  691.             
  692.                 this.datiMonitoraggioPdD = "Aggiornati al "+DateManager.getDate().toString();
  693.             }else{
  694.                 this.datiMonitoraggioPdD = "Non disponibili: e' necessario indicare il tipo di database in govway.properties";
  695.                 throw new Exception("Per il monitoraggio della porta di dominio e' necessario indicare il tipo di database in govway.properties");
  696.             }
  697.         }catch(Throwable e){
  698.             this.log.error("DriverMonitoraggio non inizializzato",e);
  699.             this.datiMonitoraggioPdD = "Non disponibili: "+e.getMessage();
  700.         }
  701.             
  702.     
  703.     }
  704.     
  705.     /* Metodi di management JMX */
  706.     
  707.     public String getStatoCaches(){
  708.         try{
  709.             return Cache.printStatistics("\n","\n-----------------------------------------------------\n");
  710.         }catch(Throwable e){
  711.             this.log.error(e.getMessage(),e);
  712.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+e.getMessage();
  713.         }
  714.     }
  715.     
  716.     public static final String MSG_NESSUNA_CONNESSIONE_ALLOCATA = "Nessuna connessione allocata";
  717.     public static final String MSG_CONNESSIONI_ALLOCATE = " risorse allocate: ";
  718.     public static final String MSG_CONNESSIONI_ALLOCATE_TRANSAZIONI = " risorse allocate per la gestione delle transazioni: ";
  719.     public static final String MSG_CONNESSIONI_ALLOCATE_STATISTICHE = " risorse allocate per la generazione delle statistiche: ";
  720.     public static final String MSG_CONNESSIONI_ALLOCATE_CONSEGNE_PRESE_IN_CARICO_SMISTATORE = " risorse allocate per lo smistatore dei messaggi presi in carico: ";
  721.     public static final String MSG_CONNESSIONI_ALLOCATE_CONSEGNE_PRESE_IN_CARICO_RUNTIME = " risorse allocate per il gestore runtime dei messaggi presi in carico: ";
  722.     public static final String MSG_CONNESSIONI_ALLOCATE_CONSEGNE_PRESE_IN_CARICO_TRANSAZIONI = " risorse allocate per il gestore delle tracce relative ai messaggi presi in carico: ";
  723.     public static final String MSG_CONNESSIONI_ALLOCATE_CONSEGNE_MESSAGE_BOX_RUNTIME = " risorse allocate per il gestore runtime del servizio MessageBox: ";
  724.     public static final String MSG_CONNESSIONI_ALLOCATE_CONSEGNE_MESSAGE_BOX_TRANSAZIONI = " risorse allocate per il gestore delle tracce del servizio MessageBox: ";
  725.     public static final String MSG_CONNESSIONI_HTTP_ALLOCATE = " connessioni allocate: ";
  726.     
  727.     public static final String MSG_NESSUNA_TRANSAZIONE_ATTIVA = "Nessuna transazione attiva";
  728.     public static final String MSG_TRANSAZIONI_ATTIVE = " transazioni attive: ";
  729.     public static final String MSG_TRANSAZIONI_ATTIVE_ID_PROTOCOLLO = " id di protocollo attivi: ";
  730.     
  731.     public String getUsedDBConnections(){
  732.         String[] risorse = null;
  733.         String[] risorseTransaction = null;
  734.         String[] risorseStatistiche = null;
  735.         String[] risorseConsegnePreseInCaricoSmistatore = null;
  736.         String[] risorseConsegnePreseInCaricoRuntime = null;
  737.         String[] risorseConsegnePreseInCaricoTransazioni = null;
  738.         String[] risorseConsegneMessageBoxRuntime = null;
  739.         String[] risorseConsegneMessageBoxTransazioni = null;
  740.         try{
  741.             risorse = DBManager.getStatoRisorse();
  742.             
  743.             OpenSPCoop2Properties prop = OpenSPCoop2Properties.getInstance();
  744.             
  745.             boolean useRuntimePdDTransazioni = DBTransazioniManager.getInstance().useRuntimePdD();
  746.             if(!useRuntimePdDTransazioni) {
  747.                 if(!prop.isTransazioniDatasourceUseDBUtils()) {
  748.                     // le aggiungo altrimenti non c'è altro modo per vederle
  749.                     risorseTransaction = DBTransazioniManager.getStatoRisorse();
  750.                 }
  751.             }
  752.             
  753.             if(prop.isStatisticheGenerazioneEnabled()) {
  754.                 boolean useRuntimePdDStatistiche = DBStatisticheManager.getInstance().useRuntimePdD();
  755.                 boolean useTransazioniStatistiche = DBStatisticheManager.getInstance().useTransazioni();
  756.                 if(!useRuntimePdDStatistiche && !useTransazioniStatistiche) {
  757.                     if(!prop.isStatisticheDatasourceUseDBUtils()) {
  758.                         // le aggiungo altrimenti non c'è altro modo per vederle
  759.                         risorseStatistiche = DBStatisticheManager.getStatoRisorse();
  760.                     }
  761.                 }
  762.             }
  763.             
  764.             if(prop.isServerJ2EE()!=null && !prop.isServerJ2EE()){
  765.                 if(prop.isTimerConsegnaContenutiApplicativiAbilitato()){
  766.                     boolean useDefaultManager = DBConsegnePreseInCaricoManager.getInstanceSmistatore().useDefaultManager();
  767.                     if(!useDefaultManager) {
  768.                         if(!prop.isTimerConsegnaContenutiApplicativi_smistatore_runtime_dataSource_useDBUtils()) {
  769.                             // le aggiungo altrimenti non c'è altro modo per vederle
  770.                             risorseConsegnePreseInCaricoSmistatore = DBConsegnePreseInCaricoManager.getStatoRisorseSmistatore();
  771.                         }
  772.                     }
  773.                     
  774.                     useDefaultManager = DBConsegnePreseInCaricoManager.getInstanceRuntime().useDefaultManager();
  775.                     if(!useDefaultManager) {
  776.                         if(!prop.isTimerConsegnaContenutiApplicativi_runtime_dataSource_useDBUtils()) {
  777.                             // le aggiungo altrimenti non c'è altro modo per vederle
  778.                             risorseConsegnePreseInCaricoRuntime = DBConsegnePreseInCaricoManager.getStatoRisorseRuntime();
  779.                         }
  780.                     }
  781.                     
  782.                     useDefaultManager = DBConsegnePreseInCaricoManager.getInstanceTransazioni().useDefaultManager();
  783.                     if(!useDefaultManager) {
  784.                         if(!prop.isTimerConsegnaContenutiApplicativi_transazioni_dataSource_useDBUtils()) {
  785.                             // le aggiungo altrimenti non c'è altro modo per vederle
  786.                             risorseConsegnePreseInCaricoTransazioni = DBConsegnePreseInCaricoManager.getStatoRisorseTransazioni();
  787.                         }
  788.                     }
  789.                 }
  790.             }
  791.             
  792.             if(prop.isIntegrationManagerEnabled()) {
  793.                 boolean useDefaultManager = DBConsegneMessageBoxManager.getInstanceRuntime().useDefaultManager() ||  DBConsegneMessageBoxManager.getInstanceRuntime().useConsegnePreseInCaricoManager();
  794.                 if(!useDefaultManager) {
  795.                     if(!prop.isIntegrationManager_runtime_dataSource_useDBUtils()) {
  796.                         // le aggiungo altrimenti non c'è altro modo per vederle
  797.                         risorseConsegneMessageBoxRuntime = DBConsegneMessageBoxManager.getStatoRisorse_runtime();
  798.                     }
  799.                 }
  800.                 
  801.                 useDefaultManager = DBConsegneMessageBoxManager.getInstanceTransazioni().useDefaultManager() ||  DBConsegneMessageBoxManager.getInstanceTransazioni().useConsegnePreseInCaricoManager();
  802.                 if(!useDefaultManager) {
  803.                     if(!prop.isIntegrationManager_transazioni_dataSource_useDBUtils()) {
  804.                         // le aggiungo altrimenti non c'è altro modo per vederle
  805.                         risorseConsegneMessageBoxTransazioni = DBConsegneMessageBoxManager.getStatoRisorse_transazioni();
  806.                     }
  807.                 }
  808.             }
  809.             
  810.         }catch(Throwable e){
  811.             this.log.error(e.getMessage(),e);
  812.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+e.getMessage();
  813.         }       
  814.         return getResultUsedDBConnections(risorse, risorseTransaction, risorseStatistiche,
  815.                 risorseConsegnePreseInCaricoSmistatore, risorseConsegnePreseInCaricoRuntime, risorseConsegnePreseInCaricoTransazioni,
  816.                 risorseConsegneMessageBoxRuntime, risorseConsegneMessageBoxTransazioni);
  817.     }
  818.     public static String getResultUsedDBConnections(String[] risorse, String[] risorseTransaction, String[] risorseStatistiche,
  819.             String[] risorseConsegnePreseInCaricoSmistatore, String[] risorseConsegnePreseInCaricoRuntime, String[] risorseConsegnePreseInCaricoTransazioni,
  820.             String[] risorseConsegneMessageBoxRuntime, String[] risorseConsegneMessageBoxTransazioni) {
  821.         
  822.         if((risorse==null || risorse.length<=0) && 
  823.                 (risorseTransaction==null || risorseTransaction.length<=0) && 
  824.                 (risorseStatistiche==null || risorseStatistiche.length<=0)
  825.                 ) {
  826.             return MSG_NESSUNA_CONNESSIONE_ALLOCATA;
  827.         }
  828.             
  829.         StringBuilder bf = new StringBuilder();
  830.         if(risorse!=null && risorse.length>0) {
  831.             bf.append(risorse.length+MSG_CONNESSIONI_ALLOCATE+"\n");
  832.             for(int i=0; i<risorse.length; i++){
  833.                 bf.append(risorse[i]+"\n");
  834.             }
  835.         }
  836.         if(risorseTransaction!=null && risorseTransaction.length>0) {
  837.             bf.append(risorseTransaction.length+MSG_CONNESSIONI_ALLOCATE_TRANSAZIONI+"\n");
  838.             for(int i=0; i<risorseTransaction.length; i++){
  839.                 bf.append(risorseTransaction[i]+"\n");
  840.             }
  841.         }
  842.         if(risorseStatistiche!=null && risorseStatistiche.length>0) {
  843.             bf.append(risorseStatistiche.length+MSG_CONNESSIONI_ALLOCATE_STATISTICHE+"\n");
  844.             for(int i=0; i<risorseStatistiche.length; i++){
  845.                 bf.append(risorseStatistiche[i]+"\n");
  846.             }
  847.         }
  848.         if(risorseConsegnePreseInCaricoSmistatore!=null && risorseConsegnePreseInCaricoSmistatore.length>0) {
  849.             bf.append(risorseConsegnePreseInCaricoSmistatore.length+MSG_CONNESSIONI_ALLOCATE_CONSEGNE_PRESE_IN_CARICO_SMISTATORE+"\n");
  850.             for(int i=0; i<risorseConsegnePreseInCaricoSmistatore.length; i++){
  851.                 bf.append(risorseConsegnePreseInCaricoSmistatore[i]+"\n");
  852.             }
  853.         }
  854.         if(risorseConsegnePreseInCaricoRuntime!=null && risorseConsegnePreseInCaricoRuntime.length>0) {
  855.             bf.append(risorseConsegnePreseInCaricoRuntime.length+MSG_CONNESSIONI_ALLOCATE_CONSEGNE_PRESE_IN_CARICO_RUNTIME+"\n");
  856.             for(int i=0; i<risorseConsegnePreseInCaricoRuntime.length; i++){
  857.                 bf.append(risorseConsegnePreseInCaricoRuntime[i]+"\n");
  858.             }
  859.         }
  860.         if(risorseConsegnePreseInCaricoTransazioni!=null && risorseConsegnePreseInCaricoTransazioni.length>0) {
  861.             bf.append(risorseConsegnePreseInCaricoTransazioni.length+MSG_CONNESSIONI_ALLOCATE_CONSEGNE_PRESE_IN_CARICO_TRANSAZIONI+"\n");
  862.             for(int i=0; i<risorseConsegnePreseInCaricoTransazioni.length; i++){
  863.                 bf.append(risorseConsegnePreseInCaricoTransazioni[i]+"\n");
  864.             }
  865.         }
  866.         if(risorseConsegneMessageBoxRuntime!=null && risorseConsegneMessageBoxRuntime.length>0) {
  867.             bf.append(risorseConsegneMessageBoxRuntime.length+MSG_CONNESSIONI_ALLOCATE_CONSEGNE_MESSAGE_BOX_RUNTIME+"\n");
  868.             for(int i=0; i<risorseConsegneMessageBoxRuntime.length; i++){
  869.                 bf.append(risorseConsegneMessageBoxRuntime[i]+"\n");
  870.             }
  871.         }
  872.         if(risorseConsegneMessageBoxTransazioni!=null && risorseConsegneMessageBoxTransazioni.length>0) {
  873.             bf.append(risorseConsegneMessageBoxTransazioni.length+MSG_CONNESSIONI_ALLOCATE_CONSEGNE_MESSAGE_BOX_TRANSAZIONI+"\n");
  874.             for(int i=0; i<risorseConsegneMessageBoxTransazioni.length; i++){
  875.                 bf.append(risorseConsegneMessageBoxTransazioni[i]+"\n");
  876.             }
  877.         }
  878.         
  879.         return bf.toString();
  880.     }
  881.     
  882.     public String getUsedQueueConnections(){
  883.         String[] risorse = null;
  884.         try{
  885.             risorse = QueueManager.getStatoRisorse();
  886.         }catch(Throwable e){
  887.             this.log.error(e.getMessage(),e);
  888.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+e.getMessage();
  889.         }
  890.         return getResultUsedQueueConnections(risorse);
  891.     }
  892.     public static String getResultUsedQueueConnections(String[] risorse) {
  893.         if(risorse==null || risorse.length<=0)
  894.             return MSG_NESSUNA_CONNESSIONE_ALLOCATA;
  895.         
  896.         StringBuilder bf = new StringBuilder();
  897.         bf.append(risorse.length+MSG_CONNESSIONI_ALLOCATE+"\n");
  898.         for(int i=0; i<risorse.length; i++){
  899.             bf.append(risorse[i]+"\n");
  900.         }
  901.         return bf.toString();
  902.     }
  903.     
  904.     public String getTransazioniAttiveId() {
  905.         List<String> risorse = null;
  906.         try{
  907.             risorse = TransactionContext.getTransactionKeys();
  908.         }catch(Throwable e){
  909.             this.log.error(e.getMessage(),e);
  910.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+e.getMessage();
  911.         }
  912.         return getResultTransazioniAttiveId(risorse);
  913.     }
  914.     public static String getResultTransazioniAttiveId(List<String> risorse) {
  915.         if(risorse==null || risorse.size()<=0)
  916.             return MSG_NESSUNA_TRANSAZIONE_ATTIVA;
  917.         
  918.         StringBuilder bf = new StringBuilder();
  919.         bf.append(risorse.size()+MSG_TRANSAZIONI_ATTIVE+"\n");
  920.         for(int i=0; i<risorse.size(); i++){
  921.             bf.append(risorse.get(i)+"\n");
  922.         }
  923.         return bf.toString();
  924.     }
  925.     
  926.     public String getDettaglioTransazioneAttivaId(String idTransazione) {
  927.         
  928.         try{
  929.             Transaction tr = TransactionContext.getTransaction(idTransazione);
  930.             if(tr!=null) {
  931.                 return tr.toString();
  932.             }
  933.             throw new TransactionNotExistsException();
  934.         }
  935.         catch(TransactionNotExistsException notFound) {
  936.             return "Transazione non esistente";
  937.         }
  938.         catch(Throwable e){
  939.             this.log.error(e.getMessage(),e);
  940.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+e.getMessage();
  941.         }
  942.         
  943.     }
  944.     
  945.     public String getTransazioniAttiveIdProtocollo() {
  946.         List<String> risorse = null;
  947.         try{
  948.             risorse = TransactionContext.getIdBustaKeys();
  949.         }catch(Throwable e){
  950.             this.log.error(e.getMessage(),e);
  951.             return JMXUtils.MSG_OPERAZIONE_NON_EFFETTUATA+e.getMessage();
  952.         }
  953.         return getResultTransazioniAttiveIdProtocollo(risorse);
  954.     }
  955.     public static String getResultTransazioniAttiveIdProtocollo(List<String> risorse) {
  956.         if(risorse==null || risorse.size()<=0)
  957.             return MSG_NESSUNA_TRANSAZIONE_ATTIVA;
  958.         
  959.         StringBuilder bf = new StringBuilder();
  960.         bf.append(risorse.size()+MSG_TRANSAZIONI_ATTIVE_ID_PROTOCOLLO+"\n");
  961.         for(int i=0; i<risorse.size(); i++){
  962.             bf.append(risorse.get(i)+"\n");
  963.         }
  964.         return bf.toString();
  965.     }
  966.     
  967.     public String getActivePDConnections(){ 
  968.         Map<String, IConnettore> connettori_pd = RepositoryConnettori.getConnettori_pd();       
  969.         return getActiveConnections(connettori_pd);
  970.     }
  971.     public String getActivePAConnections(){ 
  972.         Map<String, IConnettore> connettori_pa = RepositoryConnettori.getConnettori_pa();       
  973.         return getActiveConnections(connettori_pa);
  974.     }
  975.     private String getActiveConnections(Map<String, IConnettore> connettoriParam){
  976.         
  977.         List<String> cConnettori = new ArrayList<>();
  978.         for (String id : connettoriParam.keySet()) {
  979.             IConnettore c = connettoriParam.get(id);
  980.             String location = null;
  981.             try{
  982.                 location = c.getLocation();
  983.             }catch(Exception e){
  984.                 location = "ERRORE: "+e.getMessage();
  985.             }
  986.             cConnettori.add((id+" -> ["+location+"]"));
  987.         }
  988.         return getResultActiveConnections(cConnettori);
  989.         
  990.     }
  991.     public static String getResultActiveConnections(List<String> cConnettori) {
  992.         if(cConnettori==null || cConnettori.size()==0)
  993.             return MSG_NESSUNA_CONNESSIONE_ALLOCATA;
  994.         
  995.         StringBuilder bf = new StringBuilder();
  996.         bf.append(cConnettori.size()+MSG_CONNESSIONI_HTTP_ALLOCATE+"\n");
  997.         for(int i=0; i<cConnettori.size(); i++){
  998.             bf.append(cConnettori.get(i)+"\n");
  999.         }
  1000.         return bf.toString();
  1001.     }
  1002.     
  1003. }
Created with JaCoCo 0.8.8.202204050719