Class MQTTNotification

java.lang.Object

ecmwf.ecpds.mover.service.MQTTNotification

All Implemented Interfaces:

NotificationInterface, Closeable, AutoCloseable

public final class MQTTNotification
extends Object
implements NotificationInterface

The Class MQTTNotification.

Constructor Summary

Constructors

Constructor	Description
MQTTNotification(boolean useSsl, String hostsList, String name, String password)	Instantiates a new notification manager.

Method Summary

Modifier and Type	Method	Description
void	close()	Close.
void	notify(String payload, String topic, String properties, long lifetime)	Notify.

Methods inherited from class java.lang.Object

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

Constructor Details

MQTTNotification

public MQTTNotification(boolean useSsl,
 String hostsList,
 String name,
 String password)

Instantiates a new notification manager. The authentication is only performed once the file is transmitted (when the notify method is called).

Parameters:

useSsl - the use ssl

hostsList - the hosts (list of hosts, e.g. dm1:1883;dm2;dm3)

name - the name

password - the password

Method Details

notify

public void notify(String payload,
 String topic,
 String properties,
 long lifetime)
            throws IOException,
NumberFormatException

Notify. Publish.

Specified by:

notify in interface NotificationInterface

Parameters:

payload - the url

topic - the key

properties - the value

lifetime - the lifetime

Throws:

IOException - the io exception

NumberFormatException

close

public void close()
           throws IOException

Close.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException