com.diozero.internal.provider.remote.mqtt

Class ProtobufMqttProtocolHandler

java.lang.Object

com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

com.diozero.internal.provider.remote.ProtobufBaseAsyncProtocolHandler

com.diozero.internal.provider.remote.mqtt.ProtobufMqttProtocolHandler

All Implemented Interfaces:

com.diozero.remote.message.RemoteProtocolInterface, Closeable, AutoCloseable, org.eclipse.paho.client.mqttv3.MqttCallback

public class ProtobufMqttProtocolHandler
extends ProtobufBaseAsyncProtocolHandler
implements org.eclipse.paho.client.mqttv3.MqttCallback

Field Summary

Fields inherited from class com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

conditions, lock, responses

Constructor Summary

Constructors

Constructor and Description
ProtobufMqttProtocolHandler(com.diozero.internal.provider.NativeDeviceFactoryInterface deviceFactory)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connectionLost(Throwable cause)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
void	messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
com.diozero.remote.message.GetBoardInfoResponse	request(com.diozero.remote.message.GetBoardInfo request)
com.diozero.remote.message.GpioAnalogReadResponse	request(com.diozero.remote.message.GpioAnalogRead request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioAnalogWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioClose request)
com.diozero.remote.message.GpioDigitalReadResponse	request(com.diozero.remote.message.GpioDigitalRead request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioDigitalWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioEvents request)
com.diozero.remote.message.GpioPwmReadResponse	request(com.diozero.remote.message.GpioPwmRead request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.GpioPwmWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CClose request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2COpen request)
com.diozero.remote.message.I2CReadResponse	request(com.diozero.remote.message.I2CRead request)
com.diozero.remote.message.I2CReadByteResponse	request(com.diozero.remote.message.I2CReadByte request)
com.diozero.remote.message.I2CReadByteResponse	request(com.diozero.remote.message.I2CReadByteData request)
com.diozero.remote.message.I2CReadResponse	request(com.diozero.remote.message.I2CReadI2CBlockData request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWrite request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWriteByte request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWriteByteData request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.I2CWriteI2CBlockData request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionAnalogInputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionAnalogOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionDigitalInputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionDigitalInputOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionDigitalOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.ProvisionPwmOutputDevice request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.SpiClose request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.SpiOpen request)
com.diozero.remote.message.Response	request(com.diozero.remote.message.SpiWrite request)
com.diozero.remote.message.SpiResponse	request(com.diozero.remote.message.SpiWriteAndRead request)
protected void	sendMessage(String topic, com.google.protobuf.GeneratedMessageV3 message)

Methods inherited from class com.diozero.internal.provider.remote.ProtobufBaseAsyncProtocolHandler

requestResponse

Methods inherited from class com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

processEvent, processResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufMqttProtocolHandler

public ProtobufMqttProtocolHandler(com.diozero.internal.provider.NativeDeviceFactoryInterface deviceFactory)

Method Detail

close

public void close()

Specified by:

close in interface com.diozero.remote.message.RemoteProtocolInterface

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

sendMessage

protected void sendMessage(String topic,
                           com.google.protobuf.GeneratedMessageV3 message)
                    throws org.eclipse.paho.client.mqttv3.MqttException

Specified by:

sendMessage in class ProtobufBaseAsyncProtocolHandler

Throws:

org.eclipse.paho.client.mqttv3.MqttException

request

public com.diozero.remote.message.GetBoardInfoResponse request(com.diozero.remote.message.GetBoardInfo request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionDigitalInputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionDigitalOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionDigitalInputOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionPwmOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionAnalogInputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.ProvisionAnalogOutputDevice request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.GpioDigitalReadResponse request(com.diozero.remote.message.GpioDigitalRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioDigitalWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.GpioPwmReadResponse request(com.diozero.remote.message.GpioPwmRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioPwmWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.GpioAnalogReadResponse request(com.diozero.remote.message.GpioAnalogRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioAnalogWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioEvents request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.GpioClose request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2COpen request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadByteResponse request(com.diozero.remote.message.I2CReadByte request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWriteByte request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadResponse request(com.diozero.remote.message.I2CRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadByteResponse request(com.diozero.remote.message.I2CReadByteData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWriteByteData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.I2CReadResponse request(com.diozero.remote.message.I2CReadI2CBlockData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CWriteI2CBlockData request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.I2CClose request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.SpiOpen request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.SpiWrite request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.SpiResponse request(com.diozero.remote.message.SpiWriteAndRead request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

request

public com.diozero.remote.message.Response request(com.diozero.remote.message.SpiClose request)

Specified by:

request in interface com.diozero.remote.message.RemoteProtocolInterface

connectionLost

public void connectionLost(Throwable cause)

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(String topic,
                           org.eclipse.paho.client.mqttv3.MqttMessage message)

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback