server.properties'.
*/
private Properties serverLocalProperties;
/**
* The topology in which the current container is a node.
*/
private Topology topology;
/**
* The container configuration
*/
private ContainerConfiguration containerConfiguration;
/**
* Petals composite
*/
private Component petalsComposite;
/**
* Petals Content Controller
*/
private ContentController petalsContentController;
private EndpointRegistry registry;
/**
* Flag indicating the state of the Petals container. true if the container is starting, started;
* false if the container is stopping or stopped.
*/
private volatile boolean isRunning = false;
/**
* Logger wrapper. Available once the logging system is initialized.
*/
private LoggingUtil log = new LoggingUtil(Logger.getLogger(PetalsServer.COMPONENT_LOGGER_NAME));
/**
* Creates a new instance of {@link PetalsServerImpl}
*
* @throws PetalsException
*/
public PetalsServerImpl() throws PetalsException {
this(false);
}
/**
* Creates a new instance of {@link PetalsServerImpl}
*
* @throws PetalsException
*/
public PetalsServerImpl(boolean observer) throws PetalsException {
this.petalsStopThread = new PetalsStopThread(this);
}
/**
* {@inheritDoc}
*/
public void init(final Properties serverLocalProperties, final Topology topology,
final File dataRootPath) throws PetalsServerException {
this.serverLocalProperties = serverLocalProperties;
this.topology = topology;
// The data root path MUST be set as a property to be resolved, if
// needed, in other property values
this.serverLocalProperties.setProperty(
ConfigurationProperties.DATA_ROOT_DIRECTORY_PROPERTY_NAME,
dataRootPath.getAbsolutePath());
// set the JMX server
System.setProperty("javax.management.builder.initial", "mx4j.server.MX4JMBeanServerBuilder");
try {
initializeLogging();
// initialize Petals Fractal composite
this.initializePetalsComposite();
} catch (final Exception exception) {
// clean up the petals server
throw new PetalsServerException("Problem while initializing Petals", exception);
}
}
private class ShutdownHook extends Thread {
private final PetalsServer petalsServer;
public ShutdownHook(final PetalsServer petalsServer) {
this.petalsServer = petalsServer;
}
@Override
public void run() {
try {
if (this.petalsServer.isRunning()) {
petalsServer.stop();
}
} catch (final PetalsException e) {
System.err.println("ERROR: " + e.getMessage());
}
}
}
/**
* {@inheritDoc}
*/
public void start() throws PetalsServerException {
this.isRunning = true;
try {
// start PEtALS Fractal composite
this.startPetalsComposite();
// register the PEtALS server in the Petals admin.
this.registerPetalsServer();
// expose PEtALS MBean object into the JMX server
MBeanHelper.registerMBeans(this.petalsComposite);
// recover all JBI entities
this.recoverSystem();
// set the container as active in the topology
this.startupDone();
} catch (Exception exception) {
this.log.error("An error occurs starting Petals ESB.", exception);
// clean up the petals server
if (this.petalsComposite != null) {
this.log.info("Problem while starting PEtALS, try to stop PEtALS cleanly...");
try {
FractalHelper.stopComponent(this.petalsComposite);
} catch (Throwable e) {
this.log.error("Failed to stop PEtALS cleanly");
}
}
throw new PetalsServerException("Failed to start PEtALS", exception);
}
Runtime.getRuntime().addShutdownHook(new ShutdownHook(this));
this.log.info("Server STARTED");
}
/**
* {@inheritDoc}
*/
public void stop() throws PetalsServerException {
this.isRunning = false;
PetalsServerException exception = null;
try {
this.stopPetalsComposite();
} catch (final Exception e) {
exception = new PetalsServerException(e);
}
if (exception == null) {
this.log.info("Server STOPPED");
} else {
this.log.error("ERROR: " + exception.getMessage(), exception);
}
synchronized (this) {
this.notifyAll();
}
if (exception != null) {
throw exception;
}
}
/**
* {@inheritDoc}
*/
public String getContainerConfiguration() throws PetalsServerException {
if (this.containerConfiguration == null) {
throw new PetalsServerException("The container configuration is not properly set");
}
return this.containerConfiguration.toString();
}
/**
* {@inheritDoc}
*/
public String browseJNDI() throws PetalsServerException {
if (this.containerConfiguration == null) {
throw new PetalsServerException("The container configuration is not properly set");
}
String result = null;
Component jndiComponent = FractalHelper.getRecursiveComponentByName(
this.petalsContentController, FractalHelper.JNDI_COMPONENT);
try {
JNDIService jndiService = (JNDIService) jndiComponent.getFcInterface("service");
InitialContext initialContext = jndiService.getInitialContext();
if (this.domainConfiguration.getJndiConfiguration() == null) {
result = JNDIUtil.browseJNDI(initialContext, (String) null, 0);
} else {
URI providerUrl = this.domainConfiguration.getJndiConfiguration()
.getJndiProviderUrl();
result = JNDIUtil.browseJNDI(initialContext, providerUrl.getHost(),
providerUrl.getPort());
}
} catch (final NoSuchInterfaceException e) {
throw new PetalsServerException(e);
} catch (final NamingException e) {
throw new PetalsServerException(e);
}
return result;
}
/**
* {@inheritDoc}
*/
public List* Initialize the logging system. *
* * @see PetalsServer * * @throws IOException * @throws PropertiesException */ private void initializeLogging() throws IOException, PropertiesException { // Load Petals customized log level Level.initialize(); try { final String configurationPath = System .getProperty(ConfigurationProperties.LOGGING_SYSTEM_CONF_FILE_PROPERTY_NAME); final File configurationFile; if (configurationPath == null) { System.out.println("Default conf file for log"); // Retrieve the logging.properties path final URL configurationURL = this.getClass().getResource( "/" + ConfigurationProperties.DEFAULT_LOGGER_FILENAME); if (configurationURL == null) { throw new IOException("Failed to reach the resource [" + ConfigurationProperties.DEFAULT_LOGGER_FILENAME + "]"); } configurationFile = new File(configurationURL.toURI().normalize()); } else { configurationFile = new File(configurationPath); } final InputStream fisInitial = new FileInputStream(configurationFile); try { final Properties existingProperties = new Properties(System.getProperties()); existingProperties.putAll(this.serverLocalProperties); final InputStream fisResolved = PropertiesHelper.resolvePropertiesForInputStream( fisInitial, existingProperties); try { LogManager.getLogManager().readConfiguration(fisResolved); } finally { IOHelper.close(fisResolved); } } finally { IOHelper.close(fisInitial); } } catch (final URISyntaxException e) { throw new IOException(e); } } /** * {@inheritDoc} */ public boolean isRunning() { return this.isRunning; } }