Examples of ResponseMode

Examples of org.infinispan.remoting.rpc.ResponseMode


   @Override
   public Object visitRollbackCommand(TxInvocationContext ctx, RollbackCommand command) throws Throwable {
      if (shouldInvokeRemoteTxCommand(ctx)) {
         boolean syncRollback = cacheConfiguration.transaction().syncRollbackPhase();
         ResponseMode responseMode = syncRollback ? ResponseMode.SYNCHRONOUS_IGNORE_LEAVERS : ResponseMode.ASYNCHRONOUS;
         rpcManager.invokeRemotely(getCommitNodes(ctx), command, rpcManager.getRpcOptionsBuilder(responseMode, false).build());
      }


      return invokeNextInterceptor(ctx, command);
   }

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode


      public RspList call() throws Exception {
         if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


         // Replay capability requires responses from all members!
         ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : this.mode;


         RspList<Object> retval = null;
         Buffer buf;
         if (broadcast || FORCE_MCAST) {
            RequestOptions opts = new RequestOptions();

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode


      public RspList call() throws Exception {
         if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


         // Replay capability requires responses from all members!
         ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : this.mode;


         RspList<Object> retval = null;
         Buffer buf;
         if (broadcast || FORCE_MCAST) {
            RequestOptions opts = new RequestOptions();

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode


      public RspList call() throws Exception {
         if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


         // Replay capability requires responses from all members!
         ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : this.mode;


         RspList<Object> retval = null;
         Buffer buf;
         if (broadcast || FORCE_MCAST) {
            RequestOptions opts = new RequestOptions();

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode


      public RspList call() throws Exception {
         if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


         // Replay capability requires responses from all members!
         ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : this.mode;


         RspList<Object> retval = null;
         Buffer buf;
         if (broadcast || FORCE_MCAST) {
            RequestOptions opts = new RequestOptions();

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode


      public RspList call() throws Exception {
         if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


         // Replay capability requires responses from all members!
         ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : this.mode;


         if (filter != null) mode = ResponseMode.GET_FIRST;


         RspList<Object> retval = null;
         Buffer buf;

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode

                                             Marshaller marshaller, CommandAwareRpcDispatcher card, boolean oob,
                                             JGroupsTransport transport) throws Exception {
      if (trace) log.tracef("Replication task sending %s to single recipient %s", command, destination);


      // Replay capability requires responses from all members!
      ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : origMode;
      Response retval;
      Buffer buf;
      buf = marshallCall(marshaller, command);
      retval = card.sendMessage(constructMessage(buf, destination, oob, mode),
                                new RequestOptions(mode, timeout));

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode

                                               RspFilter filter, List<Address> dests, ResponseMode origMode,
                                               Marshaller marshaller, CommandAwareRpcDispatcher card, boolean oob, boolean anycasting) throws Exception {
      if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


      // Replay capability requires responses from all members!
      ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : origMode;


      RspList<Object> retval = null;
      Buffer buf;
      if (broadcast || FORCE_MCAST) {
         buf = marshallCall(marshaller, command);

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode


      public RspList call() throws Exception {
         if (trace) log.tracef("Replication task sending %s to addresses %s", command, dests);


         // Replay capability requires responses from all members!
         ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : this.mode;


         RspList<Object> retval = null;
         Buffer buf;
         if (broadcast || FORCE_MCAST) {
            RequestOptions opts = new RequestOptions();

View Full Code Here

Examples of org.jgroups.blocks.ResponseMode

                                             Marshaller marshaller, CommandAwareRpcDispatcher card, boolean oob,
                                             JGroupsTransport transport) throws Exception {
      if (trace) log.tracef("Replication task sending %s to single recipient %s", command, destination);


      // Replay capability requires responses from all members!
      ResponseMode mode = supportReplay ? ResponseMode.GET_ALL : origMode;
      Response retval;
      Buffer buf;
      buf = marshallCall(marshaller, command);
      retval = card.sendMessage(constructMessage(buf, destination, oob, mode),
                                new RequestOptions(mode, timeout));

View Full Code Here

0 1

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.