tryllian.afc.task.jms
Class ReactiveJMSTask

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

All Implemented Interfaces:

java.util.EventListener, MessageHandler, javax.jms.MessageListener, java.io.Serializable, Task

public abstract class ReactiveJMSTask

extends QueueTask

implements javax.jms.MessageListener

This abstract class receive mesage from the JMS Queue. When a message is received, the abstract method handleJMSMessage is invoked.

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

ReactiveJMSTask()
Create a task that will listen to the JMS message using the default settings.

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

Method Summary

void	handleHeartbeat() Override this method to define proactive behavior.
abstract void	handleJMSMessage(javax.jms.Message message) Implement this method to receive the JMS message for your agent.
void	onMessage(javax.jms.Message message) MessageListener interface callback
void	taskEnded() Close the receiver.
void	taskStarted() Starts to listen to JMS Messages.

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, 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

ReactiveJMSTask

public ReactiveJMSTask()

Create a task that will listen to the JMS message using the default settings.

ReactiveJMSTask

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

Create a ReactiveJMSTask 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()

Starts to listen to JMS Messages.

Overrides:

taskStarted in class QueueTask

taskEnded

public void taskEnded()

Close the receiver.

Overrides:

taskEnded in class QueueTask

onMessage

public void onMessage(javax.jms.Message message)

MessageListener interface callback

Specified by:

onMessage in interface javax.jms.MessageListener

Parameters:

message - The message we are sending to this Receiver

handleHeartbeat

public void handleHeartbeat()

Description copied from class: DefaultTask

Override this method to define proactive behavior. This implementation is empty, so you can override it without calling super.handleHeartbeat().

Overrides:

handleHeartbeat in class DefaultTask

handleJMSMessage

public abstract void handleJMSMessage(javax.jms.Message message)

Implement this method to receive the JMS message for your agent.

Parameters:

message - the message received from the JMS Queue.