4),org/eclipse/ece/messaging/Example03MergeTest/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;      LineNumberTableLocalVariableTablethis.Lorg/eclipse/ece/messaging/Example03MergeTest;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 StackMapTabletestPushStreamMerge;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; applyQ(Lorg/eclipse/ece/messaging/Example03MergeTest;)Lorg/osgi/util/function/Function; mapH(Lorg/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/lang/String;)V java/lang/System outLjava/io/PrintStream;java/lang/StringBuilderMerged push stream no filter: append-(Ljava/lang/String;)Ljava/lang/StringBuilder;  toString()Ljava/lang/String; java/io/PrintStream printlnstrLjava/lang/String; SourceFileExample03MergeTest.javaLorg/junit/runner/RunWith;value(Lorg/mockito/runners/MockitoJUnitRunner;BootstrapMethods "java/lang/invoke/LambdaMetafactory  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;&(Ljava/lang/Object;)Ljava/lang/Object;  N   InnerClasses%%java/lang/invoke/MethodHandles$Lookup'java/lang/invoke/MethodHandlesLookup!   W* ***!/123/" #$% &')* 7 **+! 78"  #$/ &'0)2 w+**3***3*!<=>@A%B*D" +#$89 &:)< V **=?**C?*EL+IOYQL+RTVW+\^VW*EM,IOYQM,R`VW,\bVW*,d*+dhjN*-npt:vyj:*npt:v{}:}:}:  :  *W{Y:  WY:  W{Y:  W¶Y:  W{Ķ{ƶȶʶ!*I JMN"P*Q3R<UFVJXRY[Zd]n^xa~bcfghknqtuy{|-7CT^j{"z #$F~XK?1!  >F!  EY+!"#$  AY*!u"     )  c!"# $&(