4w/org/eclipse/ece/messaging/Example04CoalesceTest/org/eclipse/ece/messaging/core/BasicExampleTestcontext"Lorg/osgi/framework/BundleContext; mqttConfig#Lorg/osgi/service/cm/Configuration;wsConfig()VCode   org/osgi/framework/FrameworkUtil  getBundle.(Ljava/lang/Class;)Lorg/osgi/framework/Bundle; org/osgi/framework/Bundle getBundleContext$()Lorg/osgi/framework/BundleContext;      LineNumberTableLocalVariableTablethis1Lorg/eclipse/ece/messaging/Example04CoalesceTest;before Exceptions(,org/eclipse/paho/client/mqttv3/MqttExceptionRuntimeVisibleAnnotationsLorg/junit/Before; , -.setup%(Lorg/osgi/framework/BundleContext;)Vafter1java/io/IOExceptionLorg/junit/After; 465!org/osgi/service/cm/Configuration 7 delete StackMapTabletestPushStreamCoalescing;java/lang/ExceptionLorg/junit/Test;> MQTTService @ ABgetConfiguration7(Ljava/lang/String;)Lorg/osgi/service/cm/Configuration;D WSService 4F GH getProperties()Ljava/util/Dictionary; JLKorg/junit/Assert MN assertNull(Ljava/lang/Object;)VPjava/util/Hashtable OS brokerUrlUtcp://localhost:1883 WYXjava/util/Dictionary Z[put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;]type_mqttaws://localhost:8888cws 4e fgupdate(Ljava/util/Dictionary;)Vi (type=mqtt) k lm createFilter/(Ljava/lang/String;)Lorg/osgi/framework/Filter;u0 q rs getService0(Lorg/osgi/framework/Filter;J)Ljava/lang/Object;u)org/gecko/osgi/messaging/MessagingService Jw xN assertNotNullz (type=ws)|mqtt.temperatur t~  subscribe9(Ljava/lang/String;)Lorg/osgi/util/pushstream/PushStream;/events mqtt.wind #org/osgi/util/pushstream/PushStream mergeL(Lorg/osgi/util/pushstream/PushStream;)Lorg/osgi/util/pushstream/PushStream; applyT(Lorg/eclipse/ece/messaging/Example04CoalesceTest;)Lorg/osgi/util/function/Function; mapH(Lorg/osgi/util/function/Function;)Lorg/osgi/util/pushstream/PushStream; #()Lorg/osgi/util/function/Function; coalesceI(ILorg/osgi/util/function/Function;)Lorg/osgi/util/pushstream/PushStream; accept()Ljava/util/function/Consumer; forEach>(Ljava/util/function/Consumer;)Lorg/osgi/util/promise/Promise;start c-mqtt01 java/lang/String getBytes()[B java/nio/ByteBuffer wrap([B)Ljava/nio/ByteBuffer; t publish*(Ljava/lang/String;Ljava/nio/ByteBuffer;)V#java/util/concurrent/CountDownLatch (I)V java/util/concurrent/TimeUnit SECONDSLjava/util/concurrent/TimeUnit; await#(JLjava/util/concurrent/TimeUnit;)Zstart c-mqtt03start c-mqtt02start stop c-mqtt01 stop c-mqtt02 stop c-mqtt03stopmqttPropertiesLjava/util/Dictionary; wsProperties mqttFilterLorg/osgi/framework/Filter; mqttService+Lorg/gecko/osgi/messaging/MessagingService;wsFilter wsService subscribe01%Lorg/osgi/util/pushstream/PushStream; subscribe02 subscribe03 waitLatch%Ljava/util/concurrent/CountDownLatch;LocalVariableTypeTable;ILorg/osgi/util/pushstream/PushStream;convertMessageToString6(Lorg/gecko/osgi/messaging/Message;)Ljava/lang/String;  org/gecko/osgi/messaging/Message payload()Ljava/nio/ByteBuffer; array ([B)Vmessage"Lorg/gecko/osgi/messaging/Message;lambda$1*(Ljava/util/Collection;)Ljava/lang/String; java/util/Collection stream()Ljava/util/stream/Stream; ()Ljava/util/function/Function; java/util/stream/Stream 8(Ljava/util/function/Function;)Ljava/util/stream/Stream;,   java/util/stream/Collectors   joining6(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;  collect0(Ljava/util/stream/Collector;)Ljava/lang/Object;stringCollectionLjava/util/Collection;*Ljava/util/Collection;lambda$3(Ljava/lang/String;)V java/lang/System outLjava/io/PrintStream;java/lang/StringBuilder$Merged push stream in 'batch-mode': !  # $%append-(Ljava/lang/String;)Ljava/lang/StringBuilder; ' ()toString()Ljava/lang/String; +-,java/io/PrintStream .printlnstrLjava/lang/String;lambda$2&(Ljava/lang/String;)Ljava/lang/String;4 locationId6l 8 9: replaceAll8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;<location>client@valueBvD unit:"mps", FHtimeJtLtstampN timestampi SourceFileExample04CoalesceTest.javaLorg/junit/runner/RunWith;(Lorg/mockito/runners/MockitoJUnitRunner;BootstrapMethods VXW"java/lang/invoke/LambdaMetafactory YZ metafactory(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;U&(Ljava/lang/Object;)Ljava/lang/Object;\ _ ^\ d cN i h\ n 12m2 InnerClassess%java/lang/invoke/MethodHandles$Lookupujava/lang/invoke/MethodHandlesLookup!   W* ***!/123/" #$% &')* 7 **+! 78"  #$/ &'0)2 w+**3***3*!<=>@A%B*D" +#$89 &:)< e **=?**C?*EL+IOYQL+RTVW+\^VW*EM,IOYQM,R`VW,\bVW*,d*+dhjN*-npt:vyj:*npt:v{}:}:}:  :  *W{Y:  WŶY:  W{ǶY:  WɶY:  W{˶{Ͷ϶Ѷ!+I JMN"P*Q3R<UFVJXRY[Zd]n^xa~bcfghknqtu'8BN_iu"z #$F~cVJ<,!   >F,!   EY+!"#$ &: g* !vwv"    BY *"&*!" /0 12 J*357;57=57?A7CE7GI7KI7MI7!"w xyz%{.|7}@~" JO0PQ) R@cST*[]`a[bef[gjk[lopq rtv