Skip navigation links
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(Source.ConnectionCallback) - 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
 
getOutputEventClasses() - Method in class org.wso2.siddhi.extension.input.transport.jms.JMSSource
 
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, String[], 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

Copyright © 2017 WSO2. All rights reserved.