Package org.frankframework.stream
Class MessageOutputStream
java.lang.Object
org.frankframework.stream.MessageOutputStream
- All Implemented Interfaces:
AutoCloseable
- Direct Known Subclasses:
MessageOutputStreamCap
-
Field Summary
Modifier and TypeFieldDescriptionprotected static org.apache.logging.log4j.Logger
protected Object
-
Constructor Summary
ModifierConstructorDescriptionMessageOutputStream
(INamedObject owner, OutputStream stream, IForwardTarget next) MessageOutputStream
(INamedObject owner, OutputStream stream, IForwardTarget next, String conversionCharset) MessageOutputStream
(INamedObject owner, OutputStream stream, MessageOutputStream nextStream) MessageOutputStream
(INamedObject owner, OutputStream stream, MessageOutputStream nextStream, String conversionCharset) MessageOutputStream
(INamedObject owner, Writer writer, IForwardTarget next) MessageOutputStream
(INamedObject owner, Writer writer, IForwardTarget next, String conversionCharset) MessageOutputStream
(INamedObject owner, Writer writer, MessageOutputStream nextStream) MessageOutputStream
(INamedObject owner, Writer writer, MessageOutputStream nextStream, String conversionCharset) protected
MessageOutputStream
(INamedObject owner, IForwardTarget next, String conversionCharset) MessageOutputStream
(INamedObject owner, JsonEventHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector) protected
MessageOutputStream
(INamedObject owner, MessageOutputStream nextStream, String conversionCharset) MessageOutputStream
(INamedObject owner, ContentHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector) -
Method Summary
Modifier and TypeMethodDescriptionvoid
can be overridden in descender classes to release resources, after the chain has been closed.asNative()
asStream()
asWriter()
void
captureBinaryStream
(OutputStream outputStream) void
captureBinaryStream
(OutputStream outputStream, int maxSize) void
captureCharacterStream
(Writer writer) void
captureCharacterStream
(Writer writer, int maxSize) final void
close()
void
closeOnClose
(AutoCloseable resource) void
static MessageOutputStream
getTargetStream
(INamedObject owner, PipeLineSession session, IForwardTarget next) Provides a non-null MessageOutputStream, that the caller can use to obtain a Writer, OutputStream or ContentHandler.boolean
isBinary()
void
setForward
(PipeForward forward) protected void
setRequestStream
(Object requestStream) void
setResponse
(Message response) Response message, e.g.
-
Field Details
-
log
protected static org.apache.logging.log4j.Logger log -
requestStream
-
-
Constructor Details
-
MessageOutputStream
-
MessageOutputStream
protected MessageOutputStream(INamedObject owner, MessageOutputStream nextStream, String conversionCharset) -
MessageOutputStream
-
MessageOutputStream
-
MessageOutputStream
public MessageOutputStream(INamedObject owner, OutputStream stream, IForwardTarget next, String conversionCharset) -
MessageOutputStream
public MessageOutputStream(INamedObject owner, OutputStream stream, MessageOutputStream nextStream, String conversionCharset) -
MessageOutputStream
-
MessageOutputStream
-
MessageOutputStream
public MessageOutputStream(INamedObject owner, Writer writer, IForwardTarget next, String conversionCharset) -
MessageOutputStream
public MessageOutputStream(INamedObject owner, Writer writer, MessageOutputStream nextStream, String conversionCharset) -
MessageOutputStream
public MessageOutputStream(INamedObject owner, ContentHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector) -
MessageOutputStream
public MessageOutputStream(INamedObject owner, JsonEventHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector)
-
-
Method Details
-
setRequestStream
-
closeRequestStream
- Throws:
IOException
-
afterClose
can be overridden in descender classes to release resources, after the chain has been closed.- Throws:
SQLException
-
closeOnClose
-
close
- Specified by:
close
in interfaceAutoCloseable
- Throws:
Exception
-
isBinary
public boolean isBinary() -
asNative
-
asStream
- Throws:
StreamingException
-
asStream
- Throws:
StreamingException
-
asWriter
- Throws:
StreamingException
-
asContentHandler
- Throws:
StreamingException
-
asJsonEventHandler
-
captureCharacterStream
-
captureCharacterStream
-
captureCharacterStream
-
captureBinaryStream
-
captureBinaryStream
-
captureBinaryStream
-
setResponse
Response message, e.g. the filename, of the {IOutputStreamTarget target} after processing the stream. It is the responsibility of thetarget
to set this message. -
getResponse
-
setForward
-
getPipeRunResult
-
getForward
-
getTargetStream
public static MessageOutputStream getTargetStream(INamedObject owner, PipeLineSession session, IForwardTarget next) throws StreamingException Provides a non-null MessageOutputStream, that the caller can use to obtain a Writer, OutputStream or ContentHandler.- Throws:
StreamingException
-