io.capsisBridgeClient

Class AbstractCapsisBridgeClientManager

java.lang.Object

io.capsisBridgeClient.AbstractCapsisBridgeClientManager

Direct Known Subclasses:

CapsisBridgeClientManagerDirect, CapsisBridgeClientManagerGrpc

public abstract class AbstractCapsisBridgeClientManager
extends java.lang.Object

This class abstracts the CapsisBridgeClientManager to allow gRPC mode and direct mode interfacing to the ServiceManager. The gRPC client will send RPC requests over the channel to the gRPC service, whereas the direct client will directly call ServiceManager methods in the same process and thread.

Since:

2020-12-22

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractCapsisBridgeClient.TestHelper	testHelper

Constructor Summary

Constructors

Constructor and Description
AbstractCapsisBridgeClientManager(java.lang.String _target)

Method Summary

Modifier and Type	Method and Description
static void	info(java.lang.String msg, java.lang.Object... params) Utility method.
abstract AbstractCapsisBridgeClient	initializeService(int port, int heapMB) Initializes a new CapsisBridgeClient (either in direct or gRPC mode) and returns it.
abstract void	shutDownNow() Shuts down the client communication channel (does nothing in direct mode)
abstract void	shutDownService(int id) Shuts down the server (does nothing in direct mode)
static void	warning(java.lang.String msg, java.lang.Object... params) Utility method.

Methods inherited from class java.lang.Object

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

Field Detail

testHelper

protected AbstractCapsisBridgeClient.TestHelper testHelper

Constructor Detail

AbstractCapsisBridgeClientManager

public AbstractCapsisBridgeClientManager(java.lang.String _target)

Method Detail

info

public static void info(java.lang.String msg,
                        java.lang.Object... params)

Utility method. Outputs an INFO log trace to the logger

Parameters:

msg - The message to log

params - any other params

warning

public static void warning(java.lang.String msg,
                           java.lang.Object... params)

Utility method. Outputs a WARNING log trace to the logger

Parameters:

msg - The message to log

params - any other params

initializeService

public abstract AbstractCapsisBridgeClient initializeService(int port,
                                                             int heapMB)

Initializes a new CapsisBridgeClient (either in direct or gRPC mode) and returns it.

Parameters:

port - The port onto which the new service should listen. Use 0 to let the service choose a port. This parameter is ignored in direct mode.

heapMB - The heap size in MegaBytes to allocate for the new service

Returns:

the new CapsisBridgeClient

shutDownService

public abstract void shutDownService(int id)

Shuts down the server (does nothing in direct mode)

Parameters:

id - The server id (port) to shut down. Use 0 to shut down all servers.

shutDownNow

public abstract void shutDownNow()
                          throws java.lang.InterruptedException

Shuts down the client communication channel (does nothing in direct mode)

Throws:

java.lang.InterruptedException