flume-websocket module reorganise