subscribenumsubscribers . concode_field_sep int ioThreadMultiplier concode_elem_sep PubSubMessageCodec<Object> codec concode_elem_sep String password concode_elem_sep Logger logger concode_elem_sep String loginUrl concode_elem_sep AtomicReference<Throwable> throwable concode_elem_sep AsyncHttpClient client concode_elem_sep WebSocket connection concode_elem_sep ObjectMapper mapper concode_elem_sep String userName concode_elem_sep URI uri concode_field_sep void setPassword concode_elem_sep void onError concode_elem_sep void onError concode_elem_sep void openConnectionAsync concode_elem_sep void subscribe concode_elem_sep void openConnection concode_elem_sep void setUri concode_elem_sep void setIoThreadMultiplier concode_elem_sep void setLoginUrl concode_elem_sep boolean isConnectionOpen concode_elem_sep void assertUsable concode_elem_sep void onClose concode_elem_sep void onClose concode_elem_sep void unsubscribeNumSubscribers concode_elem_sep void onOpen concode_elem_sep void onOpen concode_elem_sep void setUserName concode_elem_sep void unsubscribe concode_elem_sep void publish concode_elem_sep void onMessage concode_elem_sep void onMessage concode_elem_sep void setup concode_elem_sep void teardown
void function ( String arg0 ) { assertUsable ( ) ; connection . sendMessage ( PubSubMessageCodec . constructSubscribeNumSubscribersMessage ( arg0 , codec ) ) ; }