org.apache.dubbo.rpc.protocol.tri.call

Class TripleClientCall

java.lang.Object

org.apache.dubbo.rpc.protocol.tri.call.TripleClientCall

All Implemented Interfaces:

ClientCall, ClientStream.Listener, Stream.Listener

public class TripleClientCall
extends Object
implements ClientCall, ClientStream.Listener

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.dubbo.rpc.protocol.tri.call.ClientCall

ClientCall.Listener

Constructor Summary

Constructors

Constructor and Description
TripleClientCall(org.apache.dubbo.remoting.api.Connection connection, Executor executor, org.apache.dubbo.rpc.model.FrameworkModel frameworkModel)

Method Summary

Modifier and Type	Method and Description
void	cancelByLocal(Throwable t) Send reset to server, no more data will be sent or received.
void	halfClose() No more data will be sent.
boolean	isAutoRequest()
void	onCancelByRemote(TriRpcStatus status) Callback when receive cancel signal.
void	onComplete(TriRpcStatus status, Map<String,Object> attachments, Map<String,String> excludeHeaders) Callback when request completed.
void	onMessage(byte[] message) Callback when receive message.
void	onStart() Callback when stream started.
void	request(int messageNumber) Request max n message from server
void	sendMessage(Object message) Send message to server
void	setAutoRequest(boolean autoRequest) Set auto request for this call
void	setCompression(String compression) Set compression algorithm for request.
org.apache.dubbo.common.stream.StreamObserver<Object>	start(RequestMetadata metadata, ClientCall.Listener responseListener)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.rpc.protocol.tri.stream.ClientStream.Listener

onComplete

Constructor Detail

TripleClientCall

public TripleClientCall(org.apache.dubbo.remoting.api.Connection connection,
                        Executor executor,
                        org.apache.dubbo.rpc.model.FrameworkModel frameworkModel)

Method Detail

onMessage

public void onMessage(byte[] message)

Description copied from interface: Stream.Listener

Callback when receive message. Note this method may be called many times if is a streaming .

Specified by:

onMessage in interface Stream.Listener

Parameters:

message - message received from remote peer

onCancelByRemote

public void onCancelByRemote(TriRpcStatus status)

Description copied from interface: Stream.Listener

Callback when receive cancel signal.

Specified by:

onCancelByRemote in interface Stream.Listener

Parameters:

status - the cancel status

onComplete

public void onComplete(TriRpcStatus status,
                       Map<String,Object> attachments,
                       Map<String,String> excludeHeaders)

Description copied from interface: ClientStream.Listener

Callback when request completed.

Specified by:

onComplete in interface ClientStream.Listener

Parameters:

status - response status

attachments - attachments received from remote peer

excludeHeaders - triple protocol reserved data

onStart

public void onStart()

Description copied from interface: ClientStream.Listener

Callback when stream started.

Specified by:

onStart in interface ClientStream.Listener

cancelByLocal

public void cancelByLocal(Throwable t)

Description copied from interface: ClientCall

Send reset to server, no more data will be sent or received.

Specified by:

cancelByLocal in interface ClientCall

Parameters:

t - cause

request

public void request(int messageNumber)

Description copied from interface: ClientCall

Request max n message from server

Specified by:

request in interface ClientCall

Parameters:

messageNumber - max message number

sendMessage

public void sendMessage(Object message)

Description copied from interface: ClientCall

Send message to server

Specified by:

sendMessage in interface ClientCall

Parameters:

message - request to send

halfClose

public void halfClose()

Description copied from interface: ClientCall

No more data will be sent.

Specified by:

halfClose in interface ClientCall

setCompression

public void setCompression(String compression)

Description copied from interface: ClientCall

Set compression algorithm for request.

Specified by:

setCompression in interface ClientCall

Parameters:

compression - compression algorithm

start

public org.apache.dubbo.common.stream.StreamObserver<Object> start(RequestMetadata metadata,
                                                                   ClientCall.Listener responseListener)

Specified by:

start in interface ClientCall

Parameters:

metadata - request metadata

responseListener - the listener to receive response

Returns:

the stream observer representing the request sink

isAutoRequest

public boolean isAutoRequest()

Specified by:

isAutoRequest in interface ClientCall

Returns:

true if this call is auto request

setAutoRequest

public void setAutoRequest(boolean autoRequest)

Description copied from interface: ClientCall

Set auto request for this call

Specified by:

setAutoRequest in interface ClientCall

Parameters:

autoRequest - whether auto request is enabled