com.alibaba.dubbo.remoting.exchange.support.header
Class HeartbeatHandler
java.lang.Object
com.alibaba.dubbo.remoting.transport.AbstractChannelHandlerDelegate
com.alibaba.dubbo.remoting.exchange.support.header.HeartbeatHandler
- All Implemented Interfaces:
- ChannelHandler, ChannelHandlerDelegate
public class HeartbeatHandler
- extends AbstractChannelHandlerDelegate
- Author:
- kimi
KEY_READ_TIMESTAMP
public static String KEY_READ_TIMESTAMP
KEY_WRITE_TIMESTAMP
public static String KEY_WRITE_TIMESTAMP
HeartbeatHandler
public HeartbeatHandler(ChannelHandler handler)
connected
public void connected(Channel channel)
throws RemotingException
- Description copied from interface:
ChannelHandler
- on channel connected.
- Specified by:
connected
in interface ChannelHandler
- Overrides:
connected
in class AbstractChannelHandlerDelegate
- Parameters:
channel
- channel.
- Throws:
RemotingException
disconnected
public void disconnected(Channel channel)
throws RemotingException
- Description copied from interface:
ChannelHandler
- on channel disconnected.
- Specified by:
disconnected
in interface ChannelHandler
- Overrides:
disconnected
in class AbstractChannelHandlerDelegate
- Parameters:
channel
- channel.
- Throws:
RemotingException
sent
public void sent(Channel channel,
Object message)
throws RemotingException
- Description copied from interface:
ChannelHandler
- on message sent.
- Specified by:
sent
in interface ChannelHandler
- Overrides:
sent
in class AbstractChannelHandlerDelegate
- Parameters:
channel
- channel.message
- message.
- Throws:
RemotingException
received
public void received(Channel channel,
Object message)
throws RemotingException
- Description copied from interface:
ChannelHandler
- on message received.
- Specified by:
received
in interface ChannelHandler
- Overrides:
received
in class AbstractChannelHandlerDelegate
- Parameters:
channel
- channel.message
- message.
- Throws:
RemotingException
Copyright © 2012–2017 Alibaba. All rights reserved.