public class RcfProtoChannel
extends java.lang.Object
Constructor and Description |
---|
RcfProtoChannel(Endpoint endpoint)
Constructs a RPC channel from an endpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
callMethod(MethodDescriptor method,
RpcController controller,
Message request,
Message responsePrototype,
|
boolean |
completed() |
void |
connect()
Connects to the server.
|
void |
delete() |
void |
disconnect()
Disconencts from the server.
|
java.lang.String |
errorText()
If Failed() is true, returns a human-readable description of the error.
|
boolean |
failed()
After a call has finished, returns true if the call failed.
|
protected void |
finalize() |
boolean |
getAsynchronousRpcMode()
Gets the asynchronous RPC mode.
|
Certificate |
getCaCertificate()
Gets the certificate authority for the channel.
|
Certificate |
getCertificate()
Gets the SSL certificate for the channel.
|
CertificateValidationCallback |
getCertificateValidationCallback() |
long |
getConnectTimeoutMs()
Gets the connect timeout value, in milliseconds.
|
boolean |
getEnableCompression()
Returns the transport level compression setting for this connection.
|
java.lang.String |
getEnableSchannelCertificateValidation()
Gets the Schannel certificate validation setting.
|
java.lang.String |
getHttpProxy()
Returns the network address of the HTTP proxy server.
|
int |
getHttpProxyPort()
Returns the port number of the HTTP proxy server.
|
java.lang.String |
getKerberosSpn()
Returns the Kerberos SPN to use when connecting.
|
java.lang.String |
getOpenSslCipherSuite()
Gets the OpenSSL cipher suite.
|
java.lang.String |
getPassword()
Returns the Windows password to use when connecting.
|
int |
getPingBackIntervalMs()
Returns the ping back interval of the connection.
|
long |
getRemoteCallTimeoutMs()
Gets the remote call timeout value, in milliseconds.
|
Message |
getResponse() |
SslImplementation |
getSslImplementation()
Gets the SSL implementation.
|
TransportProtocol |
getTransportProtocol()
Gets the transport protocol being used by the channel.
|
TransportType |
getTransportType()
Returns the transport type of the connection.
|
java.lang.String |
getUsername()
Returns the Windows username to use when connecting.
|
void |
setAsynchronousRpcMode(boolean enable)
Sets the asynchronous RPC mode.
|
void |
setCaCertificate(Certificate certificatePtr)
Sets the certificate authority for the channel.
|
void |
setCertificate(Certificate certificatePtr)
Sets the SSL certificate for the channel.
|
void |
setCertificateValidationCallback(CertificateValidationCallback certValidationCallback) |
void |
setConnectTimeoutMs(long connectTimeoutMs)
Sets the connect timeout value, in milliseconds.
|
void |
setEnableCompression(boolean enableCompression)
Sets the transport level compression setting for this connection.
|
void |
setEnableSchannelCertificateValidation(java.lang.String peerName)
Sets the Schannel certificate validation setting.
|
void |
setHttpProxy(java.lang.String httpProxy)
Sets the network address of the HTTP proxy server, through which to route remote calls.
|
void |
setHttpProxyPort(int httpProxyPort)
Sets the port number of the HTTP proxy server, through which to route remote calls.
|
void |
setKerberosSpn(java.lang.String kerberosSpn)
Sets the Kerberos SPN to use when connecting.
|
void |
setOpenSslCipherSuite(java.lang.String cipherSuite)
Sets the OpenSSL cipher suite.
|
void |
setPassword(java.lang.String password)
Sets the Windows password to use when connecting.
|
void |
setPingBackIntervalMs(int pingBackIntervalMs)
Sets the ping back interval of the connection, in milliseconds.
|
void |
setRemoteCallTimeoutMs(long remoteCallTimeoutMs)
Sets the remote call timeout value, in milliseconds.
|
void |
setSslImplementation(SslImplementation sslImplementation)
Sets the SSL implementation to be used by the channel.
|
void |
setTransportProtocol(TransportProtocol protocol)
Sets the transport protocol being used by the channel.
|
void |
setUsername(java.lang.String username)
Sets the Windows username to use when connecting.
|
void |
startCancel()
Advises the RPC system that the caller desires that the RPC call be canceled.
|
public RcfProtoChannel(Endpoint endpoint)
public void callMethod(MethodDescriptor method, RpcController controller, Message request, Message responsePrototype,done)
public Message getResponse()
public void setCertificateValidationCallback(CertificateValidationCallback certValidationCallback)
public CertificateValidationCallback getCertificateValidationCallback()
protected void finalize()
finalize
in class java.lang.Object
public void delete()
public boolean failed()
public java.lang.String errorText()
public void startCancel()
public boolean completed()
public void connect()
public void disconnect()
public void setRemoteCallTimeoutMs(long remoteCallTimeoutMs)
public long getRemoteCallTimeoutMs()
public void setConnectTimeoutMs(long connectTimeoutMs)
public long getConnectTimeoutMs()
public void setTransportProtocol(TransportProtocol protocol)
public TransportProtocol getTransportProtocol()
public void setAsynchronousRpcMode(boolean enable)
public boolean getAsynchronousRpcMode()
public void setPingBackIntervalMs(int pingBackIntervalMs)
public int getPingBackIntervalMs()
public void setHttpProxy(java.lang.String httpProxy)
public java.lang.String getHttpProxy()
public void setHttpProxyPort(int httpProxyPort)
public int getHttpProxyPort()
public TransportType getTransportType()
public void setUsername(java.lang.String username)
public java.lang.String getUsername()
public void setPassword(java.lang.String password)
public java.lang.String getPassword()
public void setKerberosSpn(java.lang.String kerberosSpn)
public java.lang.String getKerberosSpn()
public void setEnableCompression(boolean enableCompression)
public boolean getEnableCompression()
public void setCertificate(Certificate certificatePtr)
public Certificate getCertificate()
public void setCaCertificate(Certificate certificatePtr)
public Certificate getCaCertificate()
public void setOpenSslCipherSuite(java.lang.String cipherSuite)
public java.lang.String getOpenSslCipherSuite()
public void setEnableSchannelCertificateValidation(java.lang.String peerName)
public java.lang.String getEnableSchannelCertificateValidation()
public void setSslImplementation(SslImplementation sslImplementation)
public SslImplementation getSslImplementation()