JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
B
C
D
F
G
I
J
O
P
R
S
B
beforeExecute(Thread, Runnable)
- Method in class org.wso2.siddhi.extension.input.transport.jms.executor.
PausableThreadPoolExecutor
C
clear()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
connect()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
CONNECTION_FACTORY_JNDI_NAME
- Static variable in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
CONNECTION_FACTORY_TYPE
- Static variable in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
currentState()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
D
DESTINATION
- Static variable in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
destroy()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
disconnect()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
F
FACTORY_INITIAL
- Static variable in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
G
getCustomPropertyMapping()
- Static method in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
Returns the custom property map mapping the siddhi extension key name to JMS transport key.
getId()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
getRequiredOptions()
- Static method in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
Returns the required options for the JMS input transport.
I
init(SourceEventListener, OptionHolder, ConfigReader, SiddhiAppContext)
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
isEmpty()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
isPaused()
- Method in class org.wso2.siddhi.extension.input.transport.jms.executor.
PausableThreadPoolExecutor
isRunning()
- Method in class org.wso2.siddhi.extension.input.transport.jms.executor.
PausableThreadPoolExecutor
J
JMSInputAdaptorRuntimeException
- Exception in
org.wso2.siddhi.extension.input.transport.jms.exception
JMS input adaptor specific exception.
JMSInputAdaptorRuntimeException()
- Constructor for exception org.wso2.siddhi.extension.input.transport.jms.exception.
JMSInputAdaptorRuntimeException
JMSInputAdaptorRuntimeException(String)
- Constructor for exception org.wso2.siddhi.extension.input.transport.jms.exception.
JMSInputAdaptorRuntimeException
JMSInputAdaptorRuntimeException(String, Throwable)
- Constructor for exception org.wso2.siddhi.extension.input.transport.jms.exception.
JMSInputAdaptorRuntimeException
JMSInputAdaptorRuntimeException(Throwable)
- Constructor for exception org.wso2.siddhi.extension.input.transport.jms.exception.
JMSInputAdaptorRuntimeException
JMSMessageProcessor
- Class in
org.wso2.siddhi.extension.input.transport.jms
This processes the JMS messages using a pausable thread pool.
JMSMessageProcessor(SourceEventListener, int)
- Constructor for class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
JMSOptionsMapper
- Class in
org.wso2.siddhi.extension.input.transport.jms.util
Used to do the custom mapping from the siddhi extension to JMS Carbon Transport.
JMSOptionsMapper()
- Constructor for class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
JMSSource
- Class in
org.wso2.siddhi.extension.input.transport.jms
JMSSource()
- Constructor for class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
JMSWorkerThread
- Class in
org.wso2.siddhi.extension.input.transport.jms
This runnable processes each JMS message and sends it to siddhi.
JMSWorkerThread(CarbonMessage, CarbonCallback, SourceEventListener)
- Constructor for class org.wso2.siddhi.extension.input.transport.jms.
JMSWorkerThread
O
org.wso2.siddhi.extension.input.transport.jms
- package org.wso2.siddhi.extension.input.transport.jms
org.wso2.siddhi.extension.input.transport.jms.exception
- package org.wso2.siddhi.extension.input.transport.jms.exception
org.wso2.siddhi.extension.input.transport.jms.executor
- package org.wso2.siddhi.extension.input.transport.jms.executor
org.wso2.siddhi.extension.input.transport.jms.util
- package org.wso2.siddhi.extension.input.transport.jms.util
P
PausableThreadPoolExecutor
- Class in
org.wso2.siddhi.extension.input.transport.jms.executor
This is a custom implementation of the Threadpool executor to allow pausing and resuming of the thread pool.
PausableThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>)
- Constructor for class org.wso2.siddhi.extension.input.transport.jms.executor.
PausableThreadPoolExecutor
pause()
- Method in class org.wso2.siddhi.extension.input.transport.jms.executor.
PausableThreadPoolExecutor
Pause the execution.
pause()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
PROVIDER_URL
- Static variable in class org.wso2.siddhi.extension.input.transport.jms.util.
JMSOptionsMapper
R
receive(CarbonMessage, CarbonCallback)
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
restoreState(Map<String, Object>)
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
resume()
- Method in class org.wso2.siddhi.extension.input.transport.jms.executor.
PausableThreadPoolExecutor
Resume pool execution.
resume()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSSource
run()
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSWorkerThread
S
setClientConnector(ClientConnector)
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
setTransportSender(TransportSender)
- Method in class org.wso2.siddhi.extension.input.transport.jms.
JMSMessageProcessor
B
C
D
F
G
I
J
O
P
R
S
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2017
WSO2
. All rights reserved.