public ExplicitFailoverServerInterceptor() 
{

}

 protected  void checkFailoverNeed(Invocation mi) throws GenericClusteringException 
{
      Object data = mi.getValue ("DO_FAIL_DURING_NEXT_CALL");
      if (data != null &&
          data instanceof java.lang.Boolean &&
          data.equals (java.lang.Boolean.TRUE))
      {
         // we now determine if we have already failed
         //
         Object alreadyDone = mi.getValue ("FAILOVER_COUNTER");
         if (alreadyDone != null &&
             alreadyDone instanceof java.lang.Integer &&
             ((java.lang.Integer)alreadyDone).intValue () == 0)
         {
            // we do fail
            //
            this.log.debug ("WE FAILOVER IN SERVER INTERCEPTOR (explicit failover asked by client interceptor)!");
            throw new GenericClusteringException 
               (GenericClusteringException.COMPLETED_NO, "Test failover from server interceptor", false);
         }
      }
}

 public Container getContainer() 
{
      return container;
}

 public Object invoke(Invocation mi) throws Exception 
{
      checkFailoverNeed (mi);
      return super.invoke (mi);
}

 public Object invokeHome(Invocation mi) throws Exception 
{
      checkFailoverNeed (mi);
     return super.invokeHome (mi);
}

 public  void setContainer(Container container) 
{
      this.container = container;
}