org.eclipse.paho.client.mqttv3.internal

Class LocalNetworkModule

java.lang.Object

org.eclipse.paho.client.mqttv3.internal.LocalNetworkModule

All Implemented Interfaces:

NetworkModule

public class LocalNetworkModule
extends java.lang.Object
implements NetworkModule

Special comms class that allows an MQTT client to use a non TCP / optimised mechanism to talk to an MQTT server when running in the same JRE instance as the MQTT server. This class checks for the existence of the optimised comms adatper class i.e. the one that provides the optimised communication mechanism. If not available the request to connect using the optimised mechanism is rejected. The only known server that implements this is the microbroker:- an MQTT server that ships with a number of IBM products.

Constructor Summary

Constructors

Constructor and Description
LocalNetworkModule(java.lang.String brokerName)

Method Summary

Modifier and Type	Method and Description
java.io.InputStream	getInputStream()
java.io.OutputStream	getOutputStream()
java.lang.String	getServerURI()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalNetworkModule

public LocalNetworkModule(java.lang.String brokerName)

Method Detail

start

public void start()
           throws java.io.IOException,
                  MqttException

Specified by:

start in interface NetworkModule

Throws:

java.io.IOException

MqttException

getInputStream

public java.io.InputStream getInputStream()
                                   throws java.io.IOException

Specified by:

getInputStream in interface NetworkModule

Throws:

java.io.IOException

getOutputStream

public java.io.OutputStream getOutputStream()
                                     throws java.io.IOException

Specified by:

getOutputStream in interface NetworkModule

Throws:

java.io.IOException

stop

public void stop()
          throws java.io.IOException

Specified by:

stop in interface NetworkModule

Throws:

java.io.IOException

getServerURI

public java.lang.String getServerURI()

Specified by:

getServerURI in interface NetworkModule