org.mule.module.pgp

Class TransformContinuouslyPolicy

java.lang.Object

org.mule.module.pgp.AbstractTransformPolicy

org.mule.module.pgp.TransformContinuouslyPolicy

All Implemented Interfaces:

TransformPolicy

public class TransformContinuouslyPolicy
extends AbstractTransformPolicy

A TransformPolicy that copies the transformed bytes continuously into the PipedOutputStream without taking into account about how many bytes the object has requested.

Nested Class Summary

Nested classes/interfaces inherited from class org.mule.module.pgp.AbstractTransformPolicy

AbstractTransformPolicy.TransformerWork

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_CHUNK_SIZE

Fields inherited from class org.mule.module.pgp.AbstractTransformPolicy

isClosed, logger

Constructor Summary

Constructors

Constructor and Description
TransformContinuouslyPolicy()
TransformContinuouslyPolicy(long chunkSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected Thread	getCopyingThread()
void	readRequest(long length) Notifies this policy that the object has requested nroOfBytes

Methods inherited from class org.mule.module.pgp.AbstractTransformPolicy

getBytesRequested, getInputStream, getTransformer, initialize, release, startCopyingThread

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CHUNK_SIZE

public static final long DEFAULT_CHUNK_SIZE

See Also:

Constant Field Values

Constructor Detail

TransformContinuouslyPolicy

public TransformContinuouslyPolicy()

TransformContinuouslyPolicy

public TransformContinuouslyPolicy(long chunkSize)

Method Detail

readRequest

public void readRequest(long length)

Notifies this policy that the object has requested nroOfBytes

Specified by:

readRequest in interface TransformPolicy

Overrides:

readRequest in class AbstractTransformPolicy

Parameters:

length - the nro of bytes requested by the object

getCopyingThread

protected Thread getCopyingThread()

Specified by:

getCopyingThread in class AbstractTransformPolicy

Returns:

an instance of the copying Thread