Package | Description |
---|---|
jadex.bdi | |
jadex.bdi.planlib | |
jadex.bdi.planlib.iasteps | |
jadex.bdi.runtime | |
jadex.bdi.runtime.interpreter | |
jadex.bdibpmn | |
jadex.bdibpmn.task | |
jadex.bpmn | |
jadex.bpmn.runtime | |
jadex.bpmn.runtime.task | |
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.modelinfo | |
jadex.bridge.service | |
jadex.bridge.service.clock | |
jadex.bridge.service.component | |
jadex.bridge.service.component.interceptors | |
jadex.bridge.service.execution | |
jadex.bridge.service.library | |
jadex.bridge.service.threadpool | |
jadex.commons |
This package contains generic utility classes.
|
jadex.commons.concurrent |
This package contains a thread pool implementation.
|
jadex.commons.future | |
jadex.extension.agr | |
jadex.extension.envsupport | |
jadex.extension.envsupport.environment | |
jadex.micro |
Modifier and Type | Method and Description |
---|---|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
BDIAgentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo modelinfo,
String config,
Map arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
Future<Tuple2<IComponentInstance,IComponentAdapter>> ret)
Create a component instance.
|
IFuture<String> |
BDIAgentFactory.getComponentType(String model,
String[] imports,
ClassLoader classloader)
Get the component type of a model.
|
IFuture<Icon> |
BDIAgentFactory.getComponentTypeIcon(String type)
Get a default icon for a file type.
|
IFuture<Boolean> |
BDIAgentFactory.isLoadable(String model,
String[] imports,
ClassLoader classloader)
Test if a model can be loaded by the factory.
|
IFuture<Boolean> |
BDIAgentFactory.isStartable(String model,
String[] imports,
ClassLoader classloader)
Test if a model is startable (e.g. an component).
|
IFuture<IModelInfo> |
BDIAgentFactory.loadModel(String filename,
String[] imports,
ClassLoader classloader)
Load a model.
|
IFuture |
BDIAgentFactory.shutdownService()
Shutdown the service.
|
IFuture |
BDIAgentFactory.startService()
Start the service.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
DefaultBDIViewerPanel.init(jadex.base.gui.plugin.IControlCenter jcc,
IExternalAccess component)
Called once to initialize the panel.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Object[]> |
StepChain.execute(IInternalAccess ia) |
IFuture<Void> |
SetBeliefStep.execute(IInternalAccess ia) |
IFuture<Map<String,Object>> |
DispatchGoalStep.execute(IInternalAccess ia) |
Modifier and Type | Method and Description |
---|---|
IFuture |
ICapability.addComponentListener(IComponentListener listener)
Add an agent listener
|
IFuture |
IBDIExternalAccess.getExternalAccess(String name)
Get external access of subcapability.
|
IFuture |
IBDIExternalAccess.getSubcapabilityNames()
Get subcapability names.
|
IFuture |
ICapability.killAgent()
Kill the agent.
|
IFuture |
ICapability.removeComponentListener(IComponentListener listener)
Add an agent listener
|
IFuture |
IEventbase.sendMessage(IMessageEvent me)
Send a message after some delay.
|
Modifier and Type | Method and Description |
---|---|
void |
Plan.resume(IFuture future)
Resume the execution of the plan.
|
void |
Plan.suspend(IFuture future,
long timeout)
Suspend the execution of the plan.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
BDIInterpreter.addComponentListener(IComponentListener listener)
Add component listener.
|
IFuture |
BDIInterpreter.cleanupComponent()
Request agent to kill itself.
|
IFuture |
BDIInterpreter.componentCreated(IComponentDescription desc,
IModelInfo model)
Called when a component has been created as a subcomponent of this component.
|
IFuture |
BDIInterpreter.componentDestroyed(IComponentDescription desc)
Called when a subcomponent of this component has been destroyed.
|
IFuture |
BDIInterpreter.init(IModelInfo model,
String config)
Extended init procedure including subcapabilities.
|
IFuture |
BDIInterpreter.initArguments(IModelInfo model,
String config,
Map arguments)
Init the arguments and results.
|
static IFuture |
AgentRules.initBelief(jadex.rules.state.IOAVState state,
Object rcapa,
Object mbel,
IValueFetcher fetcher)
Initialize a belief.
|
static IFuture |
AgentRules.initBeliefSet(jadex.rules.state.IOAVState state,
Object rcapa,
Object mbelset,
IValueFetcher fetcher)
Initialize a beliefset.
|
IFuture |
BDIInterpreter.initServices(IModelInfo model,
String config)
Overridden to init BDI internals before services.
|
IFuture |
BDIInterpreter.removeComponentListener(IComponentListener listener)
Remove component listener.
|
IFuture |
BDIInterpreter.scheduleImmediate(IComponentStep step,
Object scope)
Execute some code on the component's thread.
|
IFuture |
BDIInterpreter.scheduleStep(IComponentStep step)
Schedule a step of the component.
|
IFuture |
BDIInterpreter.scheduleStep(Object step,
Object scope)
Schedule a step of the agent.
|
static IFuture |
MessageEventRules.sendMessage(jadex.rules.state.IOAVState state,
Object rcapa,
Object rmessageevent,
byte[] codecids)
Send a message after some delay.
|
IFuture |
BDIInterpreter.startServiceContainer()
Start the services.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
BpmnPlanBodyInstance.addComponentListener(IComponentListener listener)
Add an component listener.
|
IFuture |
BpmnPlanBodyInstance.removeComponentListener(IComponentListener listener)
Remove a component listener.
|
IFuture |
BpmnPlanBodyInstance.scheduleStep(IComponentStep step)
Schedule a step of the agent.
|
IFuture |
BpmnPlanBodyInstance.sendMessage(IMessageEvent me)
Send a message after some delay.
|
IFuture |
BpmnPlanBodyInstance.sendMessage(IMessageEvent me,
byte[] codecids)
Send a message after some delay.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
WaitForSubprocessTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
WaitForSpaceObjectTaskTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
WaitForGoalTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
RemoveSpaceObjectTaskTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
DispatchSubprocessTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
DispatchGoalTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
CreateSpaceObjectTaskTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
WaitForSubprocessTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture |
WaitForSpaceObjectTaskTask.execute(ITaskContext context,
BpmnInterpreter process)
Execute the task.
|
IFuture |
WaitForGoalTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture |
RemoveSpaceObjectTaskTask.execute(ITaskContext context,
BpmnInterpreter process)
Execute the task.
|
IFuture |
DispatchSubprocessTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture |
DispatchGoalTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture |
CreateSpaceObjectTaskTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
BpmnFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo modelinfo,
String config,
Map arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
Future<Tuple2<IComponentInstance,IComponentAdapter>> inited)
Create a component instance.
|
IFuture<String> |
BpmnFactory.getComponentType(String model,
String[] imports,
ClassLoader classloader)
Get the component type of a model.
|
IFuture<Icon> |
BpmnFactory.getComponentTypeIcon(String type)
Get a default icon for a file type.
|
IFuture<Boolean> |
BpmnFactory.isLoadable(String model,
String[] imports,
ClassLoader classloader)
Test if a model can be loaded by the factory.
|
IFuture<Boolean> |
BpmnFactory.isStartable(String model,
String[] imports,
ClassLoader classloader)
Test if a model is startable (e.g. an component).
|
IFuture |
BpmnFactory.loadModel(String model,
String[] imports,
ClassLoader classloader)
Load a model.
|
IFuture<Void> |
BpmnFactory.shutdownService()
Shutdown the service.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
BpmnInterpreter.cleanupComponent()
Can be called concurrently (also during executeAction()).
|
IFuture<Void> |
ITask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture<Void> |
ITask.execute(ITaskContext context,
BpmnInterpreter process)
Execute the task.
|
IFuture |
BpmnInterpreter.scheduleStep(IComponentStep step) |
IFuture |
BpmnInterpreter.waitFor(long delay,
IComponentStep step)
Wait for some time and execute a component step afterwards.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
UserInteractionTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
ServiceCallTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
DestroyComponentTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
CreateComponentTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture<Void> |
AbstractTask.compensate(BpmnInterpreter instance)
Compensate in case the task is canceled.
|
IFuture |
UserInteractionTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture |
ServiceCallTask.execute(ITaskContext context,
BpmnInterpreter process)
Execute the task.
|
IFuture |
DestroyComponentTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture |
CreateComponentTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
IFuture<Void> |
AbstractTask.execute(ITaskContext context,
BpmnInterpreter instance)
Execute the task.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
IInternalAccess.addComponentListener(IComponentListener listener)
Add an component listener.
|
IFuture |
IExternalAccess.addComponentListener(IComponentListener listener)
Add an component listener.
|
IFuture<Void> |
IMessageService.addContentCodec(IContentCodec codec)
Add content codec type.
|
IFuture |
IMultiKernelNotifierService.addKernelListener(IMultiKernelListener listener)
Adds a kernel listener.
|
IFuture<Void> |
IMessageService.addMessageCodec(Class codec)
Add message codec type.
|
IFuture<Void> |
IMessageService.addMessageListener(IMessageListener listener,
IFilter filter)
Add a message listener.
|
IFuture |
IComponentInstance.cleanupComponent()
Can be called concurrently (also during executeAction()).
|
IFuture |
ICMSComponentListener.componentAdded(IComponentDescription desc)
Called when a new element has been added.
|
IFuture |
ICMSComponentListener.componentChanged(IComponentDescription desc)
Called when a component has changed its state.
|
IFuture |
IComponentInstance.componentCreated(IComponentDescription desc,
IModelInfo model)
Called when a component has been created as a subcomponent of this component.
|
IFuture |
IComponentInstance.componentDestroyed(IComponentDescription desc)
Called when a subcomponent of this component has been destroyed.
|
IFuture |
ICMSComponentListener.componentRemoved(IComponentDescription desc,
Map results)
Called when a new element has been removed.
|
IFuture |
IMultiKernelListener.componentTypesAdded(String[] types)
Called when new component types become available.
|
IFuture |
IMultiKernelListener.componentTypesRemoved(String[] types)
Called when component types become unavailable.
|
IFuture<IComponentIdentifier> |
IComponentManagementService.createComponent(String name,
String model,
CreationInfo info,
IResultListener killlistener)
Create a new component on the platform.
|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
IComponentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo model,
String config,
Map arguments,
IExternalAccess parent,
RequiredServiceBinding[] bindings,
boolean copy,
Future<Tuple2<IComponentInstance,IComponentAdapter>> ret)
Create a component instance.
|
IFuture<Void> |
ISettingsService.deregisterPropertiesProvider(String id)
Deregister a property provider.
|
IFuture<Map> |
IComponentManagementService.destroyComponent(IComponentIdentifier componentid)
Destroy (forcefully terminate) an component on the platform.
|
IFuture |
TerminationAdapter.eventOccured(IComponentChangeEvent cce)
Invoked when a change occurs with the component.
|
IFuture |
RemoteComponentListener.eventOccured(IComponentChangeEvent event)
Invoked when a change occurs with the component.
|
IFuture |
IComponentListener.eventOccured(IComponentChangeEvent cce)
Invoked when a change occurs with the component.
|
IFuture |
ComponentAdapter.eventOccured(IComponentChangeEvent cce)
Invoked when a change occurs with the component.
|
IFuture<T> |
IComponentStep.execute(IInternalAccess ia)
Execute the command.
|
IFuture<Boolean> |
FactoryFilter.filter(Object obj)
Test if an object passes the filter.
|
IFuture |
IExternalAccess.getArguments()
Get the arguments.
|
IFuture |
IInternalAccess.getChildren()
Get the children (if any).
|
IFuture |
IExternalAccess.getChildren()
Get the children (if any) component identifiers.
|
IFuture<IComponentIdentifier[]> |
IComponentManagementService.getChildren(IComponentIdentifier cid)
Get the children components of a component.
|
IFuture |
IExternalAccess.getChildren(String type)
Get the children (if any) component identifiers.
|
IFuture |
IComponentAdapter.getChildrenAccesses()
Get the children (if any).
|
IFuture<IComponentDescription[]> |
IComponentManagementService.getChildrenDescriptions(IComponentIdentifier cid)
Get the children components of a component.
|
IFuture |
IComponentAdapter.getChildrenIdentifiers()
Get the children (if any).
|
IFuture<IComponentDescription> |
IComponentManagementService.getComponentDescription(IComponentIdentifier cid)
Get the component description of a single component.
|
IFuture<IComponentDescription[]> |
IComponentManagementService.getComponentDescriptions()
Get all component descriptions.
|
IFuture<IComponentIdentifier[]> |
IComponentManagementService.getComponentIdentifiers()
Get the component identifiers.
|
IFuture<String> |
IComponentFactory.getComponentType(String model,
String[] imports,
ClassLoader classloader)
Get the component type of a model.
|
IFuture<Icon> |
IComponentFactory.getComponentTypeIcon(String type)
Get a default icon for a component type.
|
IFuture |
IRemoteServiceManagementService.getDeclaredServiceProxies(IComponentIdentifier cid)
Get all declared service proxies from a remote component.
|
IFuture |
IExternalAccess.getExtension(String name)
Get a space of the application.
|
IFuture |
IComponentFactoryExtensionService.getExtension(String componenttype)
Get extension.
|
IFuture<IExternalAccess> |
IComponentManagementService.getExternalAccess(IComponentIdentifier cid)
Get the external access of a component.
|
IFuture |
IRemoteServiceManagementService.getExternalAccessProxy(IComponentIdentifier cid)
Get an external access proxy from a remote component.
|
IFuture |
IExternalAccess.getFileName(String ctype)
Get the model name of a component type.
|
IFuture<IComponentIdentifier> |
IComponentManagementService.getParent(IComponentIdentifier cid)
Get the parent component of a component.
|
IFuture<Properties> |
ISettingsService.getProperties(String id)
Get the properties for a given id.
|
IFuture |
IExternalAccess.getResults()
Get the component results.
|
IFuture |
IRemoteServiceManagementService.getServiceProxies(IComponentIdentifier cid,
Class service,
String scope)
Get all service proxies from a remote component.
|
IFuture |
IRemoteServiceManagementService.getServiceProxies(IComponentIdentifier cid,
ISearchManager manager,
IVisitDecider decider,
IResultSelector selector)
Get service proxies from a remote component.
|
IFuture |
IRemoteServiceManagementService.getServiceProxy(IComponentIdentifier cid,
Class service,
String scope)
Get a service proxy from a remote component.
|
static IFuture |
ComponentChangeEvent.getTimeStamp(IServiceProvider provider)
Retrieves a timestamp from the clock service which can be used in events.
|
IFuture<Boolean> |
IComponentFactory.isLoadable(String model,
String[] imports,
ClassLoader classloader)
Test if a model can be loaded by the factory.
|
IFuture<Boolean> |
IComponentFactory.isStartable(String model,
String[] imports,
ClassLoader classloader)
Test if a model is startable (e.g. an component).
|
IFuture |
IInternalAccess.killComponent()
Kill the component.
|
IFuture |
IExternalAccess.killComponent()
Kill the component.
|
IFuture<IModelInfo> |
IComponentManagementService.loadComponentModel(String filename)
Load a component model.
|
IFuture<IModelInfo> |
IComponentFactory.loadModel(String model,
String[] imports,
ClassLoader classloader)
Load a model.
|
IFuture<Properties> |
ISettingsService.loadProperties()
Load the default platform properties.
|
IFuture |
IMessageListener.messageReceived(IMessageAdapter msg)
Invoked when a message event has been received.
|
IFuture |
IMessageListener.messageSent(IMessageAdapter msg)
Invoked when a message event has been sent.
|
IFuture<Void> |
ISettingsService.registerPropertiesProvider(String id,
IPropertiesProvider provider)
Register a property provider.
|
IFuture |
IInternalAccess.removeComponentListener(IComponentListener listener)
Remove a component listener.
|
IFuture |
IExternalAccess.removeComponentListener(IComponentListener listener)
Remove a component listener.
|
IFuture<Void> |
IMessageService.removeContentCodec(IContentCodec codec)
Remove content codec type.
|
IFuture |
IMultiKernelNotifierService.removeKernelListener(IMultiKernelListener listener)
Removes a kernel listener.
|
IFuture<Void> |
IMessageService.removeMessageCodec(Class codec)
Remove message codec type.
|
IFuture<Void> |
IMessageService.removeMessageListener(IMessageListener listener)
Remove a message listener.
|
IFuture<Void> |
IComponentManagementService.resumeComponent(IComponentIdentifier componentid)
Resume the execution of an component.
|
IFuture<Void> |
ISettingsService.saveProperties()
Save the platform properties to the default location.
|
<T> IFuture<T> |
IExternalAccess.scheduleImmediate(IComponentStep<T> step)
Execute some code on the component's thread.
|
<T> IFuture<T> |
IExternalAccess.scheduleImmediate(IComponentStep<T> step,
long delay)
Execute some code on the component's thread.
|
<T> IFuture<T> |
IExternalAccess.scheduleStep(IComponentStep<T> step)
Schedule a step of the component.
|
<T> IFuture<T> |
IExternalAccess.scheduleStep(IComponentStep<T> step,
long delay)
Schedule a step of the component.
|
IFuture<IComponentDescription[]> |
IComponentManagementService.searchComponents(IComponentDescription adesc,
ISearchConstraints con)
Search for components matching the given description.
|
IFuture<IComponentDescription[]> |
IComponentManagementService.searchComponents(IComponentDescription adesc,
ISearchConstraints con,
boolean remote)
Search for components matching the given description.
|
IFuture<Void> |
IMessageService.sendMessage(Map message,
MessageType msgtype,
IComponentIdentifier sender,
ClassLoader cl,
byte[] codecids)
Send a message.
|
IFuture<Void> |
IComponentManagementService.setComponentBreakpoints(IComponentIdentifier componentid,
String[] breakpoints)
Set breakpoints for a component.
|
IFuture<Void> |
ISettingsService.setProperties(String id,
Properties props)
Set the properties for a given id.
|
IFuture<Void> |
IComponentManagementService.stepComponent(IComponentIdentifier componentid)
Execute a step of a suspended component.
|
IFuture<Void> |
IComponentManagementService.suspendComponent(IComponentIdentifier componentid)
Suspend the execution of an component.
|
Modifier and Type | Method and Description |
---|---|
IFuture<IExtensionInfo> |
IExtensionInfo.createInstance(IExternalAccess access,
IValueFetcher fetcher)
Instantiate the extension for a specific component instance.
|
IFuture<Void> |
IExtensionInstance.terminate()
Terminate the extension.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Void> |
IServiceContainer.addService(IInternalService service)
Add a service to the container.
|
IFuture |
CacheServiceContainer.addService(IInternalService service)
Add a service to the platform.
|
IFuture<Void> |
BasicServiceContainer.addService(IInternalService service)
Add a service to the container.
|
IFuture<Boolean> |
ServiceIdFilter.filter(Object obj)
Test if service is a proxy.
|
IFuture<Boolean> |
ProxyFilter.filter(Object obj)
Test if service is a proxy.
|
IFuture<Collection<IServiceProvider>> |
IServiceProvider.getChildren()
Get the children container.
|
IFuture |
CacheServiceContainer.getChildren()
Get the children container.
|
abstract IFuture<Collection<IServiceProvider>> |
BasicServiceContainer.getChildren()
Get the children container.
|
IFuture<IServiceProvider> |
IServiceProvider.getParent()
Get the parent service container.
|
IFuture |
CacheServiceContainer.getParent()
Get the parent service container.
|
abstract IFuture<IServiceProvider> |
BasicServiceContainer.getParent()
Get the parent service container.
|
IFuture<IService> |
BasicServiceContainer.getRequiredService(RequiredServiceInfo info,
RequiredServiceBinding binding)
Get a required service.
|
IFuture<IService> |
BasicServiceContainer.getRequiredService(RequiredServiceInfo info,
RequiredServiceBinding binding,
boolean rebind)
Get a required service.
|
IFuture |
CacheServiceContainer.getRequiredService(String name) |
IFuture<IService> |
BasicServiceContainer.getRequiredService(String name)
Get a required service of a given name.
|
<T> IFuture<T> |
IServiceContainer.getRequiredService(String name)
Get a required service of a given name.
|
IFuture |
CacheServiceContainer.getRequiredService(String name,
boolean rebind) |
IFuture<IService> |
BasicServiceContainer.getRequiredService(String name,
boolean rebind)
Get a required service.
|
<T> IFuture<T> |
IServiceContainer.getRequiredService(String name,
boolean rebind)
Get a required service.
|
<T> IFuture<T> |
IServiceContainer.getService(Class<T> type,
IComponentIdentifier cid)
Get one service of a type from a specific component.
|
<T> IFuture<T> |
BasicServiceContainer.getService(Class<T> type,
IComponentIdentifier cid)
Get one service of a type from a specific component.
|
IFuture |
CacheServiceContainer.getService(Class type,
IComponentIdentifier cid)
Get one service of a type from a specific component.
|
static <T> IFuture<T> |
SServiceProvider.getService(IServiceProvider provider,
Class<T> type)
Get one service of a type.
|
static <T> IFuture<T> |
SServiceProvider.getService(IServiceProvider provider,
Class<T> type,
String scope)
Get one service of a type.
|
static <T> IFuture<T> |
SServiceProvider.getService(IServiceProvider provider,
IResultSelector selector)
Get one service of a type.
|
static <T> IFuture<T> |
SServiceProvider.getService(IServiceProvider provider,
IServiceIdentifier sid)
Get one service with id.
|
IFuture |
IRequiredServiceFetcher.getService(RequiredServiceInfo info,
RequiredServiceBinding binding,
boolean rebind)
Get a required service.
|
static <T> IFuture<T> |
SServiceProvider.getServiceUpwards(IServiceProvider provider,
Class<T> type)
Get one service of a type and only search upwards (parents).
|
IFuture<Boolean> |
IService.isValid()
Test if the service is valid.
|
IFuture<Boolean> |
BasicService.isValid()
Test if the service is valid.
|
IFuture<Void> |
IServiceContainer.removeService(IServiceIdentifier sid)
Removes a service from the container (shutdowns also the service if the container is running).
|
IFuture |
CacheServiceContainer.removeService(IServiceIdentifier sid)
Removes a service from the platform (shutdowns also the service).
|
IFuture<Void> |
BasicServiceContainer.removeService(IServiceIdentifier sid)
Removes a service from the platform (shutdowns also the service).
|
IFuture |
CacheServiceContainer.searchService(Class type)
Get one service of a type.
|
<T> IFuture<T> |
IServiceContainer.searchService(Class<T> type)
Get one service of a type.
|
<T> IFuture<T> |
IServiceContainer.searchService(Class<T> type,
String scope)
Get one service of a type.
|
IFuture |
CacheServiceContainer.searchService(Class type,
String scope)
Get one service of a type.
|
IFuture |
CacheServiceContainer.searchServiceUpwards(Class type)
Get one service of a type and only search upwards (parents).
|
<T> IFuture<T> |
IServiceContainer.searchServiceUpwards(Class<T> type)
Get one service of a type and only search upwards (parents).
|
IFuture |
IResultSelector.selectServices(Map services)
Called for each searched service provider node.
|
IFuture<List<IService>> |
BasicResultSelector.selectServices(Map servicemap)
Called for each searched service provider node.
|
IFuture<Void> |
IServiceContainer.shutdown()
Shutdown the service.
|
IFuture |
CacheServiceContainer.shutdown()
Shutdown the service.
|
IFuture<Void> |
BasicServiceContainer.shutdown()
Shutdown the service.
|
IFuture<Void> |
IInternalService.shutdownService()
Shutdown the service.
|
IFuture<Void> |
BasicService.shutdownService()
Shutdown the service.
|
IFuture<Void> |
IServiceContainer.start()
Start the service.
|
IFuture |
CacheServiceContainer.start()
Start the service.
|
IFuture<Void> |
BasicServiceContainer.start()
Start the service.
|
IFuture<Void> |
IInternalService.startService()
Start the service.
|
IFuture<Void> |
BasicService.startService()
Start the service.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Properties> |
ClockService.getProperties()
Write current state into properties.
|
IFuture<Void> |
ClockService.setProperties(Properties props)
Update from given properties.
|
IFuture |
ClockService.shutdownService()
Shutdown the service.
|
IFuture<Void> |
ClockService.startService()
Start the service.
|
Modifier and Type | Class and Description |
---|---|
class |
ComponentFuture<E>
The component future ensures that future result/exception notifications
are executed on the calling component thread.
|
class |
ComponentIntermediateFuture<E>
The component future ensures that intermediate future notifications
are executed on the calling component thread.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
DefaultServiceFetcher.createProxy(IService service,
RequiredServiceInfo info,
RequiredServiceBinding binding)
Create a proxy.
|
IFuture<Void> |
IServiceInvocationInterceptor.execute(ServiceInvocationContext context)
Execute the interceptor.
|
IFuture |
DefaultServiceFetcher.getChildExternalAccesses(IComponentIdentifier cid,
IServiceProvider provider,
RequiredServiceInfo info,
RequiredServiceBinding binding)
Get a fitting (of given type) child component.
|
IFuture<Collection<IServiceProvider>> |
ComponentServiceContainer.getChildren()
Get the children service containers.
|
IFuture<IServiceProvider> |
ComponentServiceContainer.getParent()
Get the parent service container.
|
IFuture |
DefaultServiceFetcher.getParentAccess(IServiceProvider provider,
RequiredServiceInfo info,
RequiredServiceBinding binding) |
IFuture<IService> |
ComponentServiceContainer.getRequiredService(RequiredServiceInfo info,
RequiredServiceBinding binding,
boolean rebind)
Get a required service.
|
IFuture |
DefaultServiceFetcher.getService(RequiredServiceInfo info,
RequiredServiceBinding bd,
boolean rebind)
Get a required service.
|
IFuture<Void> |
ServiceInvocationContext.invoke()
Invoke the next interceptor.
|
IFuture<Void> |
ServiceInvocationContext.invoke(Object object,
Method method,
List args)
Invoke the next interceptor.
|
<T> IFuture<T> |
ComponentServiceContainer.searchService(Class<T> type)
Get one service of a type.
|
<T> IFuture<T> |
ComponentServiceContainer.searchService(Class<T> type,
String scope)
Get one service of a type.
|
<T> IFuture<T> |
ComponentServiceContainer.searchServiceUpwards(Class<T> type)
Get one service of a type and only search upwards (parents).
|
IFuture<Void> |
ComponentServiceContainer.start()
Start the service.
|
Constructor and Description |
---|
ComponentFuture(IExternalAccess ea,
IComponentAdapter adapter,
IFuture source,
boolean copy)
Create a new future.
|
ComponentIntermediateFuture(IExternalAccess ea,
IComponentAdapter adapter,
IFuture source,
boolean copy)
Create a new future.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Void> |
DelegationInterceptor.doExecute(ServiceInvocationContext sic)
Execute the command.
|
IFuture |
DecouplingInterceptor.doExecute(ServiceInvocationContext sic)
Execute the command.
|
abstract IFuture<Void> |
AbstractMultiInterceptor.doExecute(ServiceInvocationContext sic)
Execute the command.
|
IFuture<Void> |
DecouplingInterceptor.InvokeMethodStep.execute(IInternalAccess ia) |
IFuture |
ValidationInterceptor.execute(ServiceInvocationContext sic)
Execute the interceptor.
|
IFuture |
ResolveInterceptor.execute(ServiceInvocationContext sic)
Execute the interceptor.
|
IFuture |
RecoveryInterceptor.execute(ServiceInvocationContext sic)
Execute the interceptor.
|
IFuture |
MethodInvocationInterceptor.execute(ServiceInvocationContext sic)
Execute the interceptor.
|
IFuture |
DecouplingReturnInterceptor.execute(ServiceInvocationContext sic)
Execute the interceptor.
|
IFuture<Void> |
AbstractMultiInterceptor.execute(ServiceInvocationContext sic)
Execute the command.
|
IFuture |
RecoveryInterceptor.rebind(ServiceInvocationContext sic)
Rebind a service call by using the fetcher to find/create
another service.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Void> |
SyncExecutionService.cancel(IExecutable task)
Cancel a task.
|
IFuture<Void> |
IExecutionService.cancel(IExecutable task)
Cancel a task.
|
IFuture<Void> |
AsyncExecutionService.cancel(IExecutable task)
Cancel a task.
|
IFuture<Void> |
SyncExecutionService.getNextIdleFuture()
Get the future indicating that executor is idle.
|
IFuture<Void> |
IExecutionService.getNextIdleFuture()
Get the future indicating that executor is idle.
|
IFuture<Void> |
AsyncExecutionService.getNextIdleFuture()
Get the future indicating that executor is idle.
|
IFuture<Void> |
SyncExecutionService.shutdownService()
Shutdown the executor service.
|
IFuture<Void> |
AsyncExecutionService.shutdownService()
Shutdown the executor service.
// todo: make callable more than once
|
IFuture<Void> |
SyncExecutionService.startService()
Start the executor service.
|
IFuture<Void> |
AsyncExecutionService.startService()
Start the execution service.
|
Modifier and Type | Method and Description |
---|---|
IFuture<List<URL>> |
LibraryService.getAllURLs()
Get all urls (managed and non-managed).
|
IFuture<List<URL>> |
ILibraryService.getAllURLs()
Get all urls (managed and non-managed).
|
IFuture<byte[]> |
LibraryService.getClassDefinition(String name)
Get a class definition.
|
IFuture<byte[]> |
ILibraryService.getClassDefinition(String name)
Get a class definition.
|
IFuture<List<URL>> |
LibraryService.getNonManagedURLs()
Get other contained (but not directly managed) URLs.
|
IFuture<List<URL>> |
ILibraryService.getNonManagedURLs()
Get other contained (but not directly managed) URLs.
|
IFuture<List<String>> |
LibraryService.getNonManagedURLStrings()
Get the non-managed classpath entries.
|
IFuture<List<String>> |
ILibraryService.getNonManagedURLStrings()
Get the non-managed classpath entries.
|
IFuture<Properties> |
LibraryService.getProperties()
Write current state into properties.
|
IFuture<List<URL>> |
LibraryService.getURLs()
Get all managed entries as URLs.
|
IFuture<List<URL>> |
ILibraryService.getURLs()
Get all managed entries as URLs.
|
IFuture<List<String>> |
LibraryService.getURLStrings()
Get the non-managed classpath entries as strings.
|
IFuture<List<String>> |
ILibraryService.getURLStrings()
Get the non-managed classpath entries as strings.
|
IFuture<Void> |
LibraryService.setProperties(Properties props)
Update from given properties.
|
IFuture<Void> |
LibraryService.shutdownService()
Shutdown the service.
|
IFuture<Void> |
LibraryService.startService()
Start the service.
|
IFuture |
ILibraryServiceListener.urlAdded(URL url)
Called when a new url has been added.
|
IFuture |
ILibraryServiceListener.urlRemoved(URL url)
Called when a url has been removed.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Void> |
ThreadPoolService.shutdownService()
Shutdown the service.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
IRemoteChangeListener.changeOccurred(ChangeEvent event)
Called when a change occurs.
|
IFuture<Boolean> |
IRemoteFilter.filter(Object obj)
Test if an object passes the filter.
|
IFuture<Boolean> |
IRemoteFilter.AlwaysFilter.filter(Object obj) |
IFuture<Boolean> |
IRemoteFilter.NeverFilter.filter(Object obj) |
IFuture<Boolean> |
ComposedRemoteFilter.filter(Object object)
Match an object against the filter.
|
IFuture<Properties> |
IPropertiesProvider.getProperties()
Write current state into properties.
|
IFuture<Void> |
IPropertiesProvider.setProperties(Properties props)
Update from given properties.
|
Modifier and Type | Method and Description |
---|---|
IFuture<Void> |
Executor.shutdown()
Shutdown the executor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
IIntermediateFuture<E>
Future that support intermediate results.
|
Modifier and Type | Class and Description |
---|---|
class |
Future<E>
Future that includes mechanisms for callback notification.
|
class |
IntermediateFuture<E>
Default implementation of an intermediate future.
|
Modifier and Type | Field and Description |
---|---|
static IFuture<Void> |
IFuture.DONE
A future representing a completed action.
|
static IFuture |
Future.EMPTY
The empty future.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
CallMultiplexer.doCall(IResultCommand call)
Calls the command.
|
IFuture |
CallMultiplexer.doCall(Object keyargs,
IResultCommand call)
Calls the command.
|
IFuture |
CallMultiplexer.doCall(Object keyargs,
IResultCommand call,
boolean commandaskey)
Calls the command.
|
static <T> IFuture<T> |
Future.getEmptyFuture()
Get the empty future of some type.
|
IFuture |
DuplicateResultException.getFuture()
Get the future.
|
Modifier and Type | Method and Description |
---|---|
void |
ThreadSuspendable.resume(IFuture future)
Resume the execution of the suspendable.
|
void |
ISuspendable.resume(IFuture future)
Resume the execution of the suspendable.
|
void |
ThreadSuspendable.suspend(IFuture future,
long timeout)
Suspend the execution of the suspendable.
|
void |
ISuspendable.suspend(IFuture future,
long timeout)
Suspend the execution of the suspendable.
|
Constructor and Description |
---|
DuplicateResultException(int type,
IFuture future,
Object first,
Object second)
Create a duplicate result exception.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
MAGRSpaceInstance.createInstance(IExternalAccess access,
IValueFetcher fetcher)
Instantiate the extension for a specific component instance.
|
IFuture |
AGRExtensionService.getExtension(String componenttype)
Get extension.
|
IFuture |
AGRSpace.init(IExternalAccess exta,
MAGRSpaceInstance config,
IValueFetcher fetcher)
Initialize the extension.
|
IFuture |
AGRSpace.terminate()
Initialize the extension.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
MEnvSpaceInstance.createInstance(IExternalAccess access,
IValueFetcher fetcher)
Instantiate the extension for a specific component instance.
|
IFuture |
EnvSupportExtensionService.getExtension(String componenttype)
Get extension.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
AbstractEnvironmentSpace.init(IExternalAccess exta,
MEnvSpaceInstance config,
IValueFetcher fetcher)
Initialize the extension.
|
IFuture |
AbstractEnvironmentSpace.terminate()
Initialize the extension.
|
Modifier and Type | Method and Description |
---|---|
IFuture |
MicroAgent.addComponentListener(IComponentListener listener)
Add an component listener.
|
IFuture |
MicroAgent.addService(String name,
Class type,
Object service)
Add a service to the platform.
|
IFuture |
MicroAgent.addService(String name,
Class type,
Object service,
String proxytype)
Add a service to the platform.
|
IFuture |
PojoMicroAgent.agentCreated()
Called once after agent creation.
|
IFuture |
MicroAgent.agentCreated()
Called once after agent creation.
|
IFuture |
IMicroAgent.agentCreated()
Called once after agent creation.
|
IFuture |
PojoMicroAgent.agentKilled()
Called just before the agent is removed from the platform.
|
IFuture |
MicroAgent.agentKilled()
Called just before the agent is removed from the platform.
|
IFuture |
IMicroAgent.agentKilled()
Called just before the agent is removed from the platform.
|
IFuture |
MicroAgentInterpreter.cleanupComponent()
Can be called concurrently (also during executeAction()).
|
IFuture |
MicroAgent.createComponentIdentifier(String name)
Create component identifier.
|
IFuture |
MicroAgent.createComponentIdentifier(String name,
boolean local)
Create component identifier.
|
IFuture |
MicroAgent.createComponentIdentifier(String name,
boolean local,
String[] addresses)
Create component identifier.
|
IFuture<Tuple2<IComponentInstance,IComponentAdapter>> |
MicroAgentFactory.createComponentInstance(IComponentDescription desc,
IComponentAdapterFactory factory,
IModelInfo model,
String config,
Map arguments,
IExternalAccess parent,
RequiredServiceBinding[] binding,
boolean copy,
Future<Tuple2<IComponentInstance,IComponentAdapter>> ret)
Create a component instance.
|
IFuture |
MicroAgent.createReply(Map msg,
MessageType mt)
Create a reply to this message event.
|
IFuture<Void> |
MicroAgentInterpreter.HandleMessageStep.execute(IInternalAccess ia) |
IFuture<Void> |
MicroAgent.ExecuteWaitForStep.execute(IInternalAccess ia)
Removes the first entry from the
ITimer array from the micro agents
MicroAgent.timers List and executes the IComponentStep . |
IFuture |
ExternalAccess.getAgent()
Get the agent implementation.
|
IFuture |
MicroAgent.getChildren()
Get the children (if any).
|
IFuture<String> |
MicroAgentFactory.getComponentType(String model,
String[] imports,
ClassLoader classloader)
Get the component type of a model.
|
IFuture<Icon> |
MicroAgentFactory.getComponentTypeIcon(String type)
Get a default icon for a file type.
|
IFuture |
MicroAgent.getRequiredService(String name)
Get a required service of a given name.
|
IFuture |
MicroAgent.getTime()
Get the current time.
|
IFuture<Boolean> |
MicroAgentFactory.isLoadable(String model,
String[] imports,
ClassLoader classloader)
Test if a model can be loaded by the factory.
|
IFuture<Boolean> |
MicroAgentFactory.isStartable(String model,
String[] imports,
ClassLoader classloader)
Test if a model is startable (e.g. an component).
|
IFuture |
MicroAgent.killAgent()
Kill the agent.
|
IFuture |
MicroAgent.killComponent()
Kill the component.
|
IFuture<IModelInfo> |
MicroAgentFactory.loadModel(String model,
String[] imports,
ClassLoader classloader)
Load a model.
|
IFuture |
MicroAgent.removeComponentListener(IComponentListener listener)
Remove a component listener.
|
IFuture |
MicroAgent.removeService(IServiceIdentifier sid)
Removes a service from the platform (shutdowns also the service).
|
<T> IFuture<T> |
MicroAgentInterpreter.scheduleStep(IComponentStep<T> step)
Schedule a step of the agent.
|
<T> IFuture<T> |
MicroAgent.scheduleStep(IComponentStep<T> step)
Schedule a step of the agent.
|
IFuture |
MicroAgent.sendMessage(Map me,
MessageType mt)
Send a message.
|
IFuture |
IMicroExternalAccess.sendMessage(Map me,
MessageType mt)
Send a message.
|
IFuture |
ExternalAccess.sendMessage(Map me,
MessageType mt)
Send a message.
|
IFuture |
MicroAgent.sendMessage(Map me,
MessageType mt,
byte[] codecids)
Send a message.
|
IFuture |
MicroAgent.sendMessageAndWait(Map me,
MessageType mt,
IMessageHandler handler)
Send a message and wait for a reply.
|
IFuture<Void> |
MicroAgentFactory.shutdownService()
Shutdown the service.
|
IFuture<Void> |
MicroAgentFactory.startService()
Start the service.
|
IFuture |
IMicroExternalAccess.waitFor(long time,
IComponentStep step)
Wait for an specified amount of time.
|
IFuture |
ExternalAccess.waitFor(long time,
IComponentStep run)
Wait for an specified amount of time.
|
IFuture<jadex.micro.MicroAgent.TimerWrapper> |
MicroAgent.waitFor(long time,
IComponentStep<Void> run)
Wait for an specified amount of time.
|
IFuture |
IMicroExternalAccess.waitForTick(IComponentStep step)
Wait for the next tick.
|
IFuture |
ExternalAccess.waitForTick(IComponentStep run)
Wait for the next tick.
|
IFuture<jadex.micro.MicroAgent.TimerWrapper> |
MicroAgent.waitForTick(IComponentStep<Void> run)
Wait for the next tick.
|
Copyright © 2012. All Rights Reserved.