class Stream2StringPipe extends FixedForwardPipe {

	@Override
	public PipeRunResult doPipe(Message message, IPipeLineSession session) throws PipeRunException {
		String result = null;
		try {
			result = message.asString();
		} catch (IOException e) {
			throw new PipeRunException(this, "Could not convert stream to text", e);
		}
		return new PipeRunResult(getForward(), result);
	}

}