1

zj

2024-06-13 8eea5be3b36875bd4ffe70e6c3a5bb07b1d829bf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
Êþº¾4S
12
34    5
67    89
:;<
=
>?@A
BCD
1E
log
Lorg/slf4j/Logger;
WORKING_EVENTS
,Ljava/util/concurrent/ConcurrentLinkedQueue;
    Signature
ZLjava/util/concurrent/ConcurrentLinkedQueue<Lcom/yami/trading/bean/data/domain/Realtime;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
/Lcom/yami/trading/huobi/data/job/RealtimeQueue;
add
/(Lcom/yami/trading/bean/data/domain/Realtime;)V

e
Ljava/lang/Throwable;
item
,Lcom/yami/trading/bean/data/domain/Realtime;
 StackMapTable7
size
()I
poll
.()Lcom/yami/trading/bean/data/domain/Realtime;?
<clinit>

SourceFile
RealtimeQueue.java
The item must not be null.FGH!I
java/lang/Throwable
RealtimeQueue add fail -> {}JKLMN)*+O
*com/yami/trading/bean/data/domain/Realtime
 RealtimeQueue poll() fail  -> {}
-com/yami/trading/huobi/data/job/RealtimeQueuePQR
*java/util/concurrent/ConcurrentLinkedQueue
java/lang/Object
org/springframework/util/Assert
notNull
'(Ljava/lang/Object;Ljava/lang/String;)V
(Ljava/lang/Object;)Z

getMessage
()Ljava/lang/String;
org/slf4j/Logger
error
'(Ljava/lang/String;Ljava/lang/Object;)V
()Ljava/lang/Object;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!



/

*·
±
    
     !"
~!*¸²*¶W§L²+¶    ¹
±
 #$
!%&'Q(    )*

²¶¬

    +,
† 
K²¶À K§L²+¶    ¹
*°
 !#$
%&'ÿ
-
(.
/¸³»Y·³±


/0