A B C D E F G H I L M N O P R S T U V W

A

abortCall(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.FlippingServiceUnavailableByConfigurationInterceptor

abortCall(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableByConfigurationInterceptor

abortCall(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableByPropertyInterceptor

abortCall(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableInterceptor

Returns true if current call should be aborted.

abortNow(Exception) - Static method in class org.distributeme.core.interceptor.InterceptorResponse

Factory method to create a ready to use response.

AbstractCallContext - Class in org.distributeme.core

Base class for client/server call contextes.

AbstractCallContext(String) - Constructor for class org.distributeme.core.AbstractCallContext

AbstractCallContext(String, String, List<?>) - Constructor for class org.distributeme.core.AbstractCallContext

AbstractClientSideRequestInterceptor - Class in org.distributeme.core.interceptor

Base, doing nothing, implementation of the ServerSideRequestInterceptor meant for extension.

AbstractClientSideRequestInterceptor() - Constructor for class org.distributeme.core.interceptor.AbstractClientSideRequestInterceptor

AbstractConcurrencyControlStrategy - Class in org.distributeme.core.concurrencycontrol

Base implementation of a ConcurrencyControlStrategy which is not doing anything.

AbstractConcurrencyControlStrategy() - Constructor for class org.distributeme.core.concurrencycontrol.AbstractConcurrencyControlStrategy

AbstractParameterBasedModRouterWithFailOverToNextNode - Class in org.distributeme.core.routing

Abstract implementation of MOD strategy router which supports FailOver to next cluster node - strategy.

AbstractParameterBasedModRouterWithFailOverToNextNode() - Constructor for class org.distributeme.core.routing.AbstractParameterBasedModRouterWithFailOverToNextNode

AbstractRequestInterceptor - Class in org.distributeme.core.interceptor

Base class offered for extension which provides default implementations for all interception methods.

AbstractRequestInterceptor() - Constructor for class org.distributeme.core.interceptor.AbstractRequestInterceptor

AbstractRouterWithFailOverToNextNode - Class in org.distributeme.core.routing

Abstract implementation of Router which supports FailingStrategy.

AbstractRouterWithFailOverToNextNode() - Constructor for class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Constructor.

AbstractRouterWithFailOverToNextNode.RouterStrategy - Enum in org.distributeme.core.routing

Returns type of strategy - on which current router works.

AbstractServerSideRequestInterceptor - Class in org.distributeme.core.interceptor

Base, doing nothing, implementation of the ClientSideRequestInterceptor meant for extension.

AbstractServerSideRequestInterceptor() - Constructor for class org.distributeme.core.interceptor.AbstractServerSideRequestInterceptor

addInterceptor(String, String) - Method in class org.distributeme.core.interceptor.InterceptorRegistry.Config

addInterceptor(String, String) - Method in class org.distributeme.core.listener.ListenerRegistry.Config

addModRoutedMethod(String, int) - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Allow to add some custom method with some name and modable parameter position to mod method registry.

addModRoutedMethod(String) - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Allow to add some custom method with some name using default 0 modable parameter position.

afterServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractRequestInterceptor

afterServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractServerSideRequestInterceptor

afterServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptor

afterServantCall(ServerSideCallContext, InterceptionContext) - Method in interface org.distributeme.core.interceptor.ServerSideRequestInterceptor

Called after the service actually processed the request.

afterServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.SinglePhaseInterceptor

afterServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractClientSideRequestInterceptor

afterServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractRequestInterceptor

afterServiceCall(ClientSideCallContext, InterceptionContext) - Method in interface org.distributeme.core.interceptor.ClientSideRequestInterceptor

Called immediately after service call, but before anything is returned to the caller.

afterServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptor

afterServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.SinglePhaseInterceptor

afterStart() - Method in interface org.distributeme.core.listener.ServerLifecycleListener

Called immediately after start and registration.

afterStart() - Method in class org.distributeme.core.listener.ServerLifecycleSysOutPrinterListener

APP - Static variable in class org.distributeme.core.RegistryUtil

Name of the registry's webapplication.

APP - Static variable in class org.distributeme.core.util.EventServiceRegistryUtil

Web-Application name.

AsynchStub - Interface in org.distributeme.core.asynch

General interface all asynch stubs implement.

B

BaseRegistryUtil - Class in org.distributeme.core.util

Base class for registry utilities.

BaseRegistryUtil() - Constructor for class org.distributeme.core.util.BaseRegistryUtil

beforeServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractRequestInterceptor

beforeServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractServerSideRequestInterceptor

beforeServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownInterceptor

beforeServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptor

beforeServantCall(ServerSideCallContext, InterceptionContext) - Method in interface org.distributeme.core.interceptor.ServerSideRequestInterceptor

Called before any real processing happens on the server side.

beforeServantCall(ServerSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.SinglePhaseInterceptor

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractClientSideRequestInterceptor

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.AbstractRequestInterceptor

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownInterceptor

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableInterceptor

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in interface org.distributeme.core.interceptor.ClientSideRequestInterceptor

Called after client side processing but before the actual call is performed.

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptor

beforeServiceCall(ClientSideCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.SinglePhaseInterceptor

beforeShutdown() - Method in interface org.distributeme.core.listener.ServerLifecycleListener

Called immediately before service stops, in the shutdown hook.

beforeShutdown() - Method in class org.distributeme.core.listener.ServerLifecycleSysOutPrinterListener

bind(ServiceDescriptor) - Static method in class org.distributeme.core.RegistryUtil

Binds a service.

C

CallBackHandler - Interface in org.distributeme.core.asynch

This interface describes objects that are submitted to the asynch call methods.

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.DefaultFailingStrategy

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.FailCall

callFailed(ClientSideCallContext) - Method in interface org.distributeme.core.failing.FailingStrategy

What should happen if a call is failed.

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.Failover

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.FailoverAndReturn

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.RetryCall

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.RetryCallOnce

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.failing.WaitOneSecondAndRetry

callFailed(ClientSideCallContext) - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

CallTimeoutedException - Exception in org.distributeme.core.asynch

This exception is thrown whenever a call is aborted due timeout.

CallTimeoutedException() - Constructor for exception org.distributeme.core.asynch.CallTimeoutedException

Default constructor.

changeServiceId(String) - Method in class org.distributeme.core.ServiceDescriptor

Changes the service id in the descriptor to another id.

ClientSideCallContext - Class in org.distributeme.core

This class represents a collection of infos available on the client side in the stub and stub-related code.

ClientSideCallContext(String) - Constructor for class org.distributeme.core.ClientSideCallContext

ClientSideCallContext(String, String, List<?>) - Constructor for class org.distributeme.core.ClientSideCallContext

ClientSideRequestInterceptor - Interface in org.distributeme.core.interceptor

Describes the client side request interceptor.

ClientSideSlowDownByConfigurationInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This slow down interceptor is acting on client side and configured by availabilitytesting.json configuration file.

ClientSideSlowDownByConfigurationInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownByConfigurationInterceptor

ClientSideSlowDownByPropertyInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor slows down a server if the service id is submitted to the process as -DavailabilityTestingServiceId.

ClientSideSlowDownByPropertyInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownByPropertyInterceptor

ClientSideSlowDownInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

Base class for client side slow down interceptors.

ClientSideSlowDownInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownInterceptor

ConcurrencyControlException - Exception in org.distributeme.core.concurrencycontrol

Exception thrown if concurrency control decides that the amount of acceptable requests is reached and no further requests can pass through.

ConcurrencyControlException(String) - Constructor for exception org.distributeme.core.concurrencycontrol.ConcurrencyControlException

ConcurrencyControlException(String, Throwable) - Constructor for exception org.distributeme.core.concurrencycontrol.ConcurrencyControlException

ConcurrencyControlStrategy - Interface in org.distributeme.core.concurrencycontrol

This interface allows the customer to control concurrent access to the services.

ConfigurationInterceptorUtil - Class in org.distributeme.core.interceptor.availabilitytesting

Utility to handle availabilitytesting configuration.

ConfigurationInterceptorUtil() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil

ConfigurationInterceptorUtil.ConfigurationObject - Class in org.distributeme.core.interceptor.availabilitytesting

Helper class that holds the config and is re/configured by distributeme.

ConfigurationInterceptorUtil.ConfigurationObject() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

ConstantBasedConcurrencyControlStrategy - Class in org.distributeme.core.concurrencycontrol

This implementation of a concurrencycontrolstrategy is based on constants which are annotated to the target interface.

ConstantBasedConcurrencyControlStrategy() - Constructor for class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

Constants - Class in org.distributeme.core.interceptor.availabilitytesting

Constants for availability testing.

Constants() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.Constants

CONTINUE - Static variable in class org.distributeme.core.interceptor.InterceptorResponse

Default reply variable.

create() - Static method in class org.distributeme.core.RegistryLocation

Creates a new configured registry location.

createLocalServiceDescription(ServiceDescriptor.Protocol, String, String, int) - Static method in class org.distributeme.core.RegistryUtil

createRegistryOperationUrl(String, String) - Static method in class org.distributeme.core.RegistryUtil

Helper methods that creates the url for given operation and parameters.

createRegistryOperationUrl(Location, String, String) - Static method in class org.distributeme.core.RegistryUtil

Helper methods that creates the url for given operation and parameters.

createSubCallHandler(String) - Method in class org.distributeme.core.asynch.MultiCallCollector

customize(String) - Method in class org.distributeme.core.concurrencycontrol.AbstractConcurrencyControlStrategy

customize(String) - Method in interface org.distributeme.core.concurrencycontrol.ConcurrencyControlStrategy

Called shortly after the initialization to customize this strategy according to the parameter in the annotation.

customize(String) - Method in class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

customize(String) - Method in class org.distributeme.core.failing.Failover

customize(String) - Method in class org.distributeme.core.failing.FailoverAndReturn

customize(String) - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

customize(String) - Method in class org.distributeme.core.routing.FairRoundRobinRouter

customize(String) - Method in class org.distributeme.core.routing.NoOpRouter

customize(String) - Method in class org.distributeme.core.routing.ParameterBasedModRouter

customize(String) - Method in class org.distributeme.core.routing.PropertyBasedRegistrationNameProvider

customize(String) - Method in interface org.distributeme.core.routing.RegistrationNameProvider

Called shortly after the initialization to customize this registration name provider according to the parameter in the annotation.

customize(String) - Method in class org.distributeme.core.routing.RoundRobinRouter

customize(String) - Method in interface org.distributeme.core.routing.Router

Called shortly after the initialization to customize this router according to the parameter in the annotation.

customize(String) - Method in class org.distributeme.core.routing.SysOutRouter

D

debug(String, String) - Method in class org.distributeme.core.RegistryUtil.Configurable

debugOut() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

debugOutConfig() - Static method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil

DEFAULT_SLOW_DOWN_TIME - Static variable in class org.distributeme.core.interceptor.availabilitytesting.Constants

Default slow down time.

DefaultFailingStrategy - Class in org.distributeme.core.failing

This failing strategy is used if no other failing strategy is specified.

DefaultFailingStrategy() - Constructor for class org.distributeme.core.failing.DefaultFailingStrategy

Defaults - Class in org.distributeme.core

This class provides methods for runtime overriding of the default behaviour.

Defaults() - Constructor for class org.distributeme.core.Defaults

Defaults.DefaultsConfiguration - Class in org.distributeme.core

Inner configuration holder class.

Defaults.DefaultsConfiguration() - Constructor for class org.distributeme.core.Defaults.DefaultsConfiguration

describeRegistry() - Static method in class org.distributeme.core.RegistryUtil

Returns a string representing current state of the registry.

DiscoveryMode - Enum in org.distributeme.core

Options for service discovery mode.

DistributemeRuntimeException - Exception in org.distributeme.core.exception

Base class for distributeme runtime exceptions.

DistributemeRuntimeException(String) - Constructor for exception org.distributeme.core.exception.DistributemeRuntimeException

DistributemeRuntimeException(String, Throwable) - Constructor for exception org.distributeme.core.exception.DistributemeRuntimeException

E

encode(String) - Static method in class org.distributeme.core.util.BaseRegistryUtil

URLEncodes a string.

equals(Object) - Method in class org.distributeme.core.ServiceDescriptor

error(Exception) - Method in interface org.distributeme.core.asynch.CallBackHandler

Called upon erroneous execution of a method.

error(Exception) - Method in class org.distributeme.core.asynch.MultiCallCollector.SubCallBackHandler

error(Exception) - Method in class org.distributeme.core.asynch.SingleCallHandler

EventServiceRegistryUtil - Class in org.distributeme.core.util

Utility classes for requests to the registry via http.

EventServiceRegistryUtil() - Constructor for class org.distributeme.core.util.EventServiceRegistryUtil

extractServiceIds() - Static method in class org.distributeme.core.interceptor.availabilitytesting.PropertyInterceptorUtil

F

fail() - Static method in class org.distributeme.core.failing.FailDecision

Factory method for fail reaction.

FailCall - Class in org.distributeme.core.failing

This failing strategy simply fails the call and not tries to retry anything.

FailCall() - Constructor for class org.distributeme.core.failing.FailCall

FailDecision - Class in org.distributeme.core.failing

Possible decisions that a failing strategy can make.

FailDecision(FailDecision.Reaction) - Constructor for class org.distributeme.core.failing.FailDecision

Creates a new fail decision with given reaction.

FailDecision(FailDecision.Reaction, String) - Constructor for class org.distributeme.core.failing.FailDecision

Creates a new fail decision with given reaction and target service.

FailDecision.Reaction - Enum in org.distributeme.core.failing

Reaction on failure.

FailingStrategy - Interface in org.distributeme.core.failing

This interface describes a decision utility for reaction on failing.

failingSupported() - Method in class org.distributeme.core.routing.AbstractParameterBasedModRouterWithFailOverToNextNode

failingSupported() - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Allow to turn on and off failing support.

failingSupported() - Method in class org.distributeme.core.routing.RoundRobinRouterWithFailoverToNextNode

Failover - Class in org.distributeme.core.failing

This failing strategy / router combination fails over to a special failover service instance and stays there.

Failover() - Constructor for class org.distributeme.core.failing.Failover

FailoverAndReturn - Class in org.distributeme.core.failing

This is base class for failing strategy / router combination which is pretty much the same as Failover, but instead of staying on the failover instance forever, it tries to switch back after some timeout.

FailoverAndReturn() - Constructor for class org.distributeme.core.failing.FailoverAndReturn

FailoverAndReturnInAMinute - Class in org.distributeme.core.failing

This failing strategy / router combination is pretty much the same as Failover, but instead of staying on the failover instance forever, it tries to switch back after a minute.

FailoverAndReturnInAMinute() - Constructor for class org.distributeme.core.failing.FailoverAndReturnInAMinute

FailoverAndReturnInTenSeconds - Class in org.distributeme.core.failing

This failing strategy / router combination is pretty much the same as Failover, but instead of staying on the failover instance forever, it tries to switch back after 10 seconds.

FailoverAndReturnInTenSeconds() - Constructor for class org.distributeme.core.failing.FailoverAndReturnInTenSeconds

FairRoundRobinRouter - Class in org.distributeme.core.routing

This router sends each call to another instance.

FairRoundRobinRouter() - Constructor for class org.distributeme.core.routing.FairRoundRobinRouter

findOrCreateRegistry() - Static method in class org.distributeme.core.RMIRegistryUtil

Finds or creates a new registry.

flip() - Static method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil

Returns true if this call should be fliped.

flip() - Static method in class org.distributeme.core.interceptor.availabilitytesting.PropertyInterceptorUtil

Returns true if the service should be flipped.

FlippingClientSideSlowDownByConfigurationInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor slows down the request depending on a configured probability (flipping) on the client side.

FlippingClientSideSlowDownByConfigurationInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.FlippingClientSideSlowDownByConfigurationInterceptor

FlippingServerSideSlowDownByConfigurationInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor slows down the request depending on a configured probability (flipping) on the server side.

FlippingServerSideSlowDownByConfigurationInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.FlippingServerSideSlowDownByConfigurationInterceptor

FlippingServiceUnavailableByConfigurationInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor makes the service unavailable depending on a configured probability (flipping) on the client side.

FlippingServiceUnavailableByConfigurationInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.FlippingServiceUnavailableByConfigurationInterceptor

fromRegistrationString(String) - Static method in class org.distributeme.core.ServiceDescriptor

Factory method to create a service descriptor from a registration string (used for bind in the registry).

fromResolveString(String) - Static method in class org.distributeme.core.ServiceDescriptor

Factory method to create a service descriptor from a resolve string (used for lookup in the registry).

fromSystemWideUniqueId(String) - Static method in class org.distributeme.core.ServiceDescriptor

Virtually the same as fromRegistrationString but better named ;-).

G

get() - Method in enum org.distributeme.core.conventions.SystemProperties

Returns the set value.

getAsBoolean() - Method in enum org.distributeme.core.conventions.SystemProperties

Returns the system property value as boolean.

getAsInt() - Method in enum org.distributeme.core.conventions.SystemProperties

Returns the system property value as int.

getAsynchExecutorPoolSize() - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

getAsynchExecutorPoolSize() - Static method in class org.distributeme.core.Defaults

getAsynchFactoryFullClassName(Class<? extends Service>) - Static method in class org.distributeme.core.conventions.SharedNamingUtils

getAsynchRemote(Class<T>) - Static method in class org.distributeme.core.ServiceLocator

Returns a remote instance of a service aka stub.

getCallCount() - Method in class org.distributeme.core.ClientSideCallContext

Returns the context call counter, which means how many attempts to call the server has been made.

getCategory() - Method in enum org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptorStatsProducer

getClientSideRequestInterceptors() - Method in class org.distributeme.core.interceptor.InterceptorRegistry

getCommand() - Method in class org.distributeme.core.interceptor.InterceptorResponse

getCreationTimestamp() - Method in interface org.distributeme.core.lifecycle.ServiceAdapter

Returns the timestamp of the service creation.

getCreationTimestamp() - Method in class org.distributeme.core.lifecycle.ServiceInfo

getCurrentPhase() - Method in class org.distributeme.core.interceptor.InterceptionContext

getDefaultAsynchCallTimeout() - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

getDefaultAsynchCallTimeout() - Static method in class org.distributeme.core.Defaults

getDefaultConcurrencyControlStrategy() - Static method in class org.distributeme.core.Defaults

getDefaultConcurrencyControlStrategyClassName() - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

getDefaultFailingStrategy() - Static method in class org.distributeme.core.Defaults

Returns the default failing strategy.

getDefaultFailingStrategyClassName() - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

getException() - Method in class org.distributeme.core.interceptor.InterceptionContext

getException() - Method in class org.distributeme.core.interceptor.InterceptorResponse

getFailbackTimeout() - Method in class org.distributeme.core.failing.FailoverAndReturn

Returns the time unit in milliseconds between the router retries to get back to original server.

getFailbackTimeout() - Method in class org.distributeme.core.failing.FailoverAndReturnInAMinute

getFailbackTimeout() - Method in class org.distributeme.core.failing.FailoverAndReturnInTenSeconds

getFlipChanceInPercent() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

getGlobalServiceId() - Method in class org.distributeme.core.ServiceDescriptor

getHealth() - Method in class org.distributeme.core.lifecycle.HealthStatus

getHealthStatus() - Method in interface org.distributeme.core.lifecycle.LifecycleAware

Returns the custom health status.

getHealthStatus(String) - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Returns the health status of a given service.

getHealthStatus(String) - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

getHealthStatuses() - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Returns map with health status objects for all contained public services (usually one!).

getHealthStatuses() - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

getHost() - Method in interface org.distributeme.core.Location

Returns the host of the registry.

getHost() - Method in class org.distributeme.core.RegistryLocation

Returns the host.

getHost() - Method in class org.distributeme.core.ServiceDescriptor

getInstance() - Static method in class org.distributeme.core.interceptor.InterceptorRegistry

Returns the singleton instances.

getInstance() - Static method in class org.distributeme.core.listener.ListenerRegistry

Returns the singleton instances.

getInstanceId() - Method in class org.distributeme.core.ServiceDescriptor

getLastAccessTimestamp() - Method in interface org.distributeme.core.lifecycle.ServiceAdapter

Returns the timestamp of the service last update.

getLastAccessTimestamp() - Method in class org.distributeme.core.lifecycle.ServiceInfo

getLocal(Class<T>) - Static method in class org.distributeme.core.ServiceLocator

Returns a local instance of T.

getLocalStore() - Method in class org.distributeme.core.interceptor.InterceptionContext

getLog() - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Simply return configured Logger instance.

getLookupString() - Method in class org.distributeme.core.ServiceDescriptor

getMappings() - Method in class org.distributeme.core.RegistryUtil.Configurable

getMessage() - Method in class org.distributeme.core.lifecycle.HealthStatus

getMethodName() - Method in class org.distributeme.core.AbstractCallContext

getMod() - Method in class org.distributeme.core.routing.ParameterBasedModRouter

getModableValue(Object) - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Return long value for mod calculation.

getModableValue(Object) - Method in class org.distributeme.core.routing.ParameterBasedModRouter

Returns parameter value converted to Long actually.

getModableValue(Object) - Method in class org.distributeme.core.routing.RoundRobinRouterWithFailoverToNextNode

getMonitoredLocal(Class<T>, Class<?>...) - Static method in class org.distributeme.core.ServiceLocator

Returns a moskito-monitored local instance of the requested interface.

getPackageName(Class<? extends Service>) - Static method in class org.distributeme.core.conventions.SharedNamingUtils

Get package name for generated code.

getParameterPosition() - Method in class org.distributeme.core.routing.ParameterBasedModRouter

getParameters() - Method in class org.distributeme.core.AbstractCallContext

getPort() - Method in interface org.distributeme.core.Location

Returns the port of the registry.

getPort() - Method in class org.distributeme.core.RegistryLocation

Returns the port.

getPort() - Method in class org.distributeme.core.ServiceDescriptor

getProducerId() - Method in enum org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptorStatsProducer

getProtocol() - Method in class org.distributeme.core.ServiceDescriptor

getPublicServices() - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Returns a list of all publicly accessable services.

getPublicServices() - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

getReaction() - Method in class org.distributeme.core.failing.FailDecision

getRegistrationName(String) - Method in class org.distributeme.core.failing.Failover

getRegistrationName(String) - Method in class org.distributeme.core.failing.FailoverAndReturn

getRegistrationName(String) - Method in class org.distributeme.core.routing.PropertyBasedRegistrationNameProvider

getRegistrationName(String) - Method in interface org.distributeme.core.routing.RegistrationNameProvider

Returns the registration name for this service instance.

getRegistrationString() - Method in class org.distributeme.core.ServiceDescriptor

getRegistryBaseUrl() - Static method in class org.distributeme.core.RegistryUtil

Get registry url for internal use.

getRegistryBaseUrl(String, int) - Static method in class org.distributeme.core.RegistryUtil

Get registry url for internal use.

getRegistryBaseUrl(String) - Static method in class org.distributeme.core.util.BaseRegistryUtil

Returns the base url of the specified registry application.

getRegistryBaseUrl(String, String, int) - Static method in class org.distributeme.core.util.BaseRegistryUtil

getRegistryBaseUrl() - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

Returns the base url for this registry application.

getRegistryBaseUrl(String, int) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

Returns the base url for this registry application.

getRegistryContainerHost() - Method in class org.distributeme.core.RegistryLocation

getRegistryContainerPort() - Method in class org.distributeme.core.RegistryLocation

getRemote(Class<T>) - Static method in class org.distributeme.core.ServiceLocator

Returns a remote instance of a service aka stub.

getReturnException(String) - Method in class org.distributeme.core.asynch.MultiCallCollector

getReturnException() - Method in class org.distributeme.core.asynch.SingleCallHandler

getReturnValue(String) - Method in class org.distributeme.core.asynch.MultiCallCollector

getReturnValue() - Method in class org.distributeme.core.asynch.SingleCallHandler

getReturnValue() - Method in class org.distributeme.core.interceptor.InterceptionContext

getReturnValue() - Method in class org.distributeme.core.interceptor.InterceptorResponse

getRmiRegistryMaxPort() - Method in class org.distributeme.core.RegistryLocation

getRmiRegistryMinPort() - Method in class org.distributeme.core.RegistryLocation

getRmiRegistryPort() - Static method in class org.distributeme.core.RMIRegistryUtil

getServerLifecycleListeners() - Method in class org.distributeme.core.listener.ListenerRegistry

getServerSideRequestInterceptors() - Method in class org.distributeme.core.interceptor.InterceptorRegistry

getServiceAmount() - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Return amount of services for which routing should be performed.

getServiceId() - Method in class org.distributeme.core.AbstractCallContext

getServiceId() - Method in class org.distributeme.core.lifecycle.ServiceInfo

getServiceId() - Method in class org.distributeme.core.ServiceDescriptor

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.failing.Failover

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.failing.FailoverAndReturn

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.routing.FairRoundRobinRouter

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.routing.NoOpRouter

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.routing.ParameterBasedModRouter

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.routing.RoundRobinRouter

getServiceIdForCall(ClientSideCallContext) - Method in interface org.distributeme.core.routing.Router

Returns the serviceId for this particular call to route to.

getServiceIdForCall(ClientSideCallContext) - Method in class org.distributeme.core.routing.SysOutRouter

getServiceIds() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

getServiceIdsList() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

getServiceInfo(String) - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Collects and returns the info about the specified service.

getServiceInfo(String) - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

getSlowDownTime() - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownByConfigurationInterceptor

getSlowDownTime() - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownByPropertyInterceptor

getSlowDownTime() - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownInterceptor

Returns the amount of time in milliseconds the call should be slowed down.

getSlowDownTime() - Static method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil

getSlowDownTime() - Static method in class org.distributeme.core.interceptor.availabilitytesting.PropertyInterceptorUtil

getSlowDownTime() - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownByConfigurationInterceptor

getSlowDownTime() - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownByPropertyInterceptor

getSlowDownTime() - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownInterceptor

Returns the amount of time in milliseconds the call should be slowed down.

getSlowDownTimeInMillis() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

getStats() - Method in enum org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptorStatsProducer

getStrategy() - Method in class org.distributeme.core.routing.AbstractParameterBasedModRouterWithFailOverToNextNode

getStrategy() - Method in class org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode

Return RouterStrategy - which should be used for current Router implementation.

getStrategy() - Method in class org.distributeme.core.routing.RoundRobinRouterWithFailoverToNextNode

getStubFactoryFullClassName(Class<? extends Service>) - Static method in class org.distributeme.core.conventions.SharedNamingUtils

Get generated remote stub factory name.

getSubsystem() - Method in enum org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptorStatsProducer

getSuffix() - Method in class org.distributeme.core.failing.FailoverAndReturn

getSystemWideUniqueId() - Method in class org.distributeme.core.ServiceDescriptor

getTargetService() - Method in class org.distributeme.core.failing.FailDecision

getTimestamp() - Method in class org.distributeme.core.ServiceDescriptor

getTimeString(long) - Static method in class org.distributeme.core.ServiceDescriptor

getTransportableCallContext() - Method in class org.distributeme.core.AbstractCallContext

getUrlContent(String) - Static method in class org.distributeme.core.util.BaseRegistryUtil

Reads the server reply to an url and returns it as string.

getUrlContent(String, boolean) - Static method in class org.distributeme.core.util.BaseRegistryUtil

getXMLServiceList() - Static method in class org.distributeme.core.RegistryUtil

Returns the list of services as xml-string.

getXMLServiceList(Location) - Static method in class org.distributeme.core.RegistryUtil

Returns the list of services from a specified location.

H

hashCode() - Method in class org.distributeme.core.ServiceDescriptor

Health - Enum in org.distributeme.core.lifecycle

Health state of a service.

HealthStatus - Class in org.distributeme.core.lifecycle

HealthStatus of a service contains of a state and a message.

HealthStatus(Health, String) - Constructor for class org.distributeme.core.lifecycle.HealthStatus

Creates a new health status.

HOST_SEPARATOR - Static variable in class org.distributeme.core.ServiceDescriptor

Separator between host part and interface part in the string representation.

I

increaseCallCount() - Method in class org.distributeme.core.ClientSideCallContext

INSTANCE_SEPARATOR - Static variable in class org.distributeme.core.ServiceDescriptor

Separator between serviceId and instanceId.

InterceptionContext - Class in org.distributeme.core.interceptor

The interception context indicates current progress and phase of the interception and also allows to store some local information to this call.

InterceptionContext() - Constructor for class org.distributeme.core.interceptor.InterceptionContext

InterceptionPhase - Enum in org.distributeme.core.interceptor

Describes various interception phases during a call.

InterceptorRegistry - Class in org.distributeme.core.interceptor

The registry for the interceptors.

InterceptorRegistry.Config - Class in org.distributeme.core.interceptor

Internal configuration holder class.

InterceptorRegistry.Config() - Constructor for class org.distributeme.core.interceptor.InterceptorRegistry.Config

InterceptorResponse - Class in org.distributeme.core.interceptor

Returned by the interceptor as a result of call interception.

InterceptorResponse(InterceptorResponse.InterceptorCommand) - Constructor for class org.distributeme.core.interceptor.InterceptorResponse

InterceptorResponse.InterceptorCommand - Enum in org.distributeme.core.interceptor

The command.

isError(String) - Method in class org.distributeme.core.asynch.MultiCallCollector

isError() - Method in class org.distributeme.core.asynch.SingleCallHandler

isFinished() - Method in class org.distributeme.core.asynch.MultiCallCollector

isFinished() - Method in class org.distributeme.core.asynch.SingleCallHandler

isFirstCall() - Method in class org.distributeme.core.ClientSideCallContext

isOnline() - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Returns true if the service is online.

isOnline() - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

isServiceIdConfiguredByProperty(String) - Static method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil

isServiceIdConfiguredByProperty(String) - Static method in class org.distributeme.core.interceptor.availabilitytesting.PropertyInterceptorUtil

isSet() - Method in enum org.distributeme.core.conventions.SystemProperties

Returns true if the property is set.

isSuccess(String) - Method in class org.distributeme.core.asynch.MultiCallCollector

isSuccess() - Method in class org.distributeme.core.asynch.SingleCallHandler

L

LifecycleAware - Interface in org.distributeme.core.lifecycle

A service can implement this to signal distributeme that it is aware of the lifecycles and wants to be asked about it status.

LifecycleComponent - Interface in org.distributeme.core.lifecycle

Defines an internal component that controls lifecycle of services inside of distributeme distributed vms.

LifecycleComponentImpl - Enum in org.distributeme.core.lifecycle

Implementation of the LifecycleComponent.

list2string(List<ServiceDescriptor>) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

Converts a list of service descriptors to a string.

ListenerRegistry - Class in org.distributeme.core.listener

The registry for the ServerLifecycleListener instances..

ListenerRegistry.Config - Class in org.distributeme.core.listener

Internal configuration holder class.

ListenerRegistry.Config() - Constructor for class org.distributeme.core.listener.ListenerRegistry.Config

Location - Interface in org.distributeme.core

Interface which defines host and port.

logClientSideExceptions() - Static method in class org.distributeme.core.Verbosity

logServerSideExceptions() - Static method in class org.distributeme.core.Verbosity

M

MINUTE - Static variable in class org.distributeme.core.failing.FailoverAndReturn

Minutes in ms.

MoskitoJourneyInterceptor - Class in org.distributeme.core.interceptor.moskito

This interceptor supports moskito journeys over the network, it transmits server side call trace back to the client.

MoskitoJourneyInterceptor() - Constructor for class org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptor

MoskitoJourneyInterceptorStatsProducer - Enum in org.distributeme.core.interceptor.moskito

This producer is a dummy class that is used for grouping of requests in journey analyzes.

MultiCallCollector - Class in org.distributeme.core.asynch

A helper class to synchronously execute multiple asynchronous calls and collect results.

MultiCallCollector(int) - Constructor for class org.distributeme.core.asynch.MultiCallCollector

MultiCallCollector.SubCallBackHandler - Class in org.distributeme.core.asynch

An instance of this class is used as a call handler for each subcall.

MultiCallCollector.SubCallBackHandler(MultiCallCollector) - Constructor for class org.distributeme.core.asynch.MultiCallCollector.SubCallBackHandler

Creates a new subcallbackhandler.

N

NoConnectionToServerException - Exception in org.distributeme.core.exception

Exception that is used internally to signalize that a connection to the server couldn't be established.

NoConnectionToServerException(String) - Constructor for exception org.distributeme.core.exception.NoConnectionToServerException

NoConnectionToServerException(String, Exception) - Constructor for exception org.distributeme.core.exception.NoConnectionToServerException

NoOpRouter - Class in org.distributeme.core.routing

This router implementation does mostly nothing.

NoOpRouter() - Constructor for class org.distributeme.core.routing.NoOpRouter

notifyBind(Location, ServiceDescriptor) - Static method in class org.distributeme.core.RegistryUtil

notifyClientSideCallFinished(ClientSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.AbstractConcurrencyControlStrategy

notifyClientSideCallFinished(ClientSideCallContext) - Method in interface org.distributeme.core.concurrencycontrol.ConcurrencyControlStrategy

Called by the stub after the call is finished.

notifyClientSideCallFinished(ClientSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

notifyClientSideCallStarted(ClientSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.AbstractConcurrencyControlStrategy

notifyClientSideCallStarted(ClientSideCallContext) - Method in interface org.distributeme.core.concurrencycontrol.ConcurrencyControlStrategy

Called by the stub before the call is executed.

notifyClientSideCallStarted(ClientSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

notifyConsumerNotAvailable(ServiceDescriptor) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

notifyNotAvailable(EventServiceRegistryUtil.Target, ServiceDescriptor) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

Offers a possibility to mark a descriptor as unavailable.

notifyServerSideCallFinished(ServerSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.AbstractConcurrencyControlStrategy

notifyServerSideCallFinished(ServerSideCallContext) - Method in interface org.distributeme.core.concurrencycontrol.ConcurrencyControlStrategy

Called by the skeleton after the call is finished.

notifyServerSideCallFinished(ServerSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

notifyServerSideCallStarted(ServerSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.AbstractConcurrencyControlStrategy

notifyServerSideCallStarted(ServerSideCallContext) - Method in interface org.distributeme.core.concurrencycontrol.ConcurrencyControlStrategy

Called by the skeleton before the call is executed.

notifyServerSideCallStarted(ServerSideCallContext) - Method in class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

notifySubCallFinished() - Method in class org.distributeme.core.asynch.MultiCallCollector

notifySupplierNotAvailable(ServiceDescriptor) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

notifyUnbind(Location, ServiceDescriptor) - Static method in class org.distributeme.core.RegistryUtil

O

OK() - Static method in class org.distributeme.core.lifecycle.HealthStatus

Factory method for default status OK.

org.distributeme.core - package org.distributeme.core

org.distributeme.core.asynch - package org.distributeme.core.asynch

org.distributeme.core.concurrencycontrol - package org.distributeme.core.concurrencycontrol

org.distributeme.core.conventions - package org.distributeme.core.conventions

This package contains conventions used across distributeme submodules.

org.distributeme.core.exception - package org.distributeme.core.exception

org.distributeme.core.failing - package org.distributeme.core.failing

org.distributeme.core.interceptor - package org.distributeme.core.interceptor

Support for client and server side interceptors of calls.

org.distributeme.core.interceptor.availabilitytesting - package org.distributeme.core.interceptor.availabilitytesting

Contains set of interceptors for availability testing of services.

org.distributeme.core.interceptor.moskito - package org.distributeme.core.interceptor.moskito

Contains set of interceptors for moskito support.

org.distributeme.core.lifecycle - package org.distributeme.core.lifecycle

Contains lifecycle management.

org.distributeme.core.listener - package org.distributeme.core.listener

Provides service lifecycle listening capabilities.

org.distributeme.core.routing - package org.distributeme.core.routing

org.distributeme.core.util - package org.distributeme.core.util

OutgoingRequestRefusedException - Exception in org.distributeme.core.concurrencycontrol

This exception is thrown by the stub if client side concurrency control prohibits further outgoing connections to the server.

OutgoingRequestRefusedException() - Constructor for exception org.distributeme.core.concurrencycontrol.OutgoingRequestRefusedException

P

PARAM_ID - Static variable in class org.distributeme.core.RegistryUtil

Value for the parameter name for the id-param.

ParameterBasedModRouter - Class in org.distributeme.core.routing

This router is based on numeric parameters and their mod value.

ParameterBasedModRouter() - Constructor for class org.distributeme.core.routing.ParameterBasedModRouter

parseTimeString(String) - Static method in class org.distributeme.core.ServiceDescriptor

ping(Location) - Static method in class org.distributeme.core.RegistryUtil

Pings a location.

PORT_SEPARATOR - Static variable in class org.distributeme.core.ServiceDescriptor

Separator between host and port.

PREFIX - Static variable in class org.distributeme.core.SystemPropertyNames

This is the prefix for all parameters.

printStatusToLogInfo() - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Logs a standard message to info.

printStatusToLogInfo() - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

printStatusToSystemOut() - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Prints a standard message to system out.

printStatusToSystemOut() - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

processPhase(AbstractCallContext, InterceptionContext) - Method in class org.distributeme.core.interceptor.SinglePhaseInterceptor

PROPERTY_FLIP_CHANCE_IN_PERCENT - Static variable in class org.distributeme.core.interceptor.availabilitytesting.Constants

Name of the property that specifies flip chance.

PROPERTY_SERVICE_ID - Static variable in class org.distributeme.core.interceptor.availabilitytesting.Constants

Name of the service id system property.

PROPERTY_SLOWDOWN_TIME_IN_MILLIS - Static variable in class org.distributeme.core.interceptor.availabilitytesting.Constants

Name of the property that specifies slowdowntime in milliseconds.

PropertyBasedRegistrationNameProvider - Class in org.distributeme.core.routing

This registration name provider is based on a submitted property to the start.

PropertyBasedRegistrationNameProvider() - Constructor for class org.distributeme.core.routing.PropertyBasedRegistrationNameProvider

PropertyInterceptorUtil - Class in org.distributeme.core.interceptor.availabilitytesting

Utility to handle availabilitytesting properties..

PropertyInterceptorUtil() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.PropertyInterceptorUtil

PROTOCOL_SEPARATOR - Static variable in class org.distributeme.core.ServiceDescriptor

Separator between protocol part of the descriptor and the rest of the descriptor.

R

reconfigure() - Method in class org.distributeme.core.interceptor.InterceptorRegistry.Config

reconfigure() - Method in class org.distributeme.core.listener.ListenerRegistry.Config

registerAtRegistryAs(String, EventServiceRegistryUtil.Target, ServiceDescriptor) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

registerConsumerAtRegistryAndGetSuppliers(String, ServiceDescriptor) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

registerPublicService(String, ServiceAdapter) - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Registers a service locally running service instance.

registerPublicService(String, ServiceAdapter) - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

registerSupplierAtRegistryAndGetConsumers(String, ServiceDescriptor) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

REGISTRATION_NAME_PROVIDER - Static variable in class org.distributeme.core.SystemPropertyNames

Registration name provider allows to customize the registration name of the instance.

RegistrationNameProvider - Interface in org.distributeme.core.routing

Describes a registration name provider which defines the name useable for registration.

RegistryLocation - Class in org.distributeme.core

Configurable location object.

registryLocation - Static variable in class org.distributeme.core.util.BaseRegistryUtil

Location config object.

RegistryUtil - Class in org.distributeme.core

Utilities for communication with the registry over http protocol.

RegistryUtil() - Constructor for class org.distributeme.core.RegistryUtil

RegistryUtil.Configurable - Class in org.distributeme.core

Inner configuration holder class.

RegistryUtil.Configurable() - Constructor for class org.distributeme.core.RegistryUtil.Configurable

resolve(ServiceDescriptor, Location) - Static method in class org.distributeme.core.RegistryUtil

Resolves a service descriptor at a specified location.

resolve(ServiceDescriptor) - Static method in class org.distributeme.core.RegistryUtil

Resolves a service request.

retry() - Static method in class org.distributeme.core.failing.FailDecision

Factory method for retry reaction.

RetryCall - Class in org.distributeme.core.failing

This failing strategy always retries the call.

RetryCall() - Constructor for class org.distributeme.core.failing.RetryCall

RetryCallOnce - Class in org.distributeme.core.failing

This failing strategy only retries the call once.

RetryCallOnce() - Constructor for class org.distributeme.core.failing.RetryCallOnce

retryOnce() - Static method in class org.distributeme.core.failing.FailDecision

Factory method for retryOnce reaction.

returnLater(Object) - Static method in class org.distributeme.core.interceptor.InterceptorResponse

Factory method to create a ready to use response.

returnNow(Object) - Static method in class org.distributeme.core.interceptor.InterceptorResponse

Factory method to create a ready to use response.

RMIRegistryUtil - Class in org.distributeme.core

Utils for handling the RMIRegistry object.

RMIRegistryUtil() - Constructor for class org.distributeme.core.RMIRegistryUtil

RoundRobinRouter - Class in org.distributeme.core.routing

This router sends each call to another instance.

RoundRobinRouter() - Constructor for class org.distributeme.core.routing.RoundRobinRouter

RoundRobinRouterWithFailoverToNextNode - Class in org.distributeme.core.routing

This router sends each call to another instance.

RoundRobinRouterWithFailoverToNextNode() - Constructor for class org.distributeme.core.routing.RoundRobinRouterWithFailoverToNextNode

Router - Interface in org.distributeme.core.routing

This interface defines a call router, which influences how calls are distributed to different servers in the same system.

run() - Method in class org.distributeme.core.listener.ServerLifecycleListenerShutdownHook

run() - Method in class org.distributeme.core.ServerShutdownHook

S

SECOND - Static variable in class org.distributeme.core.failing.FailoverAndReturn

Seconds in ms.

ServerLifecycleListener - Interface in org.distributeme.core.listener

This listener allows to perform operations dependent on the lifecycle of a distributeme component.

ServerLifecycleListenerShutdownHook - Class in org.distributeme.core.listener

A shutdown hook that unregisters a service upon jvm exit.

ServerLifecycleListenerShutdownHook(List<ServerLifecycleListener>) - Constructor for class org.distributeme.core.listener.ServerLifecycleListenerShutdownHook

ServerLifecycleSysOutPrinterListener - Class in org.distributeme.core.listener

The ServerLifecycleSysOutPrinterListener simply prints out START and END messages to the stdout.

ServerLifecycleSysOutPrinterListener() - Constructor for class org.distributeme.core.listener.ServerLifecycleSysOutPrinterListener

ServerRefusedRequestException - Exception in org.distributeme.core.concurrencycontrol

This exception is thrown if a server refuses to accept more incoming requests.

ServerRefusedRequestException() - Constructor for exception org.distributeme.core.concurrencycontrol.ServerRefusedRequestException

ServerRefusedRequestException(int) - Constructor for exception org.distributeme.core.concurrencycontrol.ServerRefusedRequestException

ServerShutdownHook - Class in org.distributeme.core

A shutdown hook that unregisters a service upon jvm exit.

ServerShutdownHook(ServiceDescriptor) - Constructor for class org.distributeme.core.ServerShutdownHook

ServerSideCallContext - Class in org.distributeme.core

Contains all required infromation in the context of the current call on the server side.

ServerSideCallContext(String, Map<?, ?>) - Constructor for class org.distributeme.core.ServerSideCallContext

ServerSideRequestInterceptor - Interface in org.distributeme.core.interceptor

This interceptor describes an interface that is acting on the server side.

ServerSideSlowDownByConfigurationInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This slow down interceptor is acting on server side and configured by availabilitytesting.json configuration file.

ServerSideSlowDownByConfigurationInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownByConfigurationInterceptor

ServerSideSlowDownByPropertyInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor slows down a server if the service id is submitted to the process as -DavailabilityTestingServiceId.

ServerSideSlowDownByPropertyInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownByPropertyInterceptor

ServerSideSlowDownInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

Base class for service side slow down interceptors.

ServerSideSlowDownInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownInterceptor

ServiceAdapter - Interface in org.distributeme.core.lifecycle

Interface that is implemented by the generated skeletons and that provide additional information about services.

ServiceDescriptor - Class in org.distributeme.core

This class represents a resolvable address of a service.

ServiceDescriptor(ServiceDescriptor.Protocol, String, String, String, int) - Constructor for class org.distributeme.core.ServiceDescriptor

This constructor is used for registration.

ServiceDescriptor(ServiceDescriptor.Protocol, String, String, String, int, long) - Constructor for class org.distributeme.core.ServiceDescriptor

ServiceDescriptor(ServiceDescriptor.Protocol, String) - Constructor for class org.distributeme.core.ServiceDescriptor

This constructor is used for the lookup.

ServiceDescriptor.Protocol - Enum in org.distributeme.core

Supported protocols.

ServiceInfo - Class in org.distributeme.core.lifecycle

This class contains information about a service.

ServiceInfo() - Constructor for class org.distributeme.core.lifecycle.ServiceInfo

ServiceLocator - Class in org.distributeme.core

A utility for convenient lookup of implementations for interfaces.

ServiceLocator() - Constructor for class org.distributeme.core.ServiceLocator

ServiceUnavailableByConfigurationInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor marks service unavailable and is configured by availabilitytesting.json configuration file.

ServiceUnavailableByConfigurationInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableByConfigurationInterceptor

ServiceUnavailableByPropertyInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

This interceptor marks service unavailable and is configured by system properties.

ServiceUnavailableByPropertyInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableByPropertyInterceptor

ServiceUnavailableException - Exception in org.distributeme.core.exception

Thrown if no connection to a remote service could be established.

ServiceUnavailableException(String) - Constructor for exception org.distributeme.core.exception.ServiceUnavailableException

Creates new instance of the exception.

ServiceUnavailableException(String, Exception) - Constructor for exception org.distributeme.core.exception.ServiceUnavailableException

Creates new instance of the exception.

ServiceUnavailableInterceptor - Class in org.distributeme.core.interceptor.availabilitytesting

Base interceptor class for service unavailable interceptors.

ServiceUnavailableInterceptor() - Constructor for class org.distributeme.core.interceptor.availabilitytesting.ServiceUnavailableInterceptor

setAsynchExecutorPoolSize(int) - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

setCallCount(int) - Method in class org.distributeme.core.ClientSideCallContext

setCreationTimestamp(long) - Method in class org.distributeme.core.lifecycle.ServiceInfo

setCurrentPhase(InterceptionPhase) - Method in class org.distributeme.core.interceptor.InterceptionContext

setDefaultAsynchCallTimeout(long) - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

setDefaultConcurrencyControlStrategyClassName(String) - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

setDefaultFailingStrategyClassName(String) - Method in class org.distributeme.core.Defaults.DefaultsConfiguration

setException(Exception) - Method in class org.distributeme.core.interceptor.InterceptionContext

setFlipChanceInPercent(int) - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

setHelper() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

setIncomingTransportableCallContext(Map) - Method in class org.distributeme.core.AbstractCallContext

setInterceptors(String[]) - Method in class org.distributeme.core.interceptor.InterceptorRegistry.Config

setLastAccessTimestamp(long) - Method in class org.distributeme.core.lifecycle.ServiceInfo

setLogClientSideExceptions(boolean) - Method in class org.distributeme.core.Verbosity

setLogServerSideExceptions(boolean) - Method in class org.distributeme.core.Verbosity

setMethodName(String) - Method in class org.distributeme.core.AbstractCallContext

setParameters(List) - Method in class org.distributeme.core.AbstractCallContext

setRegistrationIpMapping(String) - Method in class org.distributeme.core.RegistryUtil.Configurable

setRegistryContainerHost(String) - Method in class org.distributeme.core.RegistryLocation

setRegistryContainerPort(int) - Method in class org.distributeme.core.RegistryLocation

setReturnValue(Object) - Method in class org.distributeme.core.interceptor.InterceptionContext

setRmiRegistryMaxPort(int) - Method in class org.distributeme.core.RegistryLocation

setRmiRegistryMinPort(int) - Method in class org.distributeme.core.RegistryLocation

setServiceId(String) - Method in class org.distributeme.core.AbstractCallContext

setServiceId(String) - Method in class org.distributeme.core.lifecycle.ServiceInfo

setServiceIds(String[]) - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

setSlowDownTimeInMillis(long) - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

setTargetService(String) - Method in class org.distributeme.core.failing.FailDecision

SharedNamingUtils - Class in org.distributeme.core.conventions

Utils for conventions like naming.

SharedNamingUtils() - Constructor for class org.distributeme.core.conventions.SharedNamingUtils

shutdown() - Method in interface org.distributeme.core.asynch.AsynchStub

Shutdowns the internal thread pool.

shutdown(String) - Method in interface org.distributeme.core.lifecycle.LifecycleComponent

Shutdowns the current VM and logs the message.

shutdown(String) - Method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

SingleCallHandler - Class in org.distributeme.core.asynch

This is a callhandler implementation which is used in generated asynchronous stubs.

SingleCallHandler() - Constructor for class org.distributeme.core.asynch.SingleCallHandler

SinglePhaseInterceptor - Class in org.distributeme.core.interceptor

This interceptor can be configured to use one or multiple phases, but doesn't need to support all phases.

SinglePhaseInterceptor(InterceptionPhase, InterceptionPhase...) - Constructor for class org.distributeme.core.interceptor.SinglePhaseInterceptor

slowDown(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownByConfigurationInterceptor

slowDown(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownByPropertyInterceptor

slowDown(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ClientSideSlowDownInterceptor

Returns true if current call should be slowed down.

slowDown(ClientSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.FlippingClientSideSlowDownByConfigurationInterceptor

slowDown(ServerSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.FlippingServerSideSlowDownByConfigurationInterceptor

slowDown(ServerSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownByConfigurationInterceptor

slowDown(ServerSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownByPropertyInterceptor

slowDown(ServerSideCallContext) - Method in class org.distributeme.core.interceptor.availabilitytesting.ServerSideSlowDownInterceptor

Returns true if current call should be slowed down.

string2list(String) - Static method in class org.distributeme.core.util.EventServiceRegistryUtil

Converts a list of string representations of service descriptors to a list of ServiceDescriptor objects.

success(Object) - Method in interface org.distributeme.core.asynch.CallBackHandler

Called upon successful execution of a method.

success(Object) - Method in class org.distributeme.core.asynch.MultiCallCollector.SubCallBackHandler

success(Object) - Method in class org.distributeme.core.asynch.SingleCallHandler

SUFFIX - Static variable in class org.distributeme.core.failing.Failover

Suffix of the failover instance.

SUFFIX - Static variable in class org.distributeme.core.failing.FailoverAndReturn

Suffix of the failover instance.

SysOutRouter - Class in org.distributeme.core.routing

This is an example implementation of a Router which actually do not route anything but simply prints out each call.

SysOutRouter() - Constructor for class org.distributeme.core.routing.SysOutRouter

SystemProperties - Enum in org.distributeme.core.conventions

Helper class for accessing and accounting for supported system properties.

SystemPropertyNames - Class in org.distributeme.core

Constants class for holding constants used for transmission of parameters to VM that distributeme understands.

SystemPropertyNames() - Constructor for class org.distributeme.core.SystemPropertyNames

T

TIMESTAMP_SEPARATOR - Static variable in class org.distributeme.core.ServiceDescriptor

Separator between port and startup timestamp.

toString() - Method in class org.distributeme.core.AbstractCallContext

toString() - Method in class org.distributeme.core.ClientSideCallContext

toString() - Method in class org.distributeme.core.concurrencycontrol.ConstantBasedConcurrencyControlStrategy

toString() - Method in class org.distributeme.core.interceptor.availabilitytesting.ConfigurationInterceptorUtil.ConfigurationObject

toString() - Method in class org.distributeme.core.interceptor.InterceptorResponse

toString() - Method in class org.distributeme.core.lifecycle.HealthStatus

toString() - Method in class org.distributeme.core.lifecycle.ServiceInfo

toString() - Method in class org.distributeme.core.RegistryLocation

toString() - Method in class org.distributeme.core.RegistryUtil.Configurable

toString() - Method in class org.distributeme.core.routing.PropertyBasedRegistrationNameProvider

toString() - Method in class org.distributeme.core.ServiceDescriptor

toString() - Method in class org.distributeme.core.util.VoidMarker

toString() - Method in class org.distributeme.core.Verbosity

toWeb() - Method in enum org.distributeme.core.conventions.WebOperations

Returns the presentation of the constant as it's used in the web.

U

unbind(ServiceDescriptor) - Static method in class org.distributeme.core.RegistryUtil

Unbinds a service.

UnlimitedConcurrencyStrategy - Class in org.distributeme.core.concurrencycontrol

This strategy implementation doesn't limit anything and is used as default concurrency control strategy.

UnlimitedConcurrencyStrategy() - Constructor for class org.distributeme.core.concurrencycontrol.UnlimitedConcurrencyStrategy

V

valueOf(String) - Static method in enum org.distributeme.core.conventions.SystemProperties

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.conventions.WebOperations

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.DiscoveryMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.failing.FailDecision.Reaction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.interceptor.InterceptionPhase

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.interceptor.InterceptorResponse.InterceptorCommand

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptorStatsProducer

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.lifecycle.Health

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode.RouterStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.distributeme.core.ServiceDescriptor.Protocol

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.distributeme.core.conventions.SystemProperties

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.conventions.WebOperations

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.DiscoveryMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.failing.FailDecision.Reaction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.interceptor.InterceptionPhase

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.interceptor.InterceptorResponse.InterceptorCommand

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.interceptor.moskito.MoskitoJourneyInterceptorStatsProducer

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.lifecycle.Health

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.lifecycle.LifecycleComponentImpl

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.routing.AbstractRouterWithFailOverToNextNode.RouterStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.distributeme.core.ServiceDescriptor.Protocol

Returns an array containing the constants of this enum type, in the order they are declared.

Verbosity - Class in org.distributeme.core

Configuration holder class for some output options.

Verbosity() - Constructor for class org.distributeme.core.Verbosity

VOID - Static variable in class org.distributeme.core.util.VoidMarker

Static instance.

VoidMarker - Class in org.distributeme.core.util

This class is used to place void values into the return lists.

W

waitForResults(long) - Method in class org.distributeme.core.asynch.MultiCallCollector

waitForResults() - Method in class org.distributeme.core.asynch.MultiCallCollector

waitForResults(long) - Method in class org.distributeme.core.asynch.SingleCallHandler

waitForResults() - Method in class org.distributeme.core.asynch.SingleCallHandler

WaitOneSecondAndRetry - Class in org.distributeme.core.failing

This call strategy will make one second pause and retry afterwards.

WaitOneSecondAndRetry() - Constructor for class org.distributeme.core.failing.WaitOneSecondAndRetry

WebOperations - Enum in org.distributeme.core.conventions

Defines operations supported by the EventServiceRegistryServlet.

A B C D E F G H I L M N O P R S T U V W