Package com.gigaspaces.internal.remoting.routing

Class AbstractRemoteOperationRouter

java.lang.Object

com.gigaspaces.internal.remoting.routing.AbstractRemoteOperationRouter

All Implemented Interfaces:

RemoteOperationRouter

Direct Known Subclasses:

ClusterRemoteOperationRouter, EmbeddedRemoteOperationRouter, PartitionedClusterRemoteOperationRouter

public abstract class AbstractRemoteOperationRouter
extends Object
implements RemoteOperationRouter

Since:

9.0.0

Author:

Niv Ingberg

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor	Description
AbstractRemoteOperationRouter(String name)

Method Summary

Modifier and Type	Method	Description
RemoteOperationsExecutorProxy	getCachedMember()
protected void	logAfterExecute(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, RemoteOperationResult result, boolean oneway)
protected void	logAfterExecuteAsync(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, RemoteOperationResult result)
protected void	logAsyncExecutionFailure(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception)
protected void	logBeforeExecute(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, boolean oneway)
protected void	logBeforeExecuteAsync(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request)
protected void	logExecutionFailure(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception, boolean oneway)
protected void	logInterruptedAsyncExecution(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception)
protected void	logInterruptedExecution(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception, boolean oneway)
protected void	logUnexpectedAsyncExecution(RemoteOperationsExecutorProxy proxy, RemoteOperationRequest<?> request, Exception exception)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.gigaspaces.internal.remoting.routing.RemoteOperationRouter

close, createFutureListener, execute, executeAsync, executeOneway, getAllAvailableMembers, getAnyActiveMember, getAnyAvailableCachedMember, getAnyAvailableMember

Field Details

_logger

protected final org.slf4j.Logger _logger

Constructor Details

AbstractRemoteOperationRouter

public AbstractRemoteOperationRouter(String name)

Method Details

logBeforeExecute

protected void logBeforeExecute(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 boolean oneway)

logBeforeExecuteAsync

protected void logBeforeExecuteAsync(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request)

logAfterExecute

protected void logAfterExecute(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 RemoteOperationResult result,
 boolean oneway)

logAfterExecuteAsync

protected void logAfterExecuteAsync(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 RemoteOperationResult result)

logExecutionFailure

protected void logExecutionFailure(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 Exception exception,
 boolean oneway)

logAsyncExecutionFailure

protected void logAsyncExecutionFailure(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 Exception exception)

logInterruptedExecution

protected void logInterruptedExecution(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 Exception exception,
 boolean oneway)

logInterruptedAsyncExecution

protected void logInterruptedAsyncExecution(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 Exception exception)

logUnexpectedAsyncExecution

protected void logUnexpectedAsyncExecution(RemoteOperationsExecutorProxy proxy,
 RemoteOperationRequest<?> request,
 Exception exception)

getCachedMember

public RemoteOperationsExecutorProxy getCachedMember()

Specified by:

getCachedMember in interface RemoteOperationRouter