public class JMSSource
extends org.wso2.siddhi.core.stream.input.source.Source
Constructor and Description |
---|
JMSSource() |
Modifier and Type | Method and Description |
---|---|
void |
connect(org.wso2.siddhi.core.stream.input.source.Source.ConnectionCallback connectionCallback) |
Map<String,Object> |
currentState() |
void |
destroy() |
void |
disconnect() |
Class[] |
getOutputEventClasses() |
void |
init(org.wso2.siddhi.core.stream.input.source.SourceEventListener sourceEventListener,
org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
String[] requestedTransportPropertyNames,
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, String[] requestedTransportPropertyNames, 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 Class[] getOutputEventClasses()
getOutputEventClasses
in class org.wso2.siddhi.core.stream.input.source.Source
public void connect(org.wso2.siddhi.core.stream.input.source.Source.ConnectionCallback connectionCallback) 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.