import org.apache.cassandra.transport.messages.EventMessage; //导入依赖的package包/类
@Override
public void channelRead0(ChannelHandlerContext ctx, Message.Response r)
{
    try
    {
        if (r instanceof EventMessage)
        {
            if (eventHandler != null)
                eventHandler.onEvent(((EventMessage) r).event);
        }
        else
            responses.put(r);
    }
    catch (InterruptedException ie)
    {
        throw new RuntimeException(ie);
    }
}
 

import org.apache.cassandra.transport.messages.EventMessage; //导入依赖的package包/类
public void send(Event event)
{
    groups.get(event.type).writeAndFlush(new EventMessage(event));
}
 

import org.apache.cassandra.transport.messages.EventMessage; //导入依赖的package包/类
public void send(Event event)
{
    groups.get(event.type).write(new EventMessage(event));
}