Êþº¾ 3
|
; 5
" 5
|
7 5
|
9
|
|
|
"
|
7 ¡ ¢
|
5 £ ¤ ¥ " ¦ §
|
¨ ©
|
a ª «
|
a ¬
|
a
|
a ®
|
¯ ° ±
|
¨ ² " ³
|
´
|
7 µ
|
9 ¶ · ¸
|
¹ º
|
» ¼ ½
|
7 ¾
|
9 ¿ À Á Ã serialVersionUID J ConstantValue log Lorg/apache/juli/logging/Log; clients ,Ljava/util/concurrent/ConcurrentLinkedQueue; Signature JLjava/util/concurrent/ConcurrentLinkedQueue<Ljavax/servlet/AsyncContext;>; clientcount +Ljava/util/concurrent/atomic/AtomicInteger; <init> ()V Code LineNumberTable LocalVariableTable this Lasync/AsyncStockServlet; service R(Ljavax/servlet/http/HttpServletRequest;Ljavax/servlet/http/HttpServletResponse;)V ticker Lasync/Stockticker; actx Ljavax/servlet/AsyncContext; req 'Ljavax/servlet/http/HttpServletRequest; resp (Ljavax/servlet/http/HttpServletResponse; StackMapTable
|
Exceptions Ä Å tick Æ Stock InnerClasses (Lasync/Stockticker$Stock;)V i$ Ljava/util/Iterator; stock Lasync/Stockticker$Stock; Ç º Æ ¢
|
writeStock 8(Ljavax/servlet/AsyncContext;Lasync/Stockticker$Stock;)V response writer Ljava/io/PrintWriter; shutdown
|
onComplete (Ljavax/servlet/AsyncEvent;)V sc Ljavax/servlet/ServletContext; event Ljavax/servlet/AsyncEvent; onError onTimeout onStartAsync <clinit>
|
SourceFile AsyncStockServlet.java K L C D AsyncStockServlet created È É Ê Ë Ì Í Î Ï Ð L Ñ Í Ò Ï Ó Ô
|
text/plain Õ Ö E F × Ø I J Ù Ú Û Ü StockTicker Ý Þ ß async/Stockticker à á java/lang/Exception Async Not Supported K Ö â L Async is not supported. ã ä å æ Ç ç Í è é javax/servlet/AsyncContext n o ê ë &javax/servlet/http/HttpServletResponse ì í STOCK# î ï Ö ð ñ # ò ñ ó ñ ô Ú õ ö ÷
|
ø L ù L ú û Ø ü Ú ý þ ÿ á async/AsyncStockServlet *java/util/concurrent/ConcurrentLinkedQueue )java/util/concurrent/atomic/AtomicInteger K javax/servlet/http/HttpServlet async/Stockticker$TickListener TickListener javax/servlet/AsyncListener javax/servlet/ServletException java/io/IOException async/Stockticker$Stock java/util/Iterator org/apache/juli/logging/Log info (Ljava/lang/Object;)V %javax/servlet/http/HttpServletRequest isAsyncStarted ()Z getAsyncContext ()Ljavax/servlet/AsyncContext; complete isAsyncSupported
|
startAsync addListener (Ljavax/servlet/AsyncListener;)V setContentType (Ljava/lang/String;)V add (Ljava/lang/Object;)Z incrementAndGet ()I getServletContext ()Ljavax/servlet/ServletContext; javax/servlet/ServletContext getAttribute &(Ljava/lang/String;)Ljava/lang/Object; addTickListener #(Lasync/Stockticker$TickListener;)V printStackTrace sendError (ILjava/lang/String;)V iterator ()Ljava/util/Iterator; hasNext next ()Ljava/lang/Object; getResponse !()Ljavax/servlet/ServletResponse; getWriter ()Ljava/io/PrintWriter; java/io/PrintWriter write getSymbol ()Ljava/lang/String; getValueAsString getLastChangeAsString getCnt java/lang/String valueOf (I)Ljava/lang/String; flush flushBuffer javax/servlet/AsyncEvent remove decrementAndGet
|
getRequest ()Ljavax/servlet/ServletRequest; javax/servlet/ServletRequest removeTickListener "org/apache/juli/logging/LogFactory getLog 0(Ljava/lang/Class;)Lorg/apache/juli/logging/Log; (I)V ! 5 ; < = > ? @ A C D E F G H I J
|
K L M A *· ² ¹ ± N 1 2 3 O P Q R S M {+¹ +¹ ¹ § f+¹ F+¹ N-*¹
|
, ¹ ² -¶ W² ¶ +¹ ¹ À :*¶ § » Y· ¶ ,¹ ± N : 9 : ; < ' = . > 6 ? > @ H A Z C ` E c F o G z I O 4 Z T U ' 9 V W { P Q { X Y { Z [ \ û H ] ^ _ ` d M · )² ¶ M,¹ ,¹ À N*-+¶ § :§ÿâ± # N N P S # Q % T ( U O * V W ! e f ) P Q ) g h \ $ ü iÿ j k i l mú ú n o M î h+¹ ! À "N-¹ # :$¶ %,¶ &¶ %'¶ %,¶ (¶ %'¶ %,¶ )¶ %'¶ %,¶ *¸ +¶ %,¶ %¶ --¹ . ± N : Y
|
Z [ \ " ] ) ^ 2 _ 9 ` B a I b U c \ d a e g f O 4 h P Q h V W h g h
|
^ p [ V q r ] _ s L M © (² ¶ L+¹ +¹ À M,¹ § N§ÿã± # N m o r # p $ s ' t O
|
V W e f ( P Q \ ! ü iÿ j i l mú ú t u M 7² +¶ /¶ 0 ,² ¶ 1 #+¶ /¹ 2 ¹ 3 M,¹ À N-*¶ 4± N y z % { 1 } 6 O * % v w 1 T U 7 P Q 7 x y \ 6 ] _ z u M B
|
+¶ /¹ ± N
|
O
|
P Q
|
x y ] _ { u M B
|
+¶ /¹ ± N
|
O
|
P Q
|
x y ] _ | u M 5 ± N O P Q x y ] _ } L M ? 5¸ 6³ » 7Y· 8³ » 9Y· :³ ± N + - / ~ c a b < Â
|
