Êþº¾ 4 ´ +chat/server/netty/NettyWSChannelInitializer #io/netty/channel/ChannelInitializer MQTT_SUBPROTOCOL_CSV_LIST Ljava/lang/String; ConstantValue mqtt, mqttv3.1, mqttv3.1.1 messageMetricsCollector .Lchat/server/moquette/MessageMetricsCollector; bytesMetricsCollector ,Lchat/server/moquette/BytesMetricsCollector; <init> ()V Code
|
LineNumberTable LocalVariableTable this -Lchat/server/netty/NettyWSChannelInitializer; initChannel *(Lio/netty/channel/socket/SocketChannel;)V
|
Exceptions java/lang/Exception timeout
|
! java/lang/Integer " # valueOf (I)Ljava/lang/Integer;
|
% ' & chat/server/Configer ( )
|
getInteger :(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
|
+ , - intValue ()I / 1 0 %io/netty/channel/socket/SocketChannel 2 3 pipeline $()Lio/netty/channel/ChannelPipeline; 5 ,chat/server/moquette/MqttBytesMetricsHandler 7
|
4 9 : /(Lchat/server/moquette/BytesMetricsCollector;)V < )io/netty/handler/timeout/IdleStateHandler
|
; > ? (III)V A +chat/server/moquette/MqttIdleTimeoutHandler
|
@
|
D E F createSSLHandler #()Lio/netty/channel/ChannelHandler; H /io/netty/handler/codec/http/HttpResponseEncoder
|
G K .io/netty/handler/codec/http/HttpRequestDecoder
|
J N 0io/netty/handler/codec/http/HttpObjectAggregator
|
M Q R (I)V T Eio/netty/handler/codec/http/websocketx/WebSocketServerProtocolHandler V /org/fusesource/mqtt
|
S X Y '(Ljava/lang/String;Ljava/lang/String;)V [ %chat/server/moquette/MqttDecodHandler
|
Z
|
^ ` _ %chat/server/moquette/MqttEncodHandler a F getInstance c .chat/server/moquette/MqttMessageMetricsHandler e
|
|
b g h 1(Lchat/server/moquette/MessageMetricsCollector;)V j -chat/server/moquette/MqttMessageLoggerHandler
|
i m chat/server/im/IMDispatcher
|
l p bytemetrics r t s io/netty/channel/ChannelPipeline u v addFirst W(Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline; x idleStateHandler r z { v addLast } idleEventHandler r addAfter i(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline; ssl
httpEncoder httpDecoder
|
aggregator webSocketHandler ws2bytebufDecoder 0chat/server/netty/WebSocketFrameToByteBufDecoder
|
bytebuf2wsEncoder 0chat/server/netty/ByteBufToWebSocketFrameEncoder
|
decoder encoder metrics messageLogger handler channel 'Lio/netty/channel/socket/SocketChannel; timeoutSeconds I "Lio/netty/channel/ChannelPipeline; bytesMetricsHandler !Lio/netty/channel/ChannelHandler; timeoutHandler
|
sslHandler messageMetricsHandler
|
dispatcher setMessageMetricsCollector setBytesMetricsCollector (Lio/netty/channel/Channel;)V
|
¯
|
SourceFile NettyWSChannelInitializer.java Signature NLio/netty/channel/ChannelInitializer<Lio/netty/channel/socket/SocketChannel;>; !
|
/ *· ± F
|
¸ ¸ $¶ *=+¹ . N» 4Y*´ 6· 8:» ;Y · =:» @Y· B:*· C:» GY· I:» JY· L: » MYO· P:
|
» SYU· W: » ZY· \: ¸ ]: » bY*´ d· f:» iY· k:» lY· n:-o¹ q W-w¹ y W-w|¹ ~ W-¹ y W-¹ y W- ¹ y W-
|
¹ y W- ¹ y W-» Y· ¹ y W-» Y· ¹ y W- ¹ y W- ¹ y W-¹ y W-¹ y W-¹ y W± ~ " $ " % . & 7 ( = ) F * O + Z , g . p / u 0 1 2 4 5 ª 6 · 8 Â 9 Í : Ø ; ã < î = þ > @ A$ B/ C: DE E ¬ F F ¡ 8 ¢ £ 1 2 ¤ "$ ¥ ¦ . x ¦ 7 § ¦ = ¨ ¦ F
¦ O ÷ ¦ Z ì ¦
|
g ß ¦ p Ö ¦ u Ñ ¦ Ä © ¦ » ¦ ² ª ¦ « h > *+µ d±
|
H I
|
¬ : > *+µ 6±
|
L M E F , ° W D ) *+À /¶ ®± ° ± ² ³
|
