mirror of
https://github.com/2006-Scape/apollo.git
synced 2026-07-05 16:49:04 +00:00
Fix typo and remove thrown exception.
This commit is contained in:
@@ -72,15 +72,15 @@ public final class ApolloHandler extends ChannelInboundHandlerAdapter {
|
|||||||
|
|
||||||
Session session = attr.get();
|
Session session = attr.get();
|
||||||
|
|
||||||
|
if (message instanceof HttpRequest || message instanceof JagGrabRequest) {
|
||||||
|
session = new UpdateSession(ctx.channel(), serverContext);
|
||||||
|
}
|
||||||
|
|
||||||
if (session != null) {
|
if (session != null) {
|
||||||
session.messageReceived(message);
|
session.messageReceived(message);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (message instanceof HttpRequest || message instanceof JagGrabRequest) {
|
|
||||||
session = new UpdateSession(ctx.channel(), serverContext);
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: Perhaps let HandshakeMessage implement Message to remove this explicit check
|
// TODO: Perhaps let HandshakeMessage implement Message to remove this explicit check
|
||||||
if (message instanceof HandshakeMessage) {
|
if (message instanceof HandshakeMessage) {
|
||||||
HandshakeMessage handshakeMessage = (HandshakeMessage) message;
|
HandshakeMessage handshakeMessage = (HandshakeMessage) message;
|
||||||
|
|||||||
@@ -26,7 +26,7 @@ public final class HandshakeDecoder extends ByteToMessageDecoder {
|
|||||||
private static final Logger logger = Logger.getLogger(HandshakeDecoder.class.getName());
|
private static final Logger logger = Logger.getLogger(HandshakeDecoder.class.getName());
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception {
|
protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) {
|
||||||
if (!buffer.isReadable()) {
|
if (!buffer.isReadable()) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@@ -49,7 +49,7 @@ public final class HandshakeDecoder extends ByteToMessageDecoder {
|
|||||||
|
|
||||||
default:
|
default:
|
||||||
ByteBuf data = buffer.readBytes(buffer.readableBytes());
|
ByteBuf data = buffer.readBytes(buffer.readableBytes());
|
||||||
logger.info(String.format("Unecpected handshake request received: %d data: %s", id, data.toString()));
|
logger.info(String.format("Unexpected handshake request received: %d data: %s", id, data.toString()));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user