com.diozero.internal.provider.remote

Class ProtobufBaseAsyncProtocolHandler

java.lang.Object

com.diozero.internal.provider.remote.BaseAsyncProtocolHandler

com.diozero.internal.provider.remote.ProtobufBaseAsyncProtocolHandler

All Implemented Interfaces:

com.diozero.remote.message.RemoteProtocolInterface, Closeable, AutoCloseable

Direct Known Subclasses:

ProtobufMqttProtocolHandler, ProtobufWebSocketProtocolHandler

public abstract class ProtobufBaseAsyncProtocolHandler
extends BaseAsyncProtocolHandler

Field Summary

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

conditions, lock, responses

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected com.diozero.remote.message.Response	requestResponse(String url, com.google.protobuf.GeneratedMessageV3 request, String correlationId)
protected abstract void	sendMessage(String url, com.google.protobuf.GeneratedMessageV3 message)

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

Methods inherited from interface com.diozero.remote.message.RemoteProtocolInterface

close, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request, request

Constructor Detail

ProtobufBaseAsyncProtocolHandler

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

Method Detail

sendMessage

protected abstract void sendMessage(String url,
                                    com.google.protobuf.GeneratedMessageV3 message)
                             throws Exception

Throws:

Exception

requestResponse

protected com.diozero.remote.message.Response requestResponse(String url,
                                                              com.google.protobuf.GeneratedMessageV3 request,
                                                              String correlationId)