List of broadcastRpcCommand() Examples

Examples of broadcastRpcCommand()

org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()
Broadcasts an RPC command to the entire cluster. @param rpc command to execute remotely @param sync if true, the transport will operate in sync mode. Otherwise, it will operate in async mode. @throws ReplicationException in the event of problems

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

         CacheCommandInitializer factory = cache.getComponentRegistry()
               .getComponent(CacheCommandInitializer.class);
         boolean isSync = isSynchronousCache(cache);


         EvictAllCommand cmd = factory.buildEvictAllCommand(cache.getName());
         rpcManager.broadcastRpcCommand(cmd, isSync);
      }
   }


   public static boolean isInvalidationCache(AdvancedCache cache) {
      return cache.getCacheConfiguration()

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

      final CacheCommandInitializer factory = cache.getComponentRegistry()
          .getComponent( CacheCommandInitializer.class );
      final boolean isSync = isSynchronousCache( cache );


      final EvictAllCommand cmd = factory.buildEvictAllCommand( cache.getName() );
      rpcManager.broadcastRpcCommand( cmd, isSync );
    }
  }


   /**
    * Indicates whether the given cache is configured with

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

      final CacheCommandInitializer factory = cache.getComponentRegistry()
          .getComponent( CacheCommandInitializer.class );
      final boolean isSync = isSynchronousCache( cache );


      final EvictAllCommand cmd = factory.buildEvictAllCommand( cache.getName() );
      rpcManager.broadcastRpcCommand( cmd, isSync );
    }
  }


   /**
    * Indicates whether the given cache is configured with

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

         CacheCommandInitializer factory = cache.getComponentRegistry()
               .getComponent(CacheCommandInitializer.class);
         boolean isSync = isSynchronousCache(cache);


         EvictAllCommand cmd = factory.buildEvictAllCommand(cache.getName());
         rpcManager.broadcastRpcCommand(cmd, isSync);
      }
   }


   public static boolean isInvalidationCache(AdvancedCache cache) {
      return cache.getCacheConfiguration()

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

      final CacheCommandInitializer factory = cache.getComponentRegistry()
          .getComponent( CacheCommandInitializer.class );
      final boolean isSync = isSynchronousCache( cache );


      final EvictAllCommand cmd = factory.buildEvictAllCommand( cache.getName() );
      rpcManager.broadcastRpcCommand( cmd, isSync );
    }
  }


  public static boolean isInvalidationCache(AdvancedCache cache) {
    return cache.getCacheConfiguration()

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

   public void broadcastEvictAll() {
      RpcManager rpcManager = cache.getRpcManager();
      if (rpcManager != null) {
         // Only broadcast evict all if it's clustered
         EvictAllCommand cmd = cacheCmdInitializer.buildEvictAllCommand(cache.getName());
         rpcManager.broadcastRpcCommand(cmd, isSync);
      }
   }


   @Override
   public <T> T withinTx(Callable<T> c) throws Exception {

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

   public void broadcastEvictAll() {
      RpcManager rpcManager = cache.getRpcManager();
      if (rpcManager != null) {
         // Only broadcast evict all if it's clustered
         EvictAllCommand cmd = cacheCmdInitializer.buildEvictAllCommand(cache.getName());
         rpcManager.broadcastRpcCommand(cmd, isSync);
      }
   }


   @Override
   public <T> T withinTx(Callable<T> c) throws Exception {

View Full Code Here

Examples of org.infinispan.remoting.rpc.RpcManager.broadcastRpcCommand()

      final CacheCommandInitializer factory = cache.getComponentRegistry()
          .getComponent( CacheCommandInitializer.class );
      final boolean isSync = isSynchronousCache( cache );


      final EvictAllCommand cmd = factory.buildEvictAllCommand( cache.getName() );
      rpcManager.broadcastRpcCommand( cmd, isSync );
    }
  }


   /**
    * Indicates whether the given cache is configured with

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.