org.apache.commons.messenger.task
Class ProducerTask

java.lang.Object
  org.apache.tools.ant.ProjectComponent
      org.apache.tools.ant.Task
          org.apache.commons.messenger.task.ProducerTask

public class ProducerTask
extends org.apache.tools.ant.Task

ProducerTask is an Ant task which will publish all of the given text files as a JMS Text Message using a given JMS Connection (Messenger) and a Destination

Version:

$Revision: 155459 $

Author:

James Strachan

Field Summary

Fields inherited from class org.apache.tools.ant.Task

description, location, target, taskName, taskType, wrapper

Fields inherited from class org.apache.tools.ant.ProjectComponent

project

Constructor Summary

ProducerTask()

Method Summary

void	addFileset(org.apache.tools.ant.types.FileSet set) Adds a set of files (nested fileset attribute).
void	execute() Performs the copy operation.
javax.jms.Destination	getDestination() Getter for property destination.
File	getFile() Returns the single file to be sent instead of a FileSet
Messenger	getMessenger()
MessengerManager	getMessengerManager() Getter for property messengerManager.
String	getMessengerName() Getter for property messengerName.
long	getSleep() Getter for property sleep, which defines the number of milliseconds to sleep for before each send.
String	getSubject() Getter for property subject.
protected String	readText(Reader in) Reads the given text stream into a single string
protected void	sendFile(File file, Messenger messenger, javax.jms.Destination destination) Sends the contents of the given file to the given Destination using the given Messenger instance
void	setConfiguration(String uri) Sets the URI of the Messenger.xml configuration document to use to configure the messengers to use for this task.
void	setDestination(javax.jms.Destination destination) Setter for property destination.
void	setFile(File file) Allows a single file to be sent via the Ant Task
void	setMessenger(Messenger messenger) Sets the Messenger to be used
void	setMessengerManager(MessengerManager messengerManager) Setter for property messengerManager.
void	setMessengerName(String messengerName) Setter for property messengerName.
void	setSleep(long sleep) Setter for property sleep, which defines the number of milliseconds to sleep for before each send.
void	setSubject(String subject) Setter for property subject.
protected void	sleep() Sleeps for a configurable amount of time between each message send

Methods inherited from class org.apache.tools.ant.Task

getDescription, getLocation, getOwningTarget, getRuntimeConfigurableWrapper, getTaskName, handleErrorOutput, handleOutput, init, isInvalid, log, log, maybeConfigure, perform, setDescription, setLocation, setOwningTarget, setRuntimeConfigurableWrapper, setTaskName

Methods inherited from class org.apache.tools.ant.ProjectComponent

getProject, setProject

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducerTask

public ProducerTask()

Method Detail

addFileset

public void addFileset(org.apache.tools.ant.types.FileSet set)

Adds a set of files (nested fileset attribute).

getMessenger

public Messenger getMessenger()
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setMessenger

public void setMessenger(Messenger messenger)

Sets the Messenger to be used

getMessengerName

public String getMessengerName()

Getter for property messengerName.

Returns:

Value of property messengerName.

setMessengerName

public void setMessengerName(String messengerName)

Setter for property messengerName.

Parameters:

messengerName - New value of property messengerName.

getDestination

public javax.jms.Destination getDestination()
                                     throws javax.jms.JMSException

Getter for property destination.

Returns:

Value of property destination.

Throws:

javax.jms.JMSException

setDestination

public void setDestination(javax.jms.Destination destination)

Setter for property destination.

Parameters:

destination - New value of property destination.

getSubject

public String getSubject()

Getter for property subject.

Returns:

Value of property subject.

setSubject

public void setSubject(String subject)

Setter for property subject.

Parameters:

subject - New value of property subject.

getMessengerManager

public MessengerManager getMessengerManager()

Getter for property messengerManager.

Returns:

Value of property messengerManager.

setMessengerManager

public void setMessengerManager(MessengerManager messengerManager)

Setter for property messengerManager.

Parameters:

messengerManager - New value of property messengerManager.

setConfiguration

public void setConfiguration(String uri)
                      throws javax.jms.JMSException

Sets the URI of the Messenger.xml configuration document to use to configure the messengers to use for this task.

Throws:

javax.jms.JMSException

getSleep

public long getSleep()

Getter for property sleep, which defines the number of milliseconds to sleep for before each send.

Returns:

Value of property sleep.

setSleep

public void setSleep(long sleep)

Setter for property sleep, which defines the number of milliseconds to sleep for before each send.

Parameters:

sleep - New value of property sleep.

getFile

public File getFile()

Returns the single file to be sent instead of a FileSet

Returns:

File

setFile

public void setFile(File file)

Allows a single file to be sent via the Ant Task

Parameters:

file - The file to set

execute

public void execute()
             throws org.apache.tools.ant.BuildException

Performs the copy operation.

Overrides:

execute in class org.apache.tools.ant.Task

Throws:

org.apache.tools.ant.BuildException

sendFile

protected void sendFile(File file,
                        Messenger messenger,
                        javax.jms.Destination destination)
                 throws IOException,
                        javax.jms.JMSException

Sends the contents of the given file to the given Destination using the given Messenger instance

Throws:

IOException

javax.jms.JMSException

readText

protected String readText(Reader in)
                   throws IOException

Reads the given text stream into a single string

Throws:

IOException

sleep

protected void sleep()

Sleeps for a configurable amount of time between each message send