tryllian.afc.task.jms
Class SendJMSMessageTask

java.lang.Object
  tryllian.afc.task.AbstractTask
      tryllian.afc.task.DefaultTask
          tryllian.afc.task.jms.JMSTask
              tryllian.afc.task.jms.QueueTask
                  tryllian.afc.task.jms.SendJMSMessageTask

All Implemented Interfaces:

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

public class SendJMSMessageTask

extends QueueTask

This task will send a message to the JMS system. You have to invoke one of the set method to set the message you want to send before starting the task.

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

SendJMSMessageTask()
Creates a new instance of SendJMSMessageTask using the default settings.

SendJMSMessageTask(java.lang.String jndiFactory, java.lang.String urlProvider, java.lang.String jmsFactory, java.lang.String queueName)
Create a SendJMSMessageTask using the specified JMS parameters.

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 sender.
void	taskStarted() Creates the sender and sends the message.

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

getConnection, getQueue, getSession

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

SendJMSMessageTask

public SendJMSMessageTask()

Creates a new instance of SendJMSMessageTask using the default settings.

SendJMSMessageTask

public SendJMSMessageTask(java.lang.String jndiFactory,
                          java.lang.String urlProvider,
                          java.lang.String jmsFactory,
                          java.lang.String queueName)

Create a SendJMSMessageTask using the specified JMS parameters.

Parameters:

jndiFactory - JNDI factory name

urlProvider - the provider URL of the JMS system.

jmsFactory - JMS factory name

queueName - name of the receiving queue

Method Detail

taskStarted

public void taskStarted()

Creates the sender and sends the message. Make sure a mesage to send has been set before.

Overrides:

taskStarted in class QueueTask

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 sender.

Overrides:

taskEnded in class QueueTask