fr.liglab.adele.cilia.jms2

Class JMSCollector

java.lang.Object

fr.liglab.adele.cilia.framework.AbstractCollector

fr.liglab.adele.cilia.jms2.JMSCollector

All Implemented Interfaces:

ICollector, javax.jms.MessageListener

public class JMSCollector
extends AbstractCollector
implements javax.jms.MessageListener

JMS/Joram in adapter based on new JMS 2.0 specification. This JMS collector works either in Point-To-Point (PTP) or Publish/Subscribe (P/S) mode messages depending of the destination type (Queue or Topic) used to receive messages. The destination type could be specified in the name of the destination, by default it is a topic.

Author:

ScalAgent Team, Cilia Project Team

Constructor Summary

Constructors

Constructor and Description
JMSCollector(org.osgi.framework.BundleContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	onMessage(javax.jms.Message msg)
void	setDestination(String name)
void	setHostname(String hostname)
void	setLogin(String login)
void	setPassword(String password)
void	setPort(int port)

Methods inherited from class fr.liglab.adele.cilia.framework.AbstractCollector

notifyDataArrival, setScheduler, setSourceName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSCollector

public JMSCollector(org.osgi.framework.BundleContext context)

Method Detail

onMessage

public void onMessage(javax.jms.Message msg)

Specified by:

onMessage in interface javax.jms.MessageListener

setDestination

public void setDestination(String name)

Parameters:

name - the destination to set

setLogin

public void setLogin(String login)

Parameters:

login - the login to set

setPassword

public void setPassword(String password)

Parameters:

password - the password to set

setHostname

public void setHostname(String hostname)

Parameters:

hostname - the hostname to set

setPort

public void setPort(int port)

Parameters:

port - the port to set