org.adroitlogic.x.core.project

Class Project

java.lang.Object

org.adroitlogic.x.core.project.Project

All Implemented Interfaces:

Initializable, Startable, XEnvironmentListener, XProject

public class Project
extends Object
implements XProject

Since:

17.01

Author:

Dimuthu Upeksha, Ruwan Linton

Field Summary

Fields

Modifier and Type	Field and Description
protected Status	status

Constructor Summary

Constructors

Constructor and Description
Project(org.springframework.context.ApplicationContext projectContext, ClassLoader classLoader, File artifactPath, ServerConfig serverConfig)

Method Summary

Modifier and Type	Method and Description
void	addTransportListener(TransportListener transportListener)
void	addTransportSender(TransportSender transportSender)
void	destroy()
void	environmentChanged(XEnvironment environment) XEnvironment's tag changes will be notified through this method.
ClassLoader	getClassLoader()
<T> T	getFeature(Class<T> clazz)
List<XIntegrationFlow>	getIntegrationFlows()
XMetricsEngine	getMetricsEngine()
ProjectConfig	getProjectConfig()
XServerConfig	getServerConfig()
Status	getStatus() Returns the current status of this Project
List<TransportListener>	getTransportListeners()
List<TransportSender>	getTransportSenders()
void	init(org.springframework.context.ApplicationContext context)
void	pauseProject() This method can be used to pause the project.
CompletableFuture<Boolean>	readyForShutdown() This method can be used to instruct the project to get ready for a shutdown operation.
void	resumeProject() This method can be used to resume the project from a paused state
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

status

protected volatile Status status

Constructor Detail

Project

public Project(org.springframework.context.ApplicationContext projectContext,
               ClassLoader classLoader,
               File artifactPath,
               ServerConfig serverConfig)

Method Detail

init

public void init(org.springframework.context.ApplicationContext context)

Specified by:

init in interface Initializable

start

public void start()

Specified by:

start in interface Startable

stop

public void stop()

Specified by:

stop in interface Startable

destroy

public void destroy()

Specified by:

destroy in interface Initializable

getProjectConfig

public ProjectConfig getProjectConfig()

Specified by:

getProjectConfig in interface XProject

getServerConfig

public XServerConfig getServerConfig()

Specified by:

getServerConfig in interface XProject

getTransportListeners

public List<TransportListener> getTransportListeners()

Specified by:

getTransportListeners in interface XProject

getTransportSenders

public List<TransportSender> getTransportSenders()

Specified by:

getTransportSenders in interface XProject

addTransportListener

public void addTransportListener(TransportListener transportListener)

Specified by:

addTransportListener in interface XProject

addTransportSender

public void addTransportSender(TransportSender transportSender)

Specified by:

addTransportSender in interface XProject

getIntegrationFlows

public List<XIntegrationFlow> getIntegrationFlows()

Specified by:

getIntegrationFlows in interface XProject

getMetricsEngine

public XMetricsEngine getMetricsEngine()

Specified by:

getMetricsEngine in interface XProject

getFeature

public <T> T getFeature(Class<T> clazz)

Specified by:

getFeature in interface XProject

getClassLoader

public ClassLoader getClassLoader()

Specified by:

getClassLoader in interface XProject

environmentChanged

public void environmentChanged(XEnvironment environment)

Description copied from interface: XEnvironmentListener

XEnvironment's tag changes will be notified through this method. The concrete classes implementing this method should know that some tags has changed (may be added ot removed). Therefore, it is the implementing method's responsibility to make sure it browse the tag container again to determine what should be done. This design is introduced to make sure that the listeners of the XEnvironment can be configured to be acted upon multiple tags at the same time

Specified by:

environmentChanged in interface XEnvironmentListener

Parameters:

environment - XEnvironment of this node

getStatus

public Status getStatus()

Description copied from interface: XProject

Returns the current status of this Project

Specified by:

getStatus in interface XProject

Returns:

Status

resumeProject

public void resumeProject()

Description copied from interface: XProject

This method can be used to resume the project from a paused state

Specified by:

resumeProject in interface XProject

pauseProject

public void pauseProject()

Description copied from interface: XProject

This method can be used to pause the project. Once the project is paused, it will cease to accept new messages through the ingress connectors, but will continue to process any messages that have been already accepted.

Specified by:

pauseProject in interface XProject

readyForShutdown

public CompletableFuture<Boolean> readyForShutdown()

Description copied from interface: XProject

This method can be used to instruct the project to get ready for a shutdown operation. When this is triggered, the project will cease to accept new messages through the ingress connectors, but will continue to process any messages that have been already accepted. Once all the accepted messages have been finished processing, the returned completable future will be completed.

Specified by:

readyForShutdown in interface XProject

Returns:

instance of CompletableFuture which will be completed when the project becomes idle and ready to be shutdown