public class MessageOutputStream extends Object implements AutoCloseable
Modifier and Type | Field and Description |
---|---|
protected static org.apache.logging.log4j.Logger |
log |
protected Object |
requestStream |
protected static org.apache.logging.log4j.Logger log
protected Object requestStream
protected MessageOutputStream(INamedObject owner, IForwardTarget next, String conversionCharset)
protected MessageOutputStream(INamedObject owner, MessageOutputStream nextStream, String conversionCharset)
public MessageOutputStream(INamedObject owner, OutputStream stream, IForwardTarget next)
public MessageOutputStream(INamedObject owner, OutputStream stream, MessageOutputStream nextStream)
public MessageOutputStream(INamedObject owner, OutputStream stream, IForwardTarget next, String conversionCharset)
public MessageOutputStream(INamedObject owner, OutputStream stream, MessageOutputStream nextStream, String conversionCharset)
public MessageOutputStream(INamedObject owner, Writer writer, IForwardTarget next)
public MessageOutputStream(INamedObject owner, Writer writer, MessageOutputStream nextStream)
public MessageOutputStream(INamedObject owner, Writer writer, IForwardTarget next, String conversionCharset)
public MessageOutputStream(INamedObject owner, Writer writer, MessageOutputStream nextStream, String conversionCharset)
public MessageOutputStream(INamedObject owner, ContentHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector)
public MessageOutputStream(INamedObject owner, JsonEventHandler handler, MessageOutputStream nextStream, ThreadLifeCycleEventListener<T> threadLifeCycleEventListener, IThreadConnectableTransactionManager txManager, PipeLineSession session, ThreadConnector<?> targetThreadConnector)
protected void setRequestStream(Object requestStream)
public void closeRequestStream() throws IOException
IOException
public void afterClose() throws Exception
Exception
public void closeOnClose(AutoCloseable resource)
public final void close() throws Exception
close
in interface AutoCloseable
Exception
public boolean isBinary()
public Object asNative()
public OutputStream asStream() throws StreamingException
StreamingException
public OutputStream asStream(String charset) throws StreamingException
StreamingException
public Writer asWriter() throws StreamingException
StreamingException
public ContentHandler asContentHandler() throws StreamingException
StreamingException
public JsonEventHandler asJsonEventHandler() throws StreamingException
StreamingException
public StringWriter captureCharacterStream()
public void captureCharacterStream(Writer writer)
public void captureCharacterStream(Writer writer, int maxSize)
public ByteArrayOutputStream captureBinaryStream()
public void captureBinaryStream(OutputStream outputStream)
public void captureBinaryStream(OutputStream outputStream, int maxSize)
public void setResponse(Message response)
target
to set this message.public Message getResponse()
public void setForward(PipeForward forward)
public PipeRunResult getPipeRunResult()
public PipeForward getForward()
public static MessageOutputStream getTargetStream(INamedObject owner, PipeLineSession session, IForwardTarget next) throws StreamingException
StreamingException
Copyright © 2023 Frank!Framework. All rights reserved.