|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeClient
public class HeaderExchangeClient
DefaultMessageClient
Constructor Summary | |
---|---|
HeaderExchangeClient(Client client,
boolean needHeartbeat)
|
Method Summary | |
---|---|
void |
close()
close the channel. |
void |
close(int timeout)
Graceful close the channel. |
Object |
getAttribute(String key)
get attribute. |
ChannelHandler |
getChannelHandler()
get channel handler. |
ExchangeHandler |
getExchangeHandler()
get message handler. |
InetSocketAddress |
getLocalAddress()
get local address. |
InetSocketAddress |
getRemoteAddress()
get remote address. |
URL |
getUrl()
get url. |
boolean |
hasAttribute(String key)
has attribute. |
boolean |
isClosed()
is closed. |
boolean |
isConnected()
is connected. |
void |
reconnect()
reconnect. |
void |
removeAttribute(String key)
remove attribute. |
ResponseFuture |
request(Object request)
send request. |
ResponseFuture |
request(Object request,
int timeout)
send request. |
void |
reset(Parameters parameters)
Deprecated. |
void |
reset(URL url)
reset. |
void |
send(Object message)
send message. |
void |
send(Object message,
boolean sent)
send message. |
void |
setAttribute(String key,
Object value)
set attribute. |
void |
startClose()
|
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public HeaderExchangeClient(Client client, boolean needHeartbeat)
Method Detail |
---|
public ResponseFuture request(Object request) throws RemotingException
ExchangeChannel
request
in interface ExchangeChannel
RemotingException
public URL getUrl()
Endpoint
getUrl
in interface Endpoint
public InetSocketAddress getRemoteAddress()
Channel
getRemoteAddress
in interface Channel
public ResponseFuture request(Object request, int timeout) throws RemotingException
ExchangeChannel
request
in interface ExchangeChannel
RemotingException
public ChannelHandler getChannelHandler()
Endpoint
getChannelHandler
in interface Endpoint
public boolean isConnected()
Channel
isConnected
in interface Channel
public InetSocketAddress getLocalAddress()
Endpoint
getLocalAddress
in interface Endpoint
public ExchangeHandler getExchangeHandler()
ExchangeChannel
getExchangeHandler
in interface ExchangeChannel
public void send(Object message) throws RemotingException
Endpoint
send
in interface Endpoint
RemotingException
public void send(Object message, boolean sent) throws RemotingException
Endpoint
send
in interface Endpoint
sent
- 是否已发送完成
RemotingException
public boolean isClosed()
Endpoint
isClosed
in interface Endpoint
public void close()
Endpoint
close
in interface Endpoint
public void close(int timeout)
Endpoint
close
in interface Endpoint
close
in interface ExchangeChannel
public void startClose()
startClose
in interface Endpoint
public void reset(URL url)
Resetable
reset
in interface Resetable
@Deprecated public void reset(Parameters parameters)
reset
in interface Client
public void reconnect() throws RemotingException
Client
reconnect
in interface Client
RemotingException
public Object getAttribute(String key)
Channel
getAttribute
in interface Channel
key
- key.
public void setAttribute(String key, Object value)
Channel
setAttribute
in interface Channel
key
- key.value
- value.public void removeAttribute(String key)
Channel
removeAttribute
in interface Channel
key
- key.public boolean hasAttribute(String key)
Channel
hasAttribute
in interface Channel
key
- key.
public String toString()
toString
in class Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |