Package org.jgroups.upgrade_server

Class UpgradeClient

java.lang.Object

org.jgroups.upgrade_server.UpgradeClient

public class UpgradeClient
extends Object

Since:

x.y

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceStub	asyncStub
protected org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceBlockingStub	blocking_stub
protected io.grpc.ManagedChannel	channel
protected static String	CLUSTER
protected org.jgroups.upgrade_server.Address	local_addr
protected io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Request>	send_stream
protected org.jgroups.upgrade_server.View	view

Constructor Summary

Constructors

Constructor	Description
UpgradeClient(String addr)

Method Summary

Modifier and Type	Method	Description
protected static void	handleMessage(org.jgroups.upgrade_server.Message msg)
protected void	handleUnicast(String line)
protected void	handleView(org.jgroups.upgrade_server.View v)
static void	main(String[] args)
protected void	start(int port)
protected void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected io.grpc.ManagedChannel channel

asyncStub

protected org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceStub asyncStub

blocking_stub

protected org.jgroups.upgrade_server.UpgradeServiceGrpc.UpgradeServiceBlockingStub blocking_stub

send_stream

protected io.grpc.stub.StreamObserver<org.jgroups.upgrade_server.Request> send_stream

local_addr

protected final org.jgroups.upgrade_server.Address local_addr

view

protected org.jgroups.upgrade_server.View view

CLUSTER

protected static final String CLUSTER

See Also:

Constant Field Values

Constructor Detail

UpgradeClient

public UpgradeClient(String addr)

Method Detail

start

protected void start(int port)
              throws InterruptedException

Throws:

InterruptedException

handleUnicast

protected void handleUnicast(String line)

handleView

protected void handleView(org.jgroups.upgrade_server.View v)

handleMessage

protected static void handleMessage(org.jgroups.upgrade_server.Message msg)

stop

protected void stop()
             throws InterruptedException

Throws:

InterruptedException

main

public static void main(String[] args)
                 throws InterruptedException

Throws:

InterruptedException