Class MqttPlugin

java.lang.Object

ecmwf.common.technical.ThreadService.ConfigurableRunnable

ecmwf.common.plugin.PluginThread

ecmwf.ecpds.mover.plugin.mqtt.MqttPlugin

All Implemented Interfaces:

MBeanService, HttpCertificateProvider, Runnable

public class MqttPlugin
extends PluginThread
implements HttpCertificateProvider

The Class MqttPlugin.

Field Summary

Fields inherited from class PluginThread

_params

Constructor Summary

Constructors

Constructor	Description
MqttPlugin(String ref, Map<String,String> params)	Instantiates a new http plugin.

Method Summary

Modifier and Type	Method	Description
String	buildCertificateJson()	Returns a JSON-encoded snapshot of the TLS certificate currently loaded by this plugin's HTTPS server, or "{}" if no certificate is available.
void	deployCertificate(byte[] pkcs12Bytes, String keystorePassword)	Deploys a new PKCS#12 keystore to this plugin's HTTPS server and hot-reloads the certificate without restarting the server (where supported).
String	getPluginName()	Gets the plugin name.
String	getVersion()	Gets the version.
void	reloadCertificate()	Hot-reloads the TLS certificate from the keystore file currently on disk, without requiring a new keystore to be uploaded.
boolean	start()	Start.
void	stop()	Stop.

Methods inherited from class PluginThread

callerBack, callerGone, configurableRun, getAttribute, getCaller, getMBeanInfo, getParam, getPluginContainer, getRef, handle, handle, invoke, setAttribute, setCaller, setPluginContainer, subscribe, unSubscribe

Methods inherited from class ThreadService.ConfigurableRunnable

execute, execute, execute, getContextClassLoader, getPriority, getThreadName, interrupt, interrupted, isAlive, isStarted, join, join, run, setContextClassLoader, setForceCookie, setInheritCookie, setPriority, setThreadNameAndCookie

Methods inherited from class Object

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

Constructor Details

MqttPlugin

public MqttPlugin(String ref,
 Map<String,String> params)

Instantiates a new http plugin.

Parameters:

ref - the ref

params - the params

Method Details

getPluginName

public String getPluginName()

Gets the plugin name. Gets the plugin name.

Specified by:

getPluginName in class PluginThread

Returns:

the plugin name

getVersion

public String getVersion()

Gets the version. Gets the version.

Specified by:

getVersion in class PluginThread

Returns:

the version

start

public boolean start()

Start. Start.

Specified by:

start in class PluginThread

Returns:

true, if successful

stop

public void stop()

Stop. Stop.

Specified by:

stop in class PluginThread

buildCertificateJson

public String buildCertificateJson()

Returns a JSON-encoded snapshot of the TLS certificate currently loaded by this plugin's HTTPS server, or "{}" if no certificate is available.

Specified by:

buildCertificateJson in interface HttpCertificateProvider

Returns:

JSON string; never null

deployCertificate

public void deployCertificate(byte[] pkcs12Bytes,
 String keystorePassword)
                       throws Exception

Deploys a new PKCS#12 keystore to this plugin's HTTPS server and hot-reloads the certificate without restarting the server (where supported).

Specified by:

deployCertificate in interface HttpCertificateProvider

Parameters:

pkcs12Bytes - the PKCS#12 keystore bytes

keystorePassword - password for the keystore and private key

Throws:

Exception - if the deployment or reload fails

reloadCertificate

public void reloadCertificate()
                       throws Exception

Description copied from interface: HttpCertificateProvider

Hot-reloads the TLS certificate from the keystore file currently on disk, without requiring a new keystore to be uploaded. Use this after replacing the keystore file via automation or a secrets manager.

Specified by:

reloadCertificate in interface HttpCertificateProvider

Throws:

Exception - if the reload fails