File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change 1111import weborb .types .IAdaptingType ;
1212
1313import java .util .Arrays ;
14+ import java .util .HashMap ;
1415import java .util .Map ;
1516import java .util .concurrent .ConcurrentHashMap ;
1617import java .util .concurrent .ConcurrentLinkedDeque ;
@@ -274,7 +275,9 @@ private Emitter subOn( RTSubscription subscription )
274275
275276 private Emitter subOff ( String subscriptionId )
276277 {
277- final Emitter emitter = connectionManager .get ().emit ( "SUB_OFF" , serialize ( subscriptionId ) );
278+ Map <String , String > request = new HashMap <>( );
279+ request .put ( "id" , subscriptionId );
280+ final Emitter emitter = connectionManager .get ().emit ( "SUB_OFF" , serialize ( request ) );
278281 logger .info ( "subOff called" );
279282 return emitter ;
280283 }
You can’t perform that action at this time.
0 commit comments