edu.iu.dsc.tws.common.net.tcp.request

Class RRClient

java.lang.Object

edu.iu.dsc.tws.common.net.tcp.request.RRClient

public class RRClient
extends java.lang.Object

RequestID response client

Constructor Summary

Constructors

Constructor and Description
RRClient(java.lang.String host, int port, Config cfg, Progress looper, int wId, ConnectHandler cHandler)

Method Summary

Modifier and Type	Method and Description
boolean	connect()
void	disconnect()
void	disconnectGraceFully(long waitTime)
boolean	isConnected()
void	registerMessage(Message.Builder builder) Register a message type for sending
void	registerResponseHandler(Message.Builder builder, MessageHandler handler) Register a response handler to a specific message type
RequestID	sendRequest(Message message)
Tuple<RequestID,Message>	sendRequestWaitResponse(Message message, long waitLimit) return requestID and response message throw an exception with the failure reason
void	setHostAndPort(java.lang.String host, int port)
void	tryConnecting()

Methods inherited from class java.lang.Object

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

Constructor Detail

RRClient

public RRClient(java.lang.String host,
                int port,
                Config cfg,
                Progress looper,
                int wId,
                ConnectHandler cHandler)

Method Detail

setHostAndPort

public void setHostAndPort(java.lang.String host,
                           int port)

connect

public boolean connect()

tryConnecting

public void tryConnecting()

disconnect

public void disconnect()

disconnectGraceFully

public void disconnectGraceFully(long waitTime)

isConnected

public boolean isConnected()

sendRequestWaitResponse

public Tuple<RequestID,Message> sendRequestWaitResponse(Message message,
                                                        long waitLimit)
                                                 throws BlockingSendException

return requestID and response message throw an exception with the failure reason

Parameters:

message - message

waitLimit - waitlimit

Returns:

request id

Throws:

BlockingSendException

sendRequest

public RequestID sendRequest(Message message)

registerResponseHandler

public void registerResponseHandler(Message.Builder builder,
                                    MessageHandler handler)

Register a response handler to a specific message type

Parameters:

builder - the response message type

handler - the message callback

registerMessage

public void registerMessage(Message.Builder builder)

Register a message type for sending

Parameters:

builder - the message type