UniversalTestSoftware/server/libs/classes/com/cbsd/universaltestsoftwareserver/netty/MessageQueueManager.class

<EFBFBD><EFBFBD><EFBFBD><EFBFBD>4<00>

java/lang/Object
<init>
()V		

>com/cbsd/universaltestsoftwareserver/netty/MessageQueueManager
messageQueue
$Ljava/util/concurrent/BlockingQueue;
"java/util/concurrent/BlockingQueue
put
(Ljava/lang/Object;)V
java/lang/InterruptedException

java/lang/Thread

currentThread
()Ljava/lang/Thread;

	interrupt	 !
writeToStorageMessageArray
Ljava/util/Queue;#$%&'
java/util/Queue
add
(Ljava/lang/Object;)Z)
java/util/ArrayList
(#,-.
poll
()Ljava/lang/Object;0
9com/cbsd/universaltestsoftwareserver/netty/SendTcpContent2$3
java/util/List#567
isEmpty
()Z#9:;
size
()I=>.
take@
8com/cbsd/universaltestsoftwareserver/netty/ClientMessage	BCD
channels
%Lio/netty/channel/group/ChannelGroup;F5G
#io/netty/channel/group/ChannelGroup	IJK
logger
Lorg/slf4j/Logger;M
*没有客户端连接，无法广播消息OPQRS
org/slf4j/Logger
warn
(Ljava/lang/String;)V
/UVW
getDataBoardId
()Ljava/lang/String;
YZ[\]
$org/apache/commons/lang3/StringUtils
isBlank
(Ljava/lang/CharSequence;)Z
_`a
#addDataToWriteToStorageMessageArray
>(Lcom/cbsd/universaltestsoftwareserver/netty/SendTcpContent;)VFcde

writeAndFlush
?(Ljava/lang/Object;)Lio/netty/channel/group/ChannelGroupFuture;
ghijk
org/slf4j/LoggerFactory
	getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;m
*io/netty/channel/group/DefaultChannelGroup	opqrs
,io/netty/util/concurrent/GlobalEventExecutor
INSTANCE
.Lio/netty/util/concurrent/GlobalEventExecutor;
luv
+(Lio/netty/util/concurrent/EventExecutor;)Vx
(java/util/concurrent/LinkedBlockingQueue
w{
java/util/ArrayDeque
z
	Signature
`Ljava/util/concurrent/BlockingQueue<Lcom/cbsd/universaltestsoftwareserver/netty/ClientMessage;>;
NLjava/util/Queue<Lcom/cbsd/universaltestsoftwareserver/netty/SendTcpContent;>;
Code
LineNumberTable
LocalVariableTable
this
@Lcom/cbsd/universaltestsoftwareserver/netty/MessageQueueManager;

addMessage
=(Lcom/cbsd/universaltestsoftwareserver/netty/ClientMessage;)V

e
 Ljava/lang/InterruptedException;
message
:Lcom/cbsd/universaltestsoftwareserver/netty/ClientMessage;

StackMapTable
MethodParameters
data
;Lcom/cbsd/universaltestsoftwareserver/netty/SendTcpContent;
takeAllData
()Ljava/util/List;
dataList
Ljava/util/List;
element
LocalVariableTypeTable
MLjava/util/List<Lcom/cbsd/universaltestsoftwareserver/netty/SendTcpContent;>;
O()Ljava/util/List<Lcom/cbsd/universaltestsoftwareserver/netty/SendTcpContent;>;
!writeToStorageMessageArrayisEmpty
writeToStorageMessageArraySize
takeMessage
<()Lcom/cbsd/universaltestsoftwareserver/netty/ClientMessage;

Exceptions
broadcastMessage
<clinit>

SourceFile
MessageQueueManager.java!JKCD
}~ !
}	
<00>/

*<2A>
<01><00>
<00>
<00><00>	<00><00><00>m<14>*<2A>
<00>
L<EFBFBD><15><1B>
	<00> 	#!
"$<00>
<00><00>
<00><00><00>L<00>
<00>)`a<00>9
<0B>*<2A>"W<><00>
(
)<00>
<00><00><00>
<00>)<00><00><00><00>%<25>(Y<>*K<><1E>+
<00>/YL<59>*+<2B>1W<><57><EFBFBD>*<2A><00>.12#4<00><00><00><00><00>
<00>
<00><00><00><02>2<>/}<00>)<00>7
<00>!
	<09><1E>4
<00>
<00>
;)<00>;
<00>!
	<09><1E>8
<00>
<00>
@	<00><00><00>$
<0C><07><
<00>?<3F>
<00>
E<00>
	<00>a<00>{
/<2F>A<>E
<00><0E>HL<>N<00>*<2A>T<>X<>*<2A>^<5E>A*<2A>bW<><00>JKLQ R$U.X<00>
/<00><00><00>
<00>
<00><00>
<00>N*<08>f<>H<>lY<6C>n<>t<>A<>wY<77>y<><07>zY<7A>|<7C><1E>
<00>
<00><00>