geode-core/src/main/java/org/apache/geode/internal/cache/RemoteOperationMessage.java
public void waitForCacheException()
        throws CacheException, RemoteOperationException, PrimaryBucketException {
      try {
        waitForRepliesUninterruptibly();
        if (this.prce != null || (this.responseRequired && !this.responseReceived)) {
          throw new RemoteOperationException(
              LocalizedStrings.PartitionMessage_ATTEMPT_FAILED.toLocalizedString(), this.prce);
        }
      } catch (ReplyException e) {
        Throwable t = e.getCause();
        if (t instanceof CacheException) {
          throw (CacheException) t;
        } else if (t instanceof RemoteOperationException) {
          RemoteOperationException ft = (RemoteOperationException) t;
          // See FetchEntriesMessage, which can marshal a ForceReattempt
          // across to the sender
          RemoteOperationException fre = new RemoteOperationException(
              LocalizedStrings.PartitionMessage_PEER_REQUESTS_REATTEMPT.toLocalizedString(), t);
          if (ft.hasHash()) {
            fre.setHash(ft.getHash());
          }
          throw fre;
        } else if (t instanceof PrimaryBucketException) {
          // See FetchEntryMessage, GetMessage, InvalidateMessage,
          // PutMessage
          // which can marshal a ForceReattemptacross to the sender
          throw new PrimaryBucketException(
              LocalizedStrings.PartitionMessage_PEER_FAILED_PRIMARY_TEST.toLocalizedString(), t);
        } else if (t instanceof RegionDestroyedException) {
          throw (RegionDestroyedException) t;
        } else if (t instanceof CancelException) {
          if (logger.isDebugEnabled()) {
            logger.debug(
                "RemoteOperationResponse got CacheClosedException from {}, throwing ForceReattemptException",
                e.getSender(), t);
          }
          throw new RemoteOperationException(
              LocalizedStrings.PartitionMessage_PARTITIONRESPONSE_GOT_REMOTE_CACHECLOSEDEXCEPTION
                  .toLocalizedString(),
              t);
        } else if (t instanceof LowMemoryException) {
          if (logger.isDebugEnabled()) {
            logger.debug("RemoteOperationResponse re-throwing remote LowMemoryException from {}",
                e.getSender(), t);
          }
          throw (LowMemoryException) t;
        }
        e.handleAsUnexpected();
      }
    }
/**
     * Waits for the response from the {@link RemoteOperationMessage}'s recipient
     * 
     * @throws CacheException if the recipient threw a cache exception during message processing
     */
Waits for the response from the  RemoteOperationMessage's recipient

@throws CacheException if the recipient threw a cache exception during message processing
Waits for the response from the RemoteOperationMessage ' s recipient @throws CacheException if the recipient threw a cache exception during message processing
public void waitForCacheException()
        throws CacheException, RemoteOperationException, PrimaryBucketException {
      try {
        waitForRepliesUninterruptibly();
        if (this.prce != null || (this.responseRequired && !this.responseReceived)) {
          throw new RemoteOperationException(
              LocalizedStrings.PartitionMessage_ATTEMPT_FAILED.toLocalizedString(), this.prce);
        }
      } catch (ReplyException e) {
        Throwable t = e.getCause();
        if (t instanceof CacheException) {
          throw (CacheException) t;
        } else if (t instanceof RemoteOperationException) {
          RemoteOperationException ft = (RemoteOperationException) t;
          RemoteOperationException fre = new RemoteOperationException(
              LocalizedStrings.PartitionMessage_PEER_REQUESTS_REATTEMPT.toLocalizedString(), t);
          if (ft.hasHash()) {
            fre.setHash(ft.getHash());
          }
          throw fre;
        } else if (t instanceof PrimaryBucketException) {
          throw new PrimaryBucketException(
              LocalizedStrings.PartitionMessage_PEER_FAILED_PRIMARY_TEST.toLocalizedString(), t);
        } else if (t instanceof RegionDestroyedException) {
          throw (RegionDestroyedException) t;
        } else if (t instanceof CancelException) {
          if (logger.isDebugEnabled()) {
            logger.debug(
                "RemoteOperationResponse got CacheClosedException from {}, throwing ForceReattemptException",
                e.getSender(), t);
          }
          throw new RemoteOperationException(
              LocalizedStrings.PartitionMessage_PARTITIONRESPONSE_GOT_REMOTE_CACHECLOSEDEXCEPTION
                  .toLocalizedString(),
              t);
        } else if (t instanceof LowMemoryException) {
          if (logger.isDebugEnabled()) {
            logger.debug("RemoteOperationResponse re-throwing remote LowMemoryException from {}",
                e.getSender(), t);
          }
          throw (LowMemoryException) t;
        }
        e.handleAsUnexpected();
      }
    }
public void waitForCacheException ( ) throws CacheException , RemoteOperationException , PrimaryBucketException { try { waitForRepliesUninterruptibly ( ) ; if ( this . prce != null || ( this . responseRequired && ! this . responseReceived ) ) { throw new RemoteOperationException ( LocalizedStrings . PartitionMessage_ATTEMPT_FAILED . toLocalizedString ( ) , this . prce ) ; } } catch ( ReplyException e ) { Throwable t = e . getCause ( ) ; if ( t instanceof CacheException ) { throw ( CacheException ) t ; } else if ( t instanceof RemoteOperationException ) { RemoteOperationException ft = ( RemoteOperationException ) t ; RemoteOperationException fre = new RemoteOperationException ( LocalizedStrings . PartitionMessage_PEER_REQUESTS_REATTEMPT . toLocalizedString ( ) , t ) ; if ( ft . hasHash ( ) ) { fre . setHash ( ft . getHash ( ) ) ; } throw fre ; } else if ( t instanceof PrimaryBucketException ) { throw new PrimaryBucketException ( LocalizedStrings . PartitionMessage_PEER_FAILED_PRIMARY_TEST . toLocalizedString ( ) , t ) ; } else if ( t instanceof RegionDestroyedException ) { throw ( RegionDestroyedException ) t ; } else if ( t instanceof CancelException ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "RemoteOperationResponse got CacheClosedException from {}, throwing ForceReattemptException" , e . getSender ( ) , t ) ; } throw new RemoteOperationException ( LocalizedStrings . PartitionMessage_PARTITIONRESPONSE_GOT_REMOTE_CACHECLOSEDEXCEPTION . toLocalizedString ( ) , t ) ; } else if ( t instanceof LowMemoryException ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "RemoteOperationResponse re-throwing remote LowMemoryException from {}" , e . getSender ( ) , t ) ; } throw ( LowMemoryException ) t ; } e . handleAsUnexpected ( ) ; } }
Waits for the response from the {@link RemoteOperationMessage}'s recipient
Waits for the response from the { @link RemoteOperationMessage } ' s recipient
// See FetchEntriesMessage, which can marshal a ForceReattempt // across to the sender // See FetchEntryMessage, GetMessage, InvalidateMessage, // PutMessage // which can marshal a ForceReattemptacross to the sender