Creating a server

DiffusionServer is available in the com.pushtechnology.diffusion.api.server. You can instantiate it with one of the following constructors:

Default configuration

DiffusionServer server = new DiffusionServer();

This instantiates the server with default configuration options. The default configuration is read from the XML configuration files in the etc directory of your Diffusion installation. Required aspects of the server must be configured before it is started. These can be configured programmatically. For more information, see Programmatic configuration.

Bootstrap properties

DiffusionServer server = new DiffusionServer(bootstrapProperties);

This specifies a set of properties inside a Properties object. The following properties are supported:

Property	Description	Default
diffusion.home	The base installation directory	Calculated from the location of the diffusion.jar file.
diffusion.config.dir	The configuration directory, where the XML configuration files are located. Relative paths are resolved from diffusion.home.	diffusion.home/etc
diffusion.ext.dir	The ext directory, where application-supplied libraries are located. Relative paths are resolved from diffusion.home.	diffusion.home/ext
diffusion.license.file	The license file	diffusion.config.dir/license.lic
diffusion.keystore.file	The keystore file required to decrypt the license	diffusion.config.dir/licence.keystore

These properties can also be set as system properties.

Whichever approach to instantiation that you use, a full set of XML configuration files can be present in the configuration directory and tuned as required or just a partial set of the files can be present and all missing configuration supplied programmatically.

Configuring the Diffusion server

Once the server object has been instantiated some properties can be configured. The root configuration object can be obtained from the server object as follows:

ServerConfig config = server.getConfig();

Alternatively the root can be obtained using ConfigManager.getServerConfig().

DiffusionServer server = new DiffusionServer();

ServerConfig config = server.getConfig();


// Connector ConnectorConfig connector = config.addConnector("Client Connector");
// Configure connector as required....

// Thread Pools
ThreadsConfig threads = config.getThreads();
ThreadPoolConfig inbound = threads.addPool("Inbound");
inbound.setCoreSize(3);
inbound.setMaximumSize(10);
inbound.setQueueSize(2000);
threads.setInboundPool(inbound.getName());
threads.setBackgroundPoolSize(2);

// Queues QueuesConfig queues = config.getQueues();
QueueConfig queue = queues.addQueue("DefaultQueue");
queue.setMaximumDepth(10000);
queues.setDefaultQueue("DefaultQueue");

// Multiplexer MultiplexerConfig multiplexer = config.addMultiplexer("Multiplexer");
multiplexer.setSize(4); 

Monitoring the Diffusion server lifecycle

The DiffusionServer class provides methods to add and remove a lifecycle listener on the server instance.

addLifecycleListener(LifecycleListener stateCallback);

removeLifecycleListener(LifecycleListener stateCallback);

Starting the server

After the server configuration has been completed, the server can be started using server.start().

Connectors start to listen on the configured ports.

Stopping the server

The server can be stopped using server.stop() at which point the server is no longer available.

Run requirements

A simple way to use Diffusion as a library within your application is to install Diffusion and include the path to diffusion.jar in your CLASSPATH.

Limitations

Currently only one Diffusion server can be instantiated in a Java VM and it can be started only once.