Class JmsReader
java.lang.Object
kieker.analysis.analysisComponent.AbstractAnalysisComponent
kieker.analysis.plugin.AbstractPlugin
kieker.analysis.plugin.reader.AbstractReaderPlugin
kieker.analysis.plugin.reader.jms.JmsReader
- All Implemented Interfaces:
IAnalysisComponent
,IPlugin
,IReaderPlugin
@Deprecated public final class JmsReader extends AbstractReaderPlugin
Deprecated.
1.15 ported to teetime
Reads monitoring records from a (remote or local) JMS queue.
- Since:
- 0.95a
- Author:
- Andre van Hoorn, Matthias Rohr
-
Nested Class Summary
Nested classes/interfaces inherited from interface kieker.analysis.plugin.IPlugin
IPlugin.PluginInputPortReference, IPlugin.STATE
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
CONFIG_PROPERTY_NAME_DESTINATION
Deprecated.The name of the configuration determining the JMS destination (e.g.static java.lang.String
CONFIG_PROPERTY_NAME_FACTORYLOOKUP
Deprecated.The name of the configuration determining the name of the used JMS factory.static java.lang.String
CONFIG_PROPERTY_NAME_PROVIDERURL
Deprecated.The name of the configuration determining the JMS provider URL.static java.lang.String
OUTPUT_PORT_NAME_RECORDS
Deprecated.The name of the output port delivering the received records.Fields inherited from class kieker.analysis.analysisComponent.AbstractAnalysisComponent
CONFIG_NAME, configuration, logger, projectContext, recordsTimeUnitFromProjectContext
-
Constructor Summary
Constructors Constructor Description JmsReader(Configuration configuration, IProjectContext projectContext)
Deprecated.Creates a new instance of this class using the given parameters. -
Method Summary
Modifier and Type Method Description Configuration
getCurrentConfiguration()
Deprecated.This method should deliver aConfiguration
object containing the current configuration of this instance.protected org.slf4j.Logger
getLog()
Deprecated.boolean
read()
Deprecated.A call to this method is a blocking call.void
terminate(boolean error)
Deprecated.Initiates a termination of the plugin.Methods inherited from class kieker.analysis.plugin.AbstractPlugin
areAllRepositoryPortsConnected, connect, connect, deliver, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getDefaultConfiguration, getIncomingPlugins, getPluginDescription, getPluginName, getRepository, getState, isConnectionAllowed, notifyNewIncomingConnection, notifyNewOutgoingConnection, shutdown, start
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface kieker.analysis.plugin.IPlugin
connect, getAllDisplayNames, getAllInputPortNames, getAllOutputPortNames, getAllRepositoryPortNames, getConnectedPlugins, getCurrentRepositories, getName, getPluginDescription, getPluginName, getState
-
Field Details
-
OUTPUT_PORT_NAME_RECORDS
public static final java.lang.String OUTPUT_PORT_NAME_RECORDSDeprecated.The name of the output port delivering the received records.- See Also:
- Constant Field Values
-
CONFIG_PROPERTY_NAME_PROVIDERURL
public static final java.lang.String CONFIG_PROPERTY_NAME_PROVIDERURLDeprecated.The name of the configuration determining the JMS provider URL.- See Also:
- Constant Field Values
-
CONFIG_PROPERTY_NAME_DESTINATION
public static final java.lang.String CONFIG_PROPERTY_NAME_DESTINATIONDeprecated.The name of the configuration determining the JMS destination (e.g. queue1).- See Also:
- Constant Field Values
-
CONFIG_PROPERTY_NAME_FACTORYLOOKUP
public static final java.lang.String CONFIG_PROPERTY_NAME_FACTORYLOOKUPDeprecated.The name of the configuration determining the name of the used JMS factory.- See Also:
- Constant Field Values
-
-
Constructor Details
-
JmsReader
public JmsReader(Configuration configuration, IProjectContext projectContext) throws java.lang.IllegalArgumentExceptionDeprecated.Creates a new instance of this class using the given parameters.- Parameters:
configuration
- The configuration used to initialize the whole reader. Keep in mind that the configuration should contain the following properties:- The property
CONFIG_PROPERTY_NAME_PROVIDERURL
, e.g.tcp://localhost:3035/
- The property
CONFIG_PROPERTY_NAME_DESTINATION
, e.g.queue1
- The property
CONFIG_PROPERTY_NAME_FACTORYLOOKUP
, e.g.org.exolab.jms.jndi.InitialContextFactory
- The property
projectContext
- The project context for this component.- Throws:
java.lang.IllegalArgumentException
- If one of the properties is empty.
-
-
Method Details
-
read
public boolean read()Deprecated.A call to this method is a blocking call.- Returns:
- true if the method succeeds, false otherwise.
-
terminate
public void terminate(boolean error)Deprecated.Initiates a termination of the plugin. This method is only used by the framework and should not be called manually. Use the methodAnalysisController.terminate(boolean)
instead. After receiving this notification, the plugin should terminate any running methods, e.g., read for readers.- Parameters:
error
- Determines whether the plugin is terminated due to an error or not.
-
getCurrentConfiguration
Deprecated.This method should deliver aConfiguration
object containing the current configuration of this instance. In other words: The constructor should be able to use the given object to initialize a new instance of this class with the same intern properties.- Specified by:
getCurrentConfiguration
in interfaceIAnalysisComponent
- Specified by:
getCurrentConfiguration
in interfaceIPlugin
- Specified by:
getCurrentConfiguration
in classAbstractAnalysisComponent
- Returns:
- A completely filled configuration object.
-
getLog
protected org.slf4j.Logger getLog()Deprecated.
-