Package 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:

RemoteProtocolInterface, java.io.Closeable, java.lang.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	Description
ProtobufMqttProtocolHandler(NativeDeviceFactoryInterface deviceFactory)

Method Summary

Modifier and Type	Method	Description
void	close()
void	connectionLost(java.lang.Throwable cause)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
GetBoardInfoResponse	request(GetBoardInfo request)
GpioAnalogReadResponse	request(GpioAnalogRead request)
Response	request(GpioAnalogWrite request)
Response	request(GpioClose request)
GpioDigitalReadResponse	request(GpioDigitalRead request)
Response	request(GpioDigitalWrite request)
Response	request(GpioEvents request)
GpioPwmReadResponse	request(GpioPwmRead request)
Response	request(GpioPwmWrite request)
Response	request(I2CClose request)
Response	request(I2COpen request)
I2CReadResponse	request(I2CRead request)
I2CReadByteResponse	request(I2CReadByte request)
I2CReadByteResponse	request(I2CReadByteData request)
I2CReadResponse	request(I2CReadI2CBlockData request)
Response	request(I2CWrite request)
Response	request(I2CWriteByte request)
Response	request(I2CWriteByteData request)
Response	request(I2CWriteI2CBlockData request)
Response	request(ProvisionAnalogInputDevice request)
Response	request(ProvisionAnalogOutputDevice request)
Response	request(ProvisionDigitalInputDevice request)
Response	request(ProvisionDigitalInputOutputDevice request)
Response	request(ProvisionDigitalOutputDevice request)
Response	request(ProvisionPwmOutputDevice request)
Response	request(SpiClose request)
Response	request(SpiOpen request)
Response	request(SpiWrite request)
SpiResponse	request(SpiWriteAndRead request)
protected void	sendMessage(java.lang.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 Details

ProtobufMqttProtocolHandler

public ProtobufMqttProtocolHandler(NativeDeviceFactoryInterface deviceFactory)

Method Details

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface RemoteProtocolInterface

sendMessage

protected void sendMessage(java.lang.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 GetBoardInfoResponse request(GetBoardInfo request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionDigitalInputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionDigitalOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionDigitalInputOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionPwmOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionAnalogInputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(ProvisionAnalogOutputDevice request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioDigitalReadResponse request(GpioDigitalRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioDigitalWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioPwmReadResponse request(GpioPwmRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioPwmWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public GpioAnalogReadResponse request(GpioAnalogRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioAnalogWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioEvents request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(GpioClose request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2COpen request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CReadByteResponse request(I2CReadByte request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteByte request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CReadResponse request(I2CRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CReadByteResponse request(I2CReadByteData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteByteData request)

Specified by:

request in interface RemoteProtocolInterface

request

public I2CReadResponse request(I2CReadI2CBlockData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CWriteI2CBlockData request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(I2CClose request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SpiOpen request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SpiWrite request)

Specified by:

request in interface RemoteProtocolInterface

request

public SpiResponse request(SpiWriteAndRead request)

Specified by:

request in interface RemoteProtocolInterface

request

public Response request(SpiClose request)

Specified by:

request in interface RemoteProtocolInterface

connectionLost

public void connectionLost(java.lang.Throwable cause)

Specified by:

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

messageArrived

public void messageArrived(java.lang.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