public class JMSSource
extends org.wso2.siddhi.core.stream.input.source.Source
Constructor and Description |
---|
JMSSource() |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
Map<String,Object> |
currentState() |
void |
destroy() |
void |
disconnect() |
void |
init(org.wso2.siddhi.core.stream.input.source.SourceEventListener sourceEventListener,
org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
org.wso2.siddhi.core.util.config.ConfigReader configReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext) |
void |
pause() |
void |
restoreState(Map<String,Object> state) |
void |
resume() |
public void init(org.wso2.siddhi.core.stream.input.source.SourceEventListener sourceEventListener, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
init
in class org.wso2.siddhi.core.stream.input.source.Source
public void connect() throws org.wso2.siddhi.core.exception.ConnectionUnavailableException
connect
in class org.wso2.siddhi.core.stream.input.source.Source
org.wso2.siddhi.core.exception.ConnectionUnavailableException
public void disconnect()
disconnect
in class org.wso2.siddhi.core.stream.input.source.Source
public void destroy()
destroy
in class org.wso2.siddhi.core.stream.input.source.Source
public void pause()
pause
in class org.wso2.siddhi.core.stream.input.source.Source
public void resume()
resume
in class org.wso2.siddhi.core.stream.input.source.Source
Copyright © 2017 WSO2. All rights reserved.