Class EventBusBridgeService

java.lang.Object

io.vertx.grpc.event.v1alpha.EventBusBridgeService

All Implemented Interfaces:

EventBusBridge

Direct Known Subclasses:

EventBusBridgeGrpcService

public class EventBusBridgeService
extends Object
implements EventBusBridge

Provides support for RPC methods implementations of the EventBusBridge gRPC service.

The following methods of this class should be overridden to provide an implementation of the service:

• Publish
• Send
• Request
• Subscribe
• Unsubscribe
• Ping

Constructor Summary

Constructors

Constructor	Description
EventBusBridgeService()

Method Summary

Modifier and Type	Method	Description
Future<com.google.protobuf.Empty>	ping(com.google.protobuf.Empty request)	Override this method to implement the Ping RPC.
protected void	ping(com.google.protobuf.Empty request, Completable<com.google.protobuf.Empty> response)
Future<com.google.protobuf.Empty>	publish(PublishOp request)	Override this method to implement the Publish RPC.
protected void	publish(PublishOp request, Completable<com.google.protobuf.Empty> response)
Future<EventBusMessage>	request(RequestOp request)	Override this method to implement the Request RPC.
protected void	request(RequestOp request, Completable<EventBusMessage> response)
Future<com.google.protobuf.Empty>	send(SendOp request)	Override this method to implement the Send RPC.
protected void	send(SendOp request, Completable<com.google.protobuf.Empty> response)
Future<ReadStream<EventBusMessage>>	subscribe(SubscribeOp request)	Override this method to implement the Subscribe RPC.
protected void	subscribe(SubscribeOp request, WriteStream<EventBusMessage> response)
Future<com.google.protobuf.Empty>	unsubscribe(UnsubscribeOp request)	Override this method to implement the Unsubscribe RPC.
protected void	unsubscribe(UnsubscribeOp request, Completable<com.google.protobuf.Empty> response)

Methods inherited from class Object

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

Constructor Details

EventBusBridgeService

public EventBusBridgeService()

Method Details

publish

public Future<com.google.protobuf.Empty> publish(PublishOp request)

Override this method to implement the Publish RPC.

Specified by:

publish in interface EventBusBridge

publish

protected void publish(PublishOp request,
 Completable<com.google.protobuf.Empty> response)

send

public Future<com.google.protobuf.Empty> send(SendOp request)

Override this method to implement the Send RPC.

Specified by:

send in interface EventBusBridge

send

protected void send(SendOp request,
 Completable<com.google.protobuf.Empty> response)

request

public Future<EventBusMessage> request(RequestOp request)

Override this method to implement the Request RPC.

Specified by:

request in interface EventBusBridge

request

protected void request(RequestOp request,
 Completable<EventBusMessage> response)

unsubscribe

public Future<com.google.protobuf.Empty> unsubscribe(UnsubscribeOp request)

Override this method to implement the Unsubscribe RPC.

Specified by:

unsubscribe in interface EventBusBridge

unsubscribe

protected void unsubscribe(UnsubscribeOp request,
 Completable<com.google.protobuf.Empty> response)

ping

public Future<com.google.protobuf.Empty> ping(com.google.protobuf.Empty request)

Override this method to implement the Ping RPC.

Specified by:

ping in interface EventBusBridge

ping

protected void ping(com.google.protobuf.Empty request,
 Completable<com.google.protobuf.Empty> response)

subscribe

public Future<ReadStream<EventBusMessage>> subscribe(SubscribeOp request)

Override this method to implement the Subscribe RPC.

Specified by:

subscribe in interface EventBusBridge

subscribe

protected void subscribe(SubscribeOp request,
 WriteStream<EventBusMessage> response)