void function ( String arg0 ) { topicMap . remove ( arg0 ) ; }
removes the subscribe topic concode_field_sep int tupleBlast concode_elem_sep Map<String,QoS> topicMap concode_elem_sep ArrayBlockingQueue<Message> holdingBuffer concode_elem_sep int DEFAULT_BUFFER_SIZE concode_elem_sep MqttClientConfig mqttClientConfig concode_elem_sep Logger LOG concode_elem_sep MQTT client concode_elem_sep int DEFAULT_BLAST_SIZE concode_elem_sep BlockingConnection connection concode_elem_sep Thread thread concode_elem_sep int bufferSize concode_field_sep void emitTuple concode_elem_sep void addSubscribeTopic concode_elem_sep void setMqttClientConfig concode_elem_sep void endWindow concode_elem_sep void initializeConnection concode_elem_sep void deactivate concode_elem_sep void beginWindow concode_elem_sep void setTupleBlast concode_elem_sep void activate concode_elem_sep void emitTuples concode_elem_sep void setup concode_elem_sep MqttClientConfig getMqttClientConfig concode_elem_sep void teardown