Constructor and Description |
---|
InputManager(SiddhiAppContext siddhiAppContext,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap) |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
InputHandler |
constructInputHandler(String streamId) |
void |
disconnect() |
InputHandler |
getInputHandler(String streamId) |
public InputManager(SiddhiAppContext siddhiAppContext, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap, ConcurrentMap<String,StreamJunction> streamJunctionMap)
public InputHandler getInputHandler(String streamId)
public void connect()
public void disconnect()
public InputHandler constructInputHandler(String streamId)
Copyright © 2019. All rights reserved.