Package org.fisco.bcos.sdk.channel

Class ChannelMsgHandler

java.lang.Object

org.fisco.bcos.sdk.channel.ChannelMsgHandler

All Implemented Interfaces:

MsgHandler

public class ChannelMsgHandler
extends java.lang.Object
implements MsgHandler

An implementation of channel.

Constructor Summary

Constructors

Constructor	Description
ChannelMsgHandler()

Method Summary

Modifier and Type	Method	Description
void	addConnectHandler(MsgHandler handler)
void	addDisconnectHandler(MsgHandler handler)
void	addEstablishHandler(MsgHandler handler)
void	addMessageHandler(MsgType type, MsgHandler handler)
void	addSeq2CallBack(java.lang.String seq, ResponseCallback callback)
java.util.Map<java.lang.String,io.netty.channel.ChannelHandlerContext>	getAvailablePeer()
void	onConnect(io.netty.channel.ChannelHandlerContext ctx)	OnConnect action.
void	onDisconnect(io.netty.channel.ChannelHandlerContext ctx)	OnDisconnect action Called when one connection disconnect.
void	onMessage(io.netty.channel.ChannelHandlerContext ctx, Message msg)	OnMessage action.
void	removeSeq(java.lang.String seq)

Methods inherited from class java.lang.Object

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

Constructor Details

ChannelMsgHandler

public ChannelMsgHandler()

Method Details

getAvailablePeer

public java.util.Map<java.lang.String,io.netty.channel.ChannelHandlerContext> getAvailablePeer()

addConnectHandler

public void addConnectHandler(MsgHandler handler)

addEstablishHandler

public void addEstablishHandler(MsgHandler handler)

addMessageHandler

public void addMessageHandler(MsgType type, MsgHandler handler)

addDisconnectHandler

public void addDisconnectHandler(MsgHandler handler)

addSeq2CallBack

public void addSeq2CallBack(java.lang.String seq, ResponseCallback callback)

removeSeq

public void removeSeq(java.lang.String seq)

onConnect

public void onConnect(io.netty.channel.ChannelHandlerContext ctx)

Description copied from interface: MsgHandler

OnConnect action. Called when connect success.

Specified by:

onConnect in interface MsgHandler

Parameters:

ctx - ChannelHandlerContext of the connection from netty

onMessage

public void onMessage(io.netty.channel.ChannelHandlerContext ctx, Message msg)

Description copied from interface: MsgHandler

OnMessage action. Called when one message comes from the network.

Specified by:

onMessage in interface MsgHandler

Parameters:

ctx - ChannelHandlerContext of the connection from netty

msg - Message from the network

onDisconnect

public void onDisconnect(io.netty.channel.ChannelHandlerContext ctx)

Description copied from interface: MsgHandler

OnDisconnect action Called when one connection disconnect.

Specified by:

onDisconnect in interface MsgHandler

Parameters:

ctx - ChannelHandlerContext of the connection from netty