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 and Description
protected org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor and Description
AbstractRemoteOperationRouter(String name)

Method Summary

Modifier and Type	Method and 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, getAnyAvailableMember

Field Detail

_logger

protected final org.slf4j.Logger _logger

Constructor Detail

AbstractRemoteOperationRouter

public AbstractRemoteOperationRouter(String name)

Method Detail

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