Java 类org.jboss.netty.channel.ChannelEvent 实例源码

项目：traccar-mongodb 文件：BaseProtocolDecoder.java

@Override
public void handleUpstream(
        ChannelHandlerContext ctx, ChannelEvent evt) throws Exception {
    if (!(evt instanceof MessageEvent)) {
        ctx.sendUpstream(evt);
        return;
    }

    MessageEvent e = (MessageEvent) evt;
    Object originalMessage = e.getMessage();
    Object decodedMessage = decode(ctx, e.getChannel(), e.getRemoteAddress(), originalMessage);
    if (originalMessage == decodedMessage) {
        ctx.sendUpstream(evt);
    } else if (decodedMessage != null) {
        fireMessageReceived(ctx, decodedMessage, e.getRemoteAddress());
    }
}

项目：andy 文件：FrameDecoder.java

public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e, Object m, FrameHandler frameHandler) throws Exception {

        ChannelBuffer input = (ChannelBuffer) m;
        if (!input.readable()) {
            return;
        }

        if (cumulation == null) {
            try {
                // the cumulation buffer is not created yet so just pass the input to callDecode(...) method
                callDecode(ctx, null, input, frameHandler);
            } finally {
                updateCumulation(ctx, input);
            }

        } else {
            input = appendToCumulation(input);
            try {
                callDecode(ctx, null, input, frameHandler);
            } finally {
                updateCumulation(ctx, input);
            }
        }
    }

项目：netty-isdn-transport 文件：IsdnServerPipelineSink.java

private void handleServerChannel(ChannelEvent e) {
    IsdnServerChannel channel = (IsdnServerChannel) e.getChannel();
    ChannelFuture future = e.getFuture();
    if (e instanceof ChannelStateEvent) {
        ChannelStateEvent stateEvent = (ChannelStateEvent) e;
        ChannelState state = stateEvent.getState();
        Object value = stateEvent.getValue();
        switch (state) {
        case OPEN:
            if (Boolean.FALSE.equals(value)) {
                close(channel, future);
            }
            break;
        case BOUND:
            if (value != null) {
                bind(channel, future, (IsdnSocketAddress) value);
            } else {
                logger.warn("eventSunk() :: UNHANDLED (BOUND value=null) --> {}", e);
                close(channel, future);
            }
            break;
        default:
            logger.warn("eventSunk() :: UNHANDLED --> {}", e);
        }
    }
}

项目：netty-isdn-transport 文件：IsdnConnectionHandler.java

@Transition (on = WRITE_REQUESTED, in = NCCI_ACTIVE)
    public void ncciDataB3Req(IsdnChannel channel, ChannelBuffer message, ChannelHandlerContext ctx, ChannelEvent channelEvent) throws CapiException {

        if (message == ChannelBuffers.EMPTY_BUFFER) {
            // send flush() signal downstream
            LOGGER.warn("ncciDataB3Req() :: empty buffer");
            handleEvent(WRITE_REQUESTED, ctx, channelEvent);
            return;
        }

        if (LOGGER.isTraceEnabled()) {
            try {
                LOGGER.trace("ncciDataB3Req() :: data = {}", message.duplicate().toString(US_ASCII_CHARSET));
            } catch (Throwable t) {
                LOGGER.trace("ncciDataB3Req()");
            }
        }

        CapiMessage dataReq = createDataB3Req(channel, message);
//        channel.write(dataReq);
        write(ctx, channelEvent.getFuture(), dataReq);

    }