Êþº¾ 3
|
< { 6 | } ~
# 6
|
8 6
|
:
|
|
|
#
|
8 h h
|
6 # ¡ ¢
|
£ ¤
|
b ¥ ¦
|
b §
|
b ¨
|
b ©
|
ª « ¬
|
£ # ®
|
¯
|
8 °
|
: ± ² ³
|
´ µ
|
¶ · ¸
|
8 { ¹
|
: º » ¼ ¾ 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 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 L M D E AsyncStockServlet created Ã Ä Å Æ Ç È É Ê Ë M Ì È Í Ê Î Ï
|
text/plain Ð Ñ F G Ò Ó J K Ô Õ Ö × async/AsyncStockContextListener StockTicker Ø Ù Ú async/Stockticker Û Ü java/lang/Exception Async Not Supported L Ñ Ý M Async is not supported. Þ ß à á â È ã ä javax/servlet/AsyncContext i j å æ &javax/servlet/http/HttpServletResponse ç è STOCK# é ê Ñ ë ì # í ì î ì ï Õ ð ñ ò
|
ó M ô M õ ö Ó ÷ Õ ø ù ú û Ü async/AsyncStockServlet ü ý þ *java/util/concurrent/ConcurrentLinkedQueue )java/util/concurrent/atomic/AtomicInteger L ÿ 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 ! 6 < = > ? @ A B D E F G H I J K
|
L M N A *· ² ¹ ± O 1 2 3 P Q R S T N {+¹ +¹ ¹ § f+¹ F+¹ N-*¹
|
, ¹ ² -¶ W² ¶ +¹ ¹ À :*¶ § » Y· ¶ ,¹ ± O : 9 : ; < ' = . > 6 ? > @ H A Z C ` E c F o G z I P 4 Z U V ' 9 W X { Q R { Y Z { [ \ ] û H ^ _ ` a e N )² ¶ M,¹ ,¹ À N*-+¶ !§ :§ÿâ± # O N P S # Q % T ( U P W X ) Q R ) f g ] $ ü hÿ 6 b h ú ú i j N î h+¹ " À #N-¹ $ :%¶ &,¶ '¶ &(¶ &,¶ )¶ &(¶ &,¶ *¶ &(¶ &,¶ +¸ ,¶ &-¶ &¶ .-¹ / ± O : Y
|
Z [ \ " ] ) ^ 2 _ 9 ` B a I b U c \ d a e g f P 4 h Q R h W X h f g
|
^ k \ V l m ^ ` n M N (² ¶ L+¹ +¹ À M,¹ § N§ÿã± # O m o r # p $ s ' t P
|
W X ( Q R ] ! ü hÿ 6 h ú ú o p N 7² +¶ 0¶ 1 ,² ¶ 2 #+¶ 0¹ 3 ¹ 4 M,¹ À N-*¶ 5± O y z % { 1 } 6 P * % q r 1 U V 7 Q R 7 s t ] 6 ^ ` u p N B
|
+¶ 0¹ ± O
|
P
|
Q R
|
s t ^ ` v p N B
|
+¶ 0¹ ± O
|
P
|
Q R
|
s t ^ ` w p N 5 ± O P Q R s t ^ ` x M N > 6¸ 7³ » 8Y· 9³ » :Y· ;³ ± O + - / y z d b c = ½
|
