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
All Methods Instance Methods Concrete Methods 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 Thorjava.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 Thorvoid
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
-
-
-
-
Method Detail
-
doRequest
protected AdaptrisMessage doRequest(AdaptrisMessage msg, java.lang.String endpoint, long timeout) throws ProduceException
- Specified by:
doRequest
in classDfuPlusWrapper
- 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 interfaceComponentLifecycleExtension
- Overrides:
prepare
in classDfuPlusWrapper
- Throws:
CoreException
-
endpoint
public java.lang.String endpoint(AdaptrisMessage msg) throws ProduceException
- Specified by:
endpoint
in classAdaptrisMessageProducerImp
- 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
-
-