Package jadex.bridge.service.component.multiinvoke

Class SequentialMultiplexDistributor

java.lang.Object

jadex.bridge.service.component.multiinvoke.SimpleMultiplexDistributor

jadex.bridge.service.component.multiinvoke.SequentialMultiplexDistributor

All Implemented Interfaces:

IMultiplexDistributor

public class SequentialMultiplexDistributor
extends SimpleMultiplexDistributor

Sequential call distributor. It determines: - which services are called: services are called as long as arguments are available - with which arguments: each argument array once - when finished: after all arguments have been used

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.List<IService>	busyservices	The list of busy services.
protected java.util.List<IService>	freeservices	The list of free services.
protected java.util.Iterator<java.lang.Object[]>	itargs	The arguments.
protected java.util.List<Future<IService>>	waitingcalls	The waiting for service calls.

Fields inherited from class jadex.bridge.service.component.multiinvoke.SimpleMultiplexDistributor

args, conv, filter, method, results

Constructor Summary

Constructors

Constructor	Description
SequentialMultiplexDistributor()

Method Summary

Modifier and Type	Method	Description
void	addService(IService service)	Add a new service.
void	checkPerformCall(IService service)	Check perform call.
protected void	freeService(IService service)
protected java.util.Iterator<java.lang.Object[]>	getArgumentIterator()	Get the argument iterator.
java.lang.Object[]	getArguments()	Get the arguments for a call.
protected IFuture<IService>	getFreeService(IService service)	Get the service for a call.
boolean	hasArguments()	Test if has arguments.
IIntermediateFuture<java.lang.Object>	init(java.lang.reflect.Method method, java.lang.Object[] args, IFilter<Tuple2<IService,java.lang.Object[]>> filter, IParameterConverter conv)	Start the distributor.
void	serviceSearchFinished()	Notify that the search has finished.

Methods inherited from class jadex.bridge.service.component.multiinvoke.SimpleMultiplexDistributor

performCall

Methods inherited from class java.lang.Object

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

Field Detail

itargs

protected java.util.Iterator<java.lang.Object[]> itargs

The arguments.

freeservices

protected java.util.List<IService> freeservices

The list of free services.

busyservices

protected java.util.List<IService> busyservices

The list of busy services.

waitingcalls

protected java.util.List<Future<IService>> waitingcalls

The waiting for service calls.

Constructor Detail

SequentialMultiplexDistributor

public SequentialMultiplexDistributor()

Method Detail

init

public IIntermediateFuture<java.lang.Object> init(java.lang.reflect.Method method,
                                                  java.lang.Object[] args,
                                                  IFilter<Tuple2<IService,java.lang.Object[]>> filter,
                                                  IParameterConverter conv)

Start the distributor.

Specified by:

init in interface IMultiplexDistributor

Overrides:

init in class SimpleMultiplexDistributor

addService

public void addService(IService service)

Add a new service.

Specified by:

addService in interface IMultiplexDistributor

Overrides:

addService in class SimpleMultiplexDistributor

Parameters:

service - The service.

serviceSearchFinished

public void serviceSearchFinished()

Notify that the search has finished.

Specified by:

serviceSearchFinished in interface IMultiplexDistributor

Overrides:

serviceSearchFinished in class SimpleMultiplexDistributor

getArgumentIterator

protected java.util.Iterator<java.lang.Object[]> getArgumentIterator()

Get the argument iterator.

getArguments

public java.lang.Object[] getArguments()

Get the arguments for a call.

Overrides:

getArguments in class SimpleMultiplexDistributor

Returns:

The arguments.

hasArguments

public boolean hasArguments()

Test if has arguments.

Returns:

True if has args.

getFreeService

protected IFuture<IService> getFreeService(IService service)

Get the service for a call.

Returns:

The service.

freeService

protected void freeService(IService service)

checkPerformCall

public void checkPerformCall(IService service)

Check perform call.

Overrides:

checkPerformCall in class SimpleMultiplexDistributor