程序包 com.alibaba.dubbo.remoting.transport

类 AbstractPeer

com.alibaba.dubbo.remoting.transport.AbstractPeer

所有已实现的接口:

ChannelHandler, Endpoint

直接已知子类:

AbstractChannel, AbstractEndpoint

public abstract class AbstractPeer
extends 
implements Endpoint, ChannelHandler

AbstractPeer

构造器概要

构造器

构造器	说明
AbstractPeer(URL url, ChannelHandler handler)

方法概要

修饰符和类型	方法	说明
void	caught(Channel ch, ex)	on exception caught.
void	close()	close the channel.
void	close(int timeout)	Graceful close the channel.
void	connected(Channel ch)	on channel connected.
void	disconnected(Channel ch)	on channel disconnected.
ChannelHandler	getChannelHandler()	get channel handler.
ChannelHandler	getDelegateHandler()	Return the final handler (which may have been wrapped).
ChannelHandler	getHandler()	已过时。
URL	getUrl()	get url.
boolean	isClosed()	is closed.
boolean	isClosing()
void	received(Channel ch, msg)	on message received.
void	message)	send message.
void	sent(Channel ch, msg)	on message sent.
void	startClose()

从类继承的方法 java.lang.

, , , , , , , ,

从接口继承的方法 com.alibaba.dubbo.remoting.Endpoint

getLocalAddress, send

构造器详细资料

AbstractPeer

public AbstractPeer(URL url,
                    ChannelHandler handler)

方法详细资料

send

public void send( message)
          throws RemotingException

从接口复制的说明: Endpoint

send message.

指定者:

send 在接口中 Endpoint

抛出:

RemotingException

close

public void close()

从接口复制的说明: Endpoint

close the channel.

指定者:

close 在接口中 Endpoint

close

public void close(int timeout)

从接口复制的说明: Endpoint

Graceful close the channel.

指定者:

close 在接口中 Endpoint

startClose

public void startClose()

指定者:

startClose 在接口中 Endpoint

getUrl

public URL getUrl()

从接口复制的说明: Endpoint

get url.

指定者:

getUrl 在接口中 Endpoint

返回:

url

getChannelHandler

public ChannelHandler getChannelHandler()

从接口复制的说明: Endpoint

get channel handler.

指定者:

getChannelHandler 在接口中 Endpoint

返回:

channel handler

getHandler

public ChannelHandler getHandler()

已过时。

返回:

ChannelHandler

getDelegateHandler

public ChannelHandler getDelegateHandler()

Return the final handler (which may have been wrapped). This method should be distinguished with getChannelHandler() method

返回:

ChannelHandler

isClosed

public boolean isClosed()

从接口复制的说明: Endpoint

is closed.

指定者:

isClosed 在接口中 Endpoint

返回:

closed

isClosing

public boolean isClosing()

connected

public void connected(Channel ch)
               throws RemotingException

从接口复制的说明: ChannelHandler

on channel connected.

指定者:

connected 在接口中 ChannelHandler

参数:

ch - channel.

抛出:

RemotingException

disconnected

public void disconnected(Channel ch)
                  throws RemotingException

从接口复制的说明: ChannelHandler

on channel disconnected.

指定者:

disconnected 在接口中 ChannelHandler

参数:

ch - channel.

抛出:

RemotingException

sent

public void sent(Channel ch,
                  msg)
          throws RemotingException

从接口复制的说明: ChannelHandler

on message sent.

指定者:

sent 在接口中 ChannelHandler

参数:

ch - channel.

msg - message.

抛出:

RemotingException

received

public void received(Channel ch,
                      msg)
              throws RemotingException

从接口复制的说明: ChannelHandler

on message received.

指定者:

received 在接口中 ChannelHandler

参数:

ch - channel.

msg - message.

抛出:

RemotingException

caught

public void caught(Channel ch,
                    ex)
            throws RemotingException

从接口复制的说明: ChannelHandler

on exception caught.

指定者:

caught 在接口中 ChannelHandler

参数:

ch - channel.

ex - exception.

抛出:

RemotingException