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

Class AbstractServerCall

java.lang.Object

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

All Implemented Interfaces:

ServerCall, ServerStream.Listener, Stream.Listener

Direct Known Subclasses:

ReflectionAbstractServerCall, StubAbstractServerCall

public abstract class AbstractServerCall
extends Object
implements ServerCall, ServerStream.Listener

Nested Class Summary

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

ServerCall.Listener

Field Summary

Fields

Modifier and Type	Field and Description
boolean	autoRequestN
Executor	executor
org.apache.dubbo.rpc.model.FrameworkModel	frameworkModel
Invoker<?>	invoker
String	methodName
static String	REMOTE_ADDRESS_KEY
org.apache.dubbo.rpc.model.ServiceDescriptor	serviceDescriptor
String	serviceName
ServerStream	stream
Long	timeout

Method Summary

Modifier and Type	Method and Description
void	cancelByLocal(Throwable throwable)
void	close(TriRpcStatus status, Map<String,Object> attachments) Close the call.
void	disableAutoRequestN()
boolean	isAutoRequestN()
boolean	isClosed()
void	onCancelByRemote(TriRpcStatus status) Callback when receive cancel signal.
void	onComplete() Callback when no more data from client side
void	onHeader(Map<String,Object> requestMetadata) Callback when receive headers
void	onMessage(byte[] message) Callback when receive message.
void	request(int numMessages) Request more request data from the client.
void	sendMessage(Object message) Send message to client
void	setCompression(String compression)

Methods inherited from class java.lang.Object

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

Field Detail

REMOTE_ADDRESS_KEY

public static final String REMOTE_ADDRESS_KEY

See Also:

Constant Field Values

invoker

public final Invoker<?> invoker

frameworkModel

public final org.apache.dubbo.rpc.model.FrameworkModel frameworkModel

stream

public final ServerStream stream

executor

public final Executor executor

methodName

public final String methodName

serviceName

public final String serviceName

serviceDescriptor

public final org.apache.dubbo.rpc.model.ServiceDescriptor serviceDescriptor

autoRequestN

public boolean autoRequestN

timeout

public Long timeout

Method Detail

onHeader

public void onHeader(Map<String,Object> requestMetadata)

Description copied from interface: ServerStream.Listener

Callback when receive headers

Specified by:

onHeader in interface ServerStream.Listener

Parameters:

requestMetadata - headers received from remote peer

request

public final void request(int numMessages)

Description copied from interface: ServerCall

Request more request data from the client.

Specified by:

request in interface ServerCall

Parameters:

numMessages - max number of messages

sendMessage

public final void sendMessage(Object message)

Description copied from interface: ServerCall

Send message to client

Specified by:

sendMessage in interface ServerCall

Parameters:

message - message to send

onComplete

public final void onComplete()

Description copied from interface: ServerStream.Listener

Callback when no more data from client side

Specified by:

onComplete in interface ServerStream.Listener

onMessage

public final 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 final 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

isClosed

public final boolean isClosed()

cancelByLocal

public void cancelByLocal(Throwable throwable)

setCompression

public void setCompression(String compression)

disableAutoRequestN

public void disableAutoRequestN()

isAutoRequestN

public boolean isAutoRequestN()

close

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

Description copied from interface: ServerCall

Close the call.

Specified by:

close in interface ServerCall

Parameters:

status - status of the call to send to the client

attachments - response attachments