tryllian.afc.task.jms
Class PublishJMSTopicTask

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

All Implemented Interfaces:

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

public class PublishJMSTopicTask

extends TopicTask

This task publishes a JMS topic.

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

PublishJMSTopicTask()
Creates a new tasks using the default settings.

PublishJMSTopicTask(java.lang.String jndiFactory, java.lang.String urlProvider, java.lang.String jmsFactory, java.lang.String topic)
Create a PublishJMSTopicTask using the specified JMS settings.

Method Summary

void	setBytesMessage(java.util.List bytes) Set the Bytes (raw data) to send.
void	setMapMessage(java.util.Map map) Set the Map to send.
void	setObjectMessage(java.io.Serializable object) Set the Object to send.
void	setStreamMessage(java.util.List stream) Set the Stream data to send.
void	setTextMessage(java.lang.String text) Set the text to send.
void	taskEnded() Close the objects that need to be closed.
void	taskStarted() publish the message.

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

getConnection, getSession, getTopic

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

PublishJMSTopicTask

public PublishJMSTopicTask()

Creates a new tasks using the default settings.

PublishJMSTopicTask

public PublishJMSTopicTask(java.lang.String jndiFactory,
                           java.lang.String urlProvider,
                           java.lang.String jmsFactory,
                           java.lang.String topic)

Create a PublishJMSTopicTask using the specified JMS settings.

Parameters:

jndiFactory - JNDI factory name.

urlProvider - the provider URL of the JMS system.

jmsFactory - JMS factory name.

topic - name of the JMS topic.

Method Detail

taskStarted

public void taskStarted()

publish the message.

Overrides:

taskStarted in class TopicTask

setTextMessage

public void setTextMessage(java.lang.String text)

Set the text to send.

Parameters:

text - the text to send.

setObjectMessage

public void setObjectMessage(java.io.Serializable object)

Set the Object to send.

Parameters:

object - the object to send.

setMapMessage

public void setMapMessage(java.util.Map map)

Set the Map to send.

Parameters:

map - the map to send.

setBytesMessage

public void setBytesMessage(java.util.List bytes)

Set the Bytes (raw data) to send.

Parameters:

bytes - the data to send (in a List of Objects).

setStreamMessage

public void setStreamMessage(java.util.List stream)

Set the Stream data to send.

Parameters:

stream - the data to send (in a List of Objects).

taskEnded

public void taskEnded()

Close the objects that need to be closed.

Overrides:

taskEnded in class TopicTask