net.sf.xenqtt.proxy
Class ProxyApplication

java.lang.Object
  net.sf.xenqtt.proxy.ProxyApplication

All Implemented Interfaces:

XenqttApplication

public class ProxyApplication
extends Object
implements XenqttApplication

A XenqttApplication is that acts as an MQTT proxy to allow a cluster of servers to act as a single MQTT proxy. All connections to this proxy that have the same client ID will share a connection to a broker and appear as a single client to it.

Constructor Summary

ProxyApplication()

Method Summary

String	getUsageText() Get usage text to display to the user.
void	start(AppContext arguments) Start the application.
void	stop() Stop the application.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProxyApplication

public ProxyApplication()

Method Detail

start

public void start(AppContext arguments)

Description copied from interface: XenqttApplication

Start the application. This method is called by the main thread that is used in launching Xenqtt.

Specified by:

start in interface XenqttApplication

Parameters:

arguments - The arguments that were supplied. This includes both normal arguments (e.g. -p port) and flags (e.g. -a)

See Also:

XenqttApplication.start(net.sf.xenqtt.AppContext)

stop

public void stop()

Description copied from interface: XenqttApplication

Stop the application. This method is called once the application is halted normally (e.g. CTRL-c). The application should take all appropriate shutdown actions at this point. This is called by the main thread that is used in launching Xenqtt

Specified by:

stop in interface XenqttApplication

See Also:

XenqttApplication.stop()

getUsageText

public String getUsageText()

Description copied from interface: XenqttApplication

Get usage text to display to the user. This is used whenever the user invokes the help option (java -jar xenqtt.jar --help application) or if the user supplies invalid arguments and/or flags to a specific application.

Specified by:

getUsageText in interface XenqttApplication

Returns:

The usage text to display

See Also:

XenqttApplication.getUsageText()