[CONF] Apache Camel: Stream (page edited)

Thu, 15 Jan 2009 08:25:29 -0800

Page Edited : CAMEL : Stream

Stream has been edited by Claus Ibsen (Jan 15, 2009).

(View changes)

Content:

Stream Component

The stream: component provides access to the System.in, System.out and System.err streams together with allowing streaming of output to a file.
Notice that some of the stream types has been @deprecated (file and url). These types are supported by their respective components.

URI format

stream:in
stream:out
stream:err
stream:file?file=/foo/bar.txt  (@deprecated)
stream:url (@deprecated) 
stream:header


If the stream:header option is specified then the stream header is used to find the stream to write to. This option is only available for StreamProducer.



Options






 Name 
 Default Value 
 Description 




 file 
 null 
 When using the stream:file notation this specifies the file name to stream to/from. @deprecated. 




 delay 
 0 
 Initial delay in millis before consuming or producing the stream. 




 encoding 
 JVM Default 
  As of 1.4 or later you can configure the encoding (is a charset name) to use text based streams (eg. message body is a String object). If not provided Camel will use the JVM default Charset. 




 promptMessage 
 null 
 Camel 2.0: Leading prompt message that can be used when reading from stream:in to have a leading text such as Enter a command: 




 promptMessageDelay 
 0 
 Camel 2.0: Optional delay in millis before showing the prompt message. Can be used when system startup to avoid prompt message being written while other logging is done to the System out. 




 promptDelay 
 0 
 Camel 2.0: Optional delay in millis before showing the prompt message. 




 promptInitialDelay 
 2000 
 Camel 2.0: initial delay in millis before showing the prompt message. This delay only occurs once. Can be used when system startup to avoid prompt message being written while other logging is done to the System out. 






Message content



The stream: component supports either String or byte[] for writing to streams. Just add to the message.in.body either a Stirng or byte[] content.

The special stream:header URI is used for custom output streams. Just add a java.io.OutputStream to message.in.header in the key header.

See samples for an example.



Samples



In this sample we output to System.out the content from the message when its put on the direct:in queue.





public void testStringContent() throws Exception {
    template.sendBody("direct:in", "Hello Text World\n");
}

public void testBinaryContent() {
    template.sendBody("direct:in", "Hello Bytes World\n".getBytes());
}

protected RouteBuilder createRouteBuilder() {
    return new RouteBuilder() {
        public void configure() {
            from("direct:in").to("stream:out");
        }
    };
}





This sample demonstrates how the header type can be used to determine which stream to use. In the sample we use our own output stream (MyOutputStream).





private OutputStream mystream = new MyOutputStream();
private StringBuffer sb = new StringBuffer();

public void testStringContent() {
    template.sendBody("direct:in", "Hello");
    // StreamProducer appends \n in text mode
    assertEquals("Hello\n", sb.toString());
}

public void testBinaryContent() {
    template.sendBody("direct:in", "Hello".getBytes());
    // StreamProducer is in binary mode so no \n is appended
    assertEquals("Hello", sb.toString());
}

protected RouteBuilder createRouteBuilder() {
    return new RouteBuilder() {
        public void configure() {
            from("direct:in").setHeader("stream", constant(mystream)).
                to("stream:header");
        }
    };
}

private class MyOutputStream extends OutputStream {

    public void write(int b) throws IOException {
        sb.append((char)b);
    }
}





See Also

Powered by Atlassian Confluence (Version: 2.2.9 Build:#527 Sep 07, 2006) - Bug/feature request

Unsubscribe or edit your notifications preferences

Reply via email to