Package com.adaptris.hpcc

Class SprayToThorImpl

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.hpcc.DfuPlusWrapper

com.adaptris.hpcc.SprayToThorImpl

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator

Direct Known Subclasses:

SprayDirectoryToThor, SprayToThor

public abstract class SprayToThorImpl
extends DfuPlusWrapper

Field Summary

Fields inherited from class com.adaptris.hpcc.DfuPlusWrapper

executor

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
SprayToThorImpl()

Method Summary

Modifier and Type	Method	Description
protected org.apache.commons.exec.CommandLine	createSprayCommand(AdaptrisMessage msg)
protected AdaptrisMessage	doRequest(AdaptrisMessage msg, java.lang.String endpoint, long timeout)
java.lang.String	endpoint(AdaptrisMessage msg)
java.lang.String	getCluster()
java.lang.String	getLogicalFilename()	The filename to write in Thor
java.lang.Boolean	getOverwrite()
protected boolean	overwrite()
void	prepare()
void	setCluster(java.lang.String cluster)
void	setLogicalFilename(java.lang.String logicalFilename)	The filename to write in Thor
void	setOverwrite(java.lang.Boolean overwrite)

Methods inherited from class com.adaptris.hpcc.DfuPlusWrapper

calculateWait, close, doProduce, execute, executeInternal, generateExceptionMessage, getMaxWait, getMonitorInterval, init, maxWaitMs, monitorIntervalMs, produce, request, request, setMaxWait, setMonitorInterval, start, stop

Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp

createName

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createQualifier, isTrackingEndpoint

Constructor Detail

SprayToThorImpl

public SprayToThorImpl()

Method Detail

doRequest

protected AdaptrisMessage doRequest(AdaptrisMessage msg,
                                    java.lang.String endpoint,
                                    long timeout)
                             throws ProduceException

Specified by:

doRequest in class DfuPlusWrapper

Throws:

ProduceException

overwrite

protected boolean overwrite()

createSprayCommand

protected org.apache.commons.exec.CommandLine createSprayCommand(AdaptrisMessage msg)
                                                          throws PasswordException,
                                                                 java.io.IOException

Throws:

PasswordException

java.io.IOException

prepare

public void prepare()
             throws CoreException

Specified by:

prepare in interface ComponentLifecycleExtension

Overrides:

prepare in class DfuPlusWrapper

Throws:

CoreException

endpoint

public java.lang.String endpoint(AdaptrisMessage msg)
                          throws ProduceException

Specified by:

endpoint in class AdaptrisMessageProducerImp

Throws:

ProduceException

getCluster

public java.lang.String getCluster()

setCluster

public void setCluster(java.lang.String cluster)

getOverwrite

public java.lang.Boolean getOverwrite()

setOverwrite

public void setOverwrite(java.lang.Boolean overwrite)

getLogicalFilename

public java.lang.String getLogicalFilename()

The filename to write in Thor

setLogicalFilename

public void setLogicalFilename(java.lang.String logicalFilename)

The filename to write in Thor