org.eclipse.paho.client.mqttv3.internal
Class CommsReceiver

java.lang.Object
  extended by org.eclipse.paho.client.mqttv3.internal.CommsReceiver
All Implemented Interfaces:
Runnable

public class CommsReceiver
extends Object
implements Runnable

Receives MQTT packets from the server.


Constructor Summary
CommsReceiver(ClientComms clientComms, ClientState clientState, CommsTokenStore tokenStore, InputStream in)
           
 
Method Summary
 boolean isRunning()
           
 void run()
          Run loop to receive messages from the server.
 void start(String threadName)
          Starts up the Receiver's thread.
 void stop()
          Stops the Receiver's thread.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CommsReceiver

public CommsReceiver(ClientComms clientComms,
                     ClientState clientState,
                     CommsTokenStore tokenStore,
                     InputStream in)
Method Detail

start

public void start(String threadName)
Starts up the Receiver's thread.


stop

public void stop()
Stops the Receiver's thread. This call will block.


run

public void run()
Run loop to receive messages from the server.

Specified by:
run in interface Runnable

isRunning

public boolean isRunning()


Copyright © 2013. All Rights Reserved.