public JRMPInvokerHA() 
{
   
      super();
}

Explicit no-args constructor.

 public Invoker createProxy(ObjectName beanName,
    LoadBalancePolicy policy,
    String proxyFamilyName) throws Exception 
{
      Integer hash = new Integer(beanName.hashCode());
      HATarget target = (HATarget) beanMap.get(hash);
      if (target == null)
      {
         throw new IllegalStateException("The bean hashCode not found");
      }
      String familyName = proxyFamilyName;
      if (familyName == null)
         familyName= target.getAssociatedPartition().getPartitionName() + "/" + beanName;
      return createProxy(target.getReplicants(), policy, familyName, target.getCurrentViewId ());
}

 protected Invoker createProxy(ArrayList targets,
    LoadBalancePolicy policy,
    String proxyFamilyName,
    long viewId) 
{
      return new JRMPInvokerProxyHA(targets, policy, proxyFamilyName, viewId);
}

 public ObjectName getServiceName() 
{
      return (serviceName == null ? support.getServiceName() : serviceName);
}

 public Object invoke(Invocation invocation) throws Exception 
{
      ClassLoader oldCl = Thread.currentThread().getContextClassLoader();
      try
      {
         // Deserialize the transaction if it is there
         invocation.setTransaction(importTPC(((MarshalledInvocation) invocation).getTransactionPropagationContext()));
         // Extract the ObjectName, the rest is still marshalled
         ObjectName mbean = (ObjectName) Registry.lookup(invocation.getObjectName());
         long clientViewId = ((Long)invocation.getValue("CLUSTER_VIEW_ID")).longValue();
         HATarget target = (HATarget)beanMap.get(invocation.getObjectName());
         if (target == null) 
         {
            // We could throw IllegalStateException but we have a race condition that could occur:
            // when we undeploy a bean, the cluster takes some time to converge
            // and to recalculate a new viewId and list of replicant for each HATarget.
            // Consequently, a client could own an up-to-date list of the replicants
            // (before the cluster has converged) and try to perform an invocation
            // on this node where the HATarget no more exist, thus receiving a
            // wrong exception and no failover is performed with an IllegalStateException
            //
            throw new GenericClusteringException(GenericClusteringException.COMPLETED_NO, 
                                                 "target is not/no more registered on this node");            
         }
         if (!target.invocationsAllowed ())
            throw new GenericClusteringException(GenericClusteringException.COMPLETED_NO, 
                                        "invocations are currently not allowed on this target");            
         // The cl on the thread should be set in another interceptor
         Object rtn = support.getServer().invoke(mbean,
                                                 "invoke",
                                                 new Object[] { invocation },
                                                 Invocation.INVOKE_SIGNATURE);
         HARMIResponse rsp = new HARMIResponse();
         if (clientViewId != target.getCurrentViewId())
         {
            rsp.newReplicants = new ArrayList(target.getReplicants());
            rsp.currentViewId = target.getCurrentViewId();
         }
         rsp.response = rtn;
         return new MarshalledObject(rsp);
      }
      catch (InstanceNotFoundException e)
      {
         throw new GenericClusteringException(GenericClusteringException.COMPLETED_NO, e);
      }
      catch (ReflectionException e)
      {
         throw new GenericClusteringException(GenericClusteringException.COMPLETED_NO, e);
      }
      catch (Exception e)
      {
         org.jboss.mx.util.JMXExceptionDecoder.rethrow(e);
         // the compiler does not know an exception is thrown by the above
         throw new org.jboss.util.UnreachableStatementException();
      }
      finally
      {
         Thread.currentThread().setContextClassLoader(oldCl);
      }
}

Invoke a Remote interface method.

 public ObjectName preRegister(MBeanServer server,
    ObjectName name) throws Exception 
{
      ObjectName result = super.preRegister(server, name);
      if (!result.equals(getServiceName()))
         throw new IllegalStateException("JMX registration (" + result + 
               ") differs from our configured service name (" + 
               getServiceName() +")");
      return result;
}

 public  void registerBean(ObjectName beanName,
    HATarget target) throws Exception 
{
      Integer hash = new Integer(beanName.hashCode());
      log.debug("registerBean: "+beanName);
      if (beanMap.containsKey(hash))
      {
         // FIXME [oleg] In theory this is possible!
         log.debug("Trying to register target " + target + " using an existing hashCode. Already registered: " + hash + "=" + beanMap.get(hash));
         throw new IllegalStateException("Trying to register target using an existing hashCode.");
      }
      beanMap.put(hash, target);
}

 public  void setServiceName(ObjectName serviceName) 
{
      this.serviceName = serviceName;
}

 protected  void startService() throws Exception 
{
      loadCustomSocketFactories();
      if (log.isDebugEnabled())
      {
         log.debug("RMI Port='" +  (rmiPort == ANONYMOUS_PORT ?
            "Anonymous" : Integer.toString(rmiPort)+"'"));
         log.debug("Client SocketFactory='" + (clientSocketFactory == null ?
            "Default" : clientSocketFactory.toString()+"'"));
         log.debug("Server SocketFactory='" + (serverSocketFactory == null ?
            "Default" : serverSocketFactory.toString()+"'"));
         log.debug("Server SocketAddr='" + (serverAddress == null ?
            "Default" : serverAddress+"'"));
         log.debug("SecurityDomain='" + (sslDomain == null ?
            "None" : sslDomain+"'"));
      }
      exportCI();
      Registry.bind(getServiceName(), this);
}

 protected  void stopService() throws Exception 
{
      unexportCI();
}

 public  void unregisterBean(ObjectName beanName) throws Exception 
{
      Integer hash = new Integer(beanName.hashCode());
      beanMap.remove(hash);
}