Êþº¾ 4 ¥ .chat/server/moquette/MqttMessageMetricsHandler %io/netty/channel/ChannelDuplexHandler logger Lorg/apache/log4j/Logger; ATTR_KEY_METRICS Lio/netty/util/AttributeKey; Signature <Lio/netty/util/AttributeKey<Lchat/server/moquette/Metrics;>; ATTR_KEY_USERNAME 0Lio/netty/util/AttributeKey<Ljava/lang/String;>; collector .Lchat/server/moquette/MessageMetricsCollector; <clinit> ()V Code
|
org/apache/log4j/Logger getLogger ,(Ljava/lang/Class;)Lorg/apache/log4j/Logger; MessageMetrics
|
io/netty/util/AttributeKey ! valueOf 0(Ljava/lang/String;)Lio/netty/util/AttributeKey; # % username ' LineNumberTable LocalVariableTable <init> 1(Lchat/server/moquette/MessageMetricsCollector;)V
|
- * / this 0Lchat/server/moquette/MqttMessageMetricsHandler; channelActive +(Lio/netty/channel/ChannelHandlerContext;)V
|
Exceptions 6 java/lang/Exception 8 : 9 &io/netty/channel/ChannelHandlerContext ; < channel ()Lio/netty/channel/Channel; > @ ? io/netty/channel/Channel A B attr 7(Lio/netty/util/AttributeKey;)Lio/netty/util/Attribute; D chat/server/moquette/Metrics
|
C - G I H io/netty/util/Attribute J K set (Ljava/lang/Object;)V
|
M 2 3 ctx (Lio/netty/channel/ChannelHandlerContext; Lio/netty/util/Attribute; LocalVariableTypeTable 9Lio/netty/util/Attribute<Lchat/server/moquette/Metrics;>; channelRead =(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;)V G V W X get ()Ljava/lang/Object;
|
C Z [ \ incrementRead (J)V 8 ^ _ ` fireChannelRead <(Ljava/lang/Object;)Lio/netty/channel/ChannelHandlerContext; msg Ljava/lang/Object; metrics Lchat/server/moquette/Metrics; write ^(Lio/netty/channel/ChannelHandlerContext;Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
|
C h i \ incrementWrote 8 k e l U(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)Lio/netty/channel/ChannelFuture; promise !Lio/netty/channel/ChannelPromise; close L(Lio/netty/channel/ChannelHandlerContext;Lio/netty/channel/ChannelPromise;)V r java/lang/String t v java/lang/StringBuilder x channel<
|
u z * { (Ljava/lang/String;)V
|
u } ~ append -(Ljava/lang/String;)Ljava/lang/StringBuilder; > closing after
|
u ~ -(Ljava/lang/Object;)Ljava/lang/StringBuilder;
|
u toString ()Ljava/lang/String;
|
K info
|
C
|
readLength ()J
|
,chat/server/moquette/MessageMetricsCollector \ sumReadMessages
|
C wroteLength
|
\ sumWroteMessages
|
o p userId Ljava/lang/String; StackMapTable getMessageMetrics :(Lio/netty/channel/Channel;)Lchat/server/moquette/Metrics; Lio/netty/channel/Channel;
|
SourceFile MqttMessageMetricsHandler.java !
|
|
|
|
E ¸ ³ ¸ ³ "$¸ ³ &± ( ) * + F
|
*· ,*+µ .± ( )
|
0 1
|
2 3 4 5 ~ "+¹ 7 ² "¹ = M,» CY· E¹ F *+· L± ( ! " $ ! % ) " 0 1 " N O A P Q A R S T 4 5 y %+¹ 7 ² "¹ = ¹ U À CN-
|
¶ Y+,¹ ] W± ( ) * + $ , ) * % 0 1 % N O % a b c d e f 4 5 (+¹ 7 ² "¹ = ¹ U À C:
|
¶ g+,-¹ j W± ( 0 1 2 ' 3 ) 4 ( 0 1 ( N O ( a b ( m n c d o p 4 5 ø u+¹ 7 ² "¹ = ¹ U À CN+¹ 7 ² &¹ = ¹ U À q:Ç s:² » uYw· y¶ |¶ |-¶ ¶
¶ *´ .-¶ ¶ *´ .-¶ ¶ *+,· ± ( & 7 8 / 9 4 : 8 = X ? c @ n B t C ) 4 u 0 1 u N O u m n ^ c d / F ý 8 C q ¡ < *² "¹ = ¹ U À C° ( F ) ; ¢ £ ¤
|
