tryllian.afc.task.jms
Class TopicTask

java.lang.Object
  tryllian.afc.task.AbstractTask
      tryllian.afc.task.DefaultTask
          tryllian.afc.task.jms.JMSTask
              tryllian.afc.task.jms.TopicTask

All Implemented Interfaces:

java.util.EventListener, MessageHandler, java.io.Serializable, Task

Direct Known Subclasses:

PublishJMSTopicTask, SubscribeJMSTopicTask

public class TopicTask

extends JMSTask

This class is a generic task for the Topic task. It initializes the session and connection for the topic tasks.

See Also:

Serialized Form

Field Summary

Fields inherited from class tryllian.afc.task.AbstractTask

NL

Fields inherited from interface tryllian.afc.task.Task

EMPTY_FINISH_VALUE, FORCED_FINISH_FAILURE, NO_TIME_OUT, TASK_TIMED_OUT

Constructor Summary

TopicTask()
Creates a new instance of TopicTask with the default settings.

TopicTask(java.lang.String jndiFactory, java.lang.String urlProvider, java.lang.String connectionFactory, java.lang.String topic)
Create a TopicTask using the specified JMS parameters.

Method Summary

protected javax.jms.TopicConnection	getConnection() Get the connection used for this JMS topic.
protected javax.jms.TopicSession	getSession() Get the session used for this JMS topic.
protected javax.jms.Topic	getTopic() Get the JMS topic.
void	taskEnded() Cleans up the JMS resources
void	taskStarted() Creates the connection and session.

Methods inherited from class tryllian.afc.task.jms.JMSTask

getConnectionFactory, getJMSDestination, getJNDIFactory, getURLProvider, setConnectionFactory, setJMSDestination, setJNDIFactory, setURLProvider

Methods inherited from class tryllian.afc.task.DefaultTask

addFinishingTask, addTask, getSubtasks, handleHeartbeat, propagateHeartbeat

Methods inherited from class tryllian.afc.task.AbstractTask

addTaskListener, fail, fail, finish, finish, finish, forceFinish, forceFinish, getAgentContext, getFinishValue, getState, getSupertask, getTimeOut, handleMessage, heartbeatReceived, logException, messageReceived, removeTaskListener, setAgentContext, setFinishValue, setTimeOut, succeed, succeed, taskAdded, taskRemoved

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicTask

public TopicTask()

Creates a new instance of TopicTask with the default settings. The defaults settings are the ones set in the default contructor of the JMSTask and :

• Connection factory : jms/TopicConnectionFactory
• Queue : jms/Topic

See Also:

JMSTask.JMSTask(java.lang.String, java.lang.String, java.lang.String, java.lang.String)

TopicTask

public TopicTask(java.lang.String jndiFactory,
                 java.lang.String urlProvider,
                 java.lang.String connectionFactory,
                 java.lang.String topic)

Create a TopicTask using the specified JMS parameters.

Parameters:

jndiFactory - JNDI factory name.

urlProvider - the provider URL of the JMS system.

connectionFactory - JMS factory name.

topic - name of the JMS topic.

Method Detail

taskStarted

public void taskStarted()

Creates the connection and session.

Overrides:

taskStarted in class AbstractTask

taskEnded

public void taskEnded()

Cleans up the JMS resources

Overrides:

taskEnded in class AbstractTask

getTopic

protected javax.jms.Topic getTopic()

Get the JMS topic.

Returns:

the JMS topic.

getSession

protected javax.jms.TopicSession getSession()

Get the session used for this JMS topic.

Returns:

the current session or null if the session is not yet created.

getConnection

protected javax.jms.TopicConnection getConnection()

Get the connection used for this JMS topic.

Returns:

the current connection or null if the connection is not yet created.