String function ( String arg0 , PubSubMessageCodec < T > arg1 ) { PubSubMessage < T > loc0 = new PubSubMessage < T > ( ) ; loc0 . setType ( PubSubMessageType . SUBSCRIBE ) ; loc0 . setTopic ( arg0 ) ; return arg1 . formatMessage ( loc0 ) ; }
constructsubscribemessage . concode_field_sep ObjectMapper mapper concode_field_sep String formatMessage concode_elem_sep PubSubMessage<T> parseMessage concode_elem_sep String constructUnsubscribeMessage concode_elem_sep String constructSubscribeNumSubscribersMessage concode_elem_sep String constructPublishMessage concode_elem_sep String constructUnsubscribeNumSubscribersMessage