Class ECPDSPublisher

java.lang.Object

ecmwf.ecpds.mover.plugin.mqtt.ECPDSPublisher

All Implemented Interfaces:

MQTTInterface

public class ECPDSPublisher
extends Object
implements MQTTInterface

The Class ECPDSPublisher.

Method Summary

Modifier and Type	Method	Description
int	clientsCount()	Get the number of client connected to the MQTT broker.
void	publish(String topic, int qos, long expiryInterval, String contentType, String clientId, String payload, boolean retain)	Publish a notification to the registered MQTT broker.
void	remove(String topic)	Remove a retained notification from the MQTT broker.

Methods inherited from class java.lang.Object

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

Method Details

publish

public void publish(String topic,
 int qos,
 long expiryInterval,
 String contentType,
 String clientId,
 String payload,
 boolean retain)

Publish a notification to the registered MQTT broker. Publish.

Specified by:

publish in interface MQTTInterface

Parameters:

topic - the topic

qos - the qos

expiryInterval - the expiry interval

contentType - the content type

clientId - the client id

payload - the payload

retain - the retain

remove

public void remove(String topic)

Remove a retained notification from the MQTT broker. Removes the.

Specified by:

remove in interface MQTTInterface

Parameters:

topic - the topic

clientsCount

public int clientsCount()

Get the number of client connected to the MQTT broker. Clients count.

Specified by:

clientsCount in interface MQTTInterface

Returns:

number clients