Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source.
   * Copyright 2006, Red Hat Middleware LLC, and individual contributors
   * as indicated by the @author tags. See the copyright.txt file in the
   * distribution for a full listing of individual contributors.
   *
   * This is free software; you can redistribute it and/or modify it
   * under the terms of the GNU Lesser General Public License as
   * published by the Free Software Foundation; either version 2.1 of
  * the License, or (at your option) any later version.
  *
  * This software is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  * Lesser General Public License for more details.
  *
  * You should have received a copy of the GNU Lesser General Public
  * License along with this software; if not, write to the Free
  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  */
 package org.jboss.ws.common.management;
 
 import static org.jboss.ws.common.Loggers.MANAGEMENT_LOGGER;
 
 import java.util.List;
 
 
The endpoint MBean representation

Author(s):
Thomas.Diesler@jboss.org
Since:
20-Jun-2007
 
 public class ManagedEndpoint implements ManagedEndpointMBean
 {
    private final Endpoint endpoint;
    private final MBeanServer mbeanServer;
 
    public ManagedEndpoint(Endpoint endpointMBeanServer mbeanServer)
    {
       this. = endpoint;
       this. = mbeanServer;
    }
    
    public String getAddress()
    {
       return .getAddress();
    }
 
    public long getAverageProcessingTime()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
       return metrics != null ? metrics.getAverageProcessingTime() : 0;
    }
 
    public long getFaultCount()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
       return metrics != null ? metrics.getFaultCount() : 0;
    }
 
    public long getMaxProcessingTime()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
       return metrics != null ? metrics.getMaxProcessingTime() : 0;
    }
 
    public long getMinProcessingTime()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
       return metrics != null ? metrics.getMinProcessingTime() : 0;
    }
 
    public long getRequestCount()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
       return metrics != null ? metrics.getRequestCount() : 0;
    }
 
    public long getResponseCount()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
       return metrics != null ? metrics.getResponseCount() : 0;
    }
 
    public long getTotalProcessingTime()
    {
       EndpointMetrics metrics = .getEndpointMetrics();
      return metrics != null ? metrics.getTotalProcessingTime() : 0;
   }
   public void start()
   {
   }
   public void stop()
   {
   }
   public void processRecord(Record record)
   {
      .processRecord(record);
   }
   public void addRecordProcessor(RecordProcessor processor)
   {
      ObjectName on = ObjectNameFactory.create(.getName() + ",recordProcessor=" + processor.getName());
      this.getRecordProcessors().add(processor);
      try
      {
         .registerMBean(processoron);
      }
      catch (JMException ex)
      {
         try
         {
            .registerMBean(new ManagedRecordProcessor(processor), on);
         }
         catch (JMException innerEx)
         {
            .cannotRegisterProcessorWithJmxServer(oninnerEx);
         }
      }
   }
   {
      return .getRecordProcessors();
   }
   public void setRecordProcessors(List<RecordProcessorprocessors)
   {
      //unregister current processors
      for (RecordProcessor processor : .getRecordProcessors())
      {
         final ObjectName on = ObjectNameFactory.create(.getName() + ",recordProcessor=" + processor.getName());
         try
         {
            .unregisterMBean(on);
         }
         catch (JMException ex)
         {
         }
      }
      //set and register the new processors
      .setRecordProcessors(processors);
      for (RecordProcessor processor : processors)
      {
         final ObjectName on = ObjectNameFactory.create(.getName() + ",recordProcessor=" + processor.getName());
         try
         {
            .registerMBean(processoron);
         }
         catch (JMException ex)
         {
            .cannotRegisterProvidedProcessor(onex);
            try
            {
               .registerMBean(new ManagedRecordProcessor(processor), on);
            }
            catch (JMException innerEx)
            {
               .cannotRegisterProcessorWithJmxServer(oninnerEx);
            }
         }
      }
   }
New to GrepCode? Check out our FAQ X