Package | Description |
---|---|
jadex.bdi | |
jadex.bdi.runtime | |
jadex.bdi.runtime.interpreter | |
jadex.bpmn | |
jadex.bpmn.runtime | |
jadex.bridge |
This package contains the interfaces of the adapter layer,
which is used to establish a connection between the Jadex runtime
system and an underlying platform.
|
jadex.bridge.nonfunctional.search | |
jadex.bridge.service.component | |
jadex.bridge.service.component.interceptors | |
jadex.bridge.service.component.multiinvoke | |
jadex.bridge.service.types.factory | |
jadex.commons.future | |
jadex.commons.gui.future | |
jadex.micro |
Modifier and Type | Method and Description |
---|---|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
BDIAgentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo modelinfo,
String config,
Map<String,Object> arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> init)
Create a component instance.
|
Tuple2<IComponentInstance,IComponentAdapter> |
BDIAgentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
OAVAgentModel amodel,
String config,
Map<String,Object> arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> ret)
Create a component instance.
|
Modifier and Type | Method and Description |
---|---|
void |
Plan.resume(Future<?> future)
Resume the execution of the plan.
|
void |
Plan.suspend(Future<?> future,
long timeout)
Suspend the execution of the plan.
|
Constructor and Description |
---|
BDIInterpreter(IComponentDescription desc,
IComponentAdapterFactory factory,
jadex.rules.state.IOAVState state,
OAVAgentModel model,
String config,
Map<String,Object> arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
Map kernelprops,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> inited)
Create an agent interpreter for the given agent.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
BpmnFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo modelinfo,
String config,
Map<String,Object> arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> inited)
Create a component instance.
|
Constructor and Description |
---|
BpmnInterpreter(IComponentDescription desc,
IComponentAdapterFactory factory,
jadex.bpmn.model.MBpmnModel model,
Map<String,Object> arguments,
String config,
IExternalAccess parent,
Map<String,IActivityHandler> activityhandlers,
Map<String,IStepHandler> stephandlers,
IValueFetcher fetcher,
RequiredServiceBinding[] bindings,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> inited)
Create a new bpmn process.
|
Modifier and Type | Method and Description |
---|---|
static <T> Future<?> |
SFuture.getFuture(boolean timeouts,
IInternalAccess ia)
Convenience method for creating a future (possibly with timeout avoidance).
|
static <T> Future<?> |
SFuture.getFuture(Class<T> type,
boolean timeouts,
IExternalAccess ea)
Convenience method for creating a future (possibly with timeout avoidance).
|
static <T> Future<?> |
SFuture.getFuture(Class<T> type,
boolean timeouts,
IInternalAccess ia)
Convenience method for creating a future (possibly with timeout avoidance).
|
static <T> Future<?> |
SFuture.getNoTimeoutFuture(Class<T> type,
IExternalAccess ea)
Convenience method for creating a future (possibly with timeout avoidance).
|
static <T> Future<?> |
SFuture.getNoTimeoutFuture(Class<T> type,
IInternalAccess ia)
Convenience method for creating a future (possibly with timeout avoidance).
|
static <T> Future<?> |
SFuture.getNoTimeoutFuture(IInternalAccess ia)
Convenience method for creating a future (possibly with timeout avoidance).
|
Modifier and Type | Method and Description |
---|---|
static void |
SFuture.avoidCallTimeouts(Future<?> ret,
IExternalAccess ea)
Automatically update the timer of a long running service call future.
|
static void |
SFuture.avoidCallTimeouts(Future<?> ret,
IExternalAccess ea,
long to,
boolean realtime)
Automatically update the timer of a long running service call future.
|
static void |
SFuture.avoidCallTimeouts(Future<?> ret,
IExternalAccess ea,
long to,
double factor,
boolean realtime)
Automatically update the timer of a long running service call future.
|
static void |
SFuture.avoidCallTimeouts(Future<?> ret,
IInternalAccess ia)
Automatically update the timer of a long running service call future.
|
static void |
SFuture.avoidCallTimeouts(Future<?> ret,
IInternalAccess ia,
long to,
boolean realtime)
Automatically update the timer of a long running service call future.
|
static void |
SFuture.avoidCallTimeouts(Future<?> ret,
IInternalAccess ia,
long to,
double factor,
boolean realtime)
Automatically update the timer of a long running service call future.
|
Modifier and Type | Method and Description |
---|---|
Future<Boolean> |
IRankingSearchTerminationDecider.isStartRanking(Collection<S> currentresults,
IServiceEvaluator evaluator)
Decides if the search should terminate and the ranking should start.
|
Future<Boolean> |
CountThresholdSearchTerminationDecider.isStartRanking(Collection<S> currentresults,
IServiceEvaluator evaluator)
Decides if the search should start ranking.
|
Modifier and Type | Method and Description |
---|---|
Future<?> |
ComponentSuspendable.getFuture()
Get the future.
|
Modifier and Type | Method and Description |
---|---|
void |
ComponentSuspendable.resume(Future<?> future)
Resume the execution of the suspendable.
|
void |
ComponentSuspendable.suspend(Future<?> future,
long timeout)
Suspend the execution of the suspendable.
|
Constructor and Description |
---|
DefaultServiceFetcher.StoreDelegationResultListener(Future<T> ret,
IServiceProvider provider,
RequiredServiceInfo info,
RequiredServiceBinding binding)
Create a new listener.
|
Modifier and Type | Method and Description |
---|---|
static Future<?> |
FutureFunctionality.getDelegationFuture(Class<?> clazz,
FutureFunctionality func) |
static Future |
FutureFunctionality.getDelegationFuture(IFuture<?> orig,
FutureFunctionality func) |
Modifier and Type | Method and Description |
---|---|
static void |
FutureFunctionality.connectDelegationFuture(Future target,
IFuture source)
Connect a delegation future with the source.
|
Modifier and Type | Method and Description |
---|---|
void |
IMultiplexCollector.init(Future<Object> fut,
Method method,
Object[] args,
Method muxmethod)
Init the collector.
|
void |
FlattenMultiplexCollector.init(Future<Object> fut,
Method method,
Object[] args,
Method muxmethod)
Init to share code.
|
Constructor and Description |
---|
MultiServiceInvocationHandler.IntermediateMethodResultListener(Future fut,
Method method,
Object[] args,
Method muxmethod)
Create a new listener.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
IComponentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo model,
String config,
Map<String,Object> arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> init)
Create a component instance.
|
Modifier and Type | Class and Description |
---|---|
class |
IntermediateFuture<E>
Default implementation of an intermediate future.
|
class |
PullIntermediateDelegationFuture<E>
Delegation future for pull future.
|
class |
PullIntermediateFuture<E>
Intermediate future that can be terminated from caller side.
|
class |
PullSubscriptionIntermediateDelegationFuture<E>
Delegation future for pull future.
|
class |
PullSubscriptionIntermediateFuture<E>
Intermediate future that can be terminated from caller side.
|
class |
SubscriptionIntermediateDelegationFuture<E> |
class |
SubscriptionIntermediateFuture<E>
Implementation of the subscription intermediate future.
|
class |
TerminableDelegationFuture<E>
A terminable delegation future can be used when a termination future
should be delegated.
|
class |
TerminableFuture<E>
Future that can be terminated from caller side.
|
class |
TerminableIntermediateDelegationFuture<E>
A terminable intermediate delegation future can be used when a termination intermediate future
should be delegated.
|
class |
TerminableIntermediateFuture<E>
Intermediate future that can be terminated from caller side.
|
class |
Tuple2Future<E,F>
Implementation of tuple2 future.
|
Modifier and Type | Field and Description |
---|---|
static ThreadLocal<List<Tuple2<Future<?>,IResultListener<?>>>> |
Future.STACK
Notification stack for unwinding call stack to topmost future.
|
Modifier and Type | Method and Description |
---|---|
static List<Tuple2<Future<?>,IResultListener<?>>> |
FutureHelper.removeStackedListeners()
Remove all collected listener notifications for the current thread.
|
Modifier and Type | Method and Description |
---|---|
void |
FutureFinishChecker.addTask(Future future)
Add a task.
|
void |
ThreadSuspendable.resume(Future<?> future)
Resume the execution of the suspendable.
|
void |
ISuspendable.resume(Future<?> future)
Resume the execution of the suspendable.
|
void |
ThreadSuspendable.suspend(Future<?> future,
long timeout)
Suspend the execution of the suspendable.
|
void |
ISuspendable.suspend(Future<?> future,
long timeout)
Suspend the execution of the suspendable.
|
Modifier and Type | Method and Description |
---|---|
static void |
FutureHelper.addStackedListeners(List<Tuple2<Future<?>,IResultListener<?>>> notifications)
Add listener notifications to the current thread.
|
Constructor and Description |
---|
DelegationResultListener(Future<E> future)
Create a new listener.
|
DelegationResultListener(Future<E> future,
boolean undone)
Create a new listener.
|
ExceptionDelegationResultListener(Future<T> future)
Create a new listener.
|
IntermediateExceptionDelegationResultListener(Future<T> future)
Create a new listener.
|
RemoteDelegationResultListener(Future<E> future)
Create a new listener.
|
Constructor and Description |
---|
SwingDelegationResultListener(Future<E> future)
Create a new listener.
|
SwingExceptionDelegationResultListener(Future<T> future)
Create a new listener.
|
SwingIntermediateExceptionDelegationResultListener(Future<T> future)
Create a new listener.
|
Modifier and Type | Method and Description |
---|---|
Future<?> |
MicroAgentInterpreter.StepInfo.getFuture()
Get the future.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
MicroAgentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo model,
String config,
Map<String,Object> arguments,
IExternalAccess parent,
RequiredServiceBinding[] binding,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> inited)
Create a component instance.
|
void |
MicroAgentInterpreter.StepInfo.setFuture(Future<?> future)
Set the future.
|
Constructor and Description |
---|
IntervalBehavior.StepResultListener(Future<F> ret) |
MicroAgentInterpreter.StepInfo(IComponentStep<?> step,
Future<?> future,
ServiceCall call,
Cause cause)
Create a new StepInfo.
|
MicroAgentInterpreter(IComponentDescription desc,
IComponentAdapterFactory factory,
MicroModel model,
Class<?> microclass,
Map<String,Object> args,
String config,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
boolean realtime,
IIntermediateResultListener<Tuple2<String,Object>> resultlistener,
Future<Void> inited)
Create a new agent.
|
Copyright © 2013. All Rights Reserved.