Message (Entwurfsmuster)

public class Message implements Serializable {

    private final MessageHeader header;
    private final MessageBody body;

    public Message (MessageHeader header, MessageBody body) {

        this.header = header;
        this.body = body;
    }

    // ...
}

package org.wikipedia.de.eip.message.construction;

import static java.lang.System.out;

import org.apache.camel.Message;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

class SingleMessageSample {

	static class Data {

		String info = "*** containing info ***";
	} // Data

	private static final DefaultCamelContext cc = new DefaultCamelContext();

	public static void main( final String... args ) throws Exception {

		final Data data = new Data();

		cc.setName( "Single Message Sample" );
		cc.addRoutes( new RouteBuilder() {

			@Override
			public void configure() {

				from( "timer:start?repeatCount=1" ) // EIP Sender
				    .log( "Sending..." )
				    .process().message( m -> m.setBody( data ) ) // EIP Message
				    .process().message( m -> print( "Send", m ) )
				    .to( "direct:receiver" ) // EIP Receiver
				    .setId( "Sender" );

				from( "direct:receiver" ) // EIP Receiver
				    .log( "Receiving..." )
				    .process().message( m -> print( "Receive", m ) ) // EIP Message
				    .setId( "Receiver" );
			}
		} );
		cc.start();
		Thread.sleep( 2000 );
		cc.stop();
		cc.close();
	} // main()

	static void print( final String endpoint, final Message m ) {

		final Data data = m.getBody( Data.class ); // Data packed in Message
		out.printf( "%s %s: %s%n", endpoint, m, data.info );
	} // print()

} // SingleMessageSample

package org.wikipedia.de.eip.message.construction;

import static java.lang.System.out;

import java.util.Vector;

import org.apache.camel.Message;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;

class MultipleMessagesSample {

	static class Data extends Vector<String> {

		Data() {
			add( "*** 1st  info ***" );
			add( "*** 2nd  info ***" );
			add( "*** 3rd  info ***" );
		}
	} // Data

	private static final DefaultCamelContext cc = new DefaultCamelContext();

	public static void main( final String... args ) throws Exception {

		final Data data = new Data();

		cc.setName( "Multiple Messages Sample" );
		cc.addRoutes( new RouteBuilder() {

			@Override
			public void configure() {

				onException( IndexOutOfBoundsException.class )
				    .handled( true )
				    .stop(); // Übertragung wird nach dem letzten Element der Liste abgebrochen

				from( "timer:start" ) // EIP Sender
				    // remove(i) löst eine IndexOutOfBoundsException aus wenn die Liste leer ist
				    .process().message( m -> m.setBody( data.remove( 0 ) ) ) // EIP Message
				    .log( "Sending..." )
				    .process().message( m -> print( "Sending", m ) )
				    .to( "direct:receiver" ) // EIP Receiver
				    .setId( "Sender" );

				from( "direct:receiver" ) // EIP Receiver
				    .log( "Receiving..." )
				    .process().message( m -> print( "Receiving", m ) ) // EIP Message
				    .setId( "Receiver" );
			}
		} );
		cc.start();
		Thread.sleep( 4000 );
		cc.stop();
		cc.close();
	} // main()

	static void print( final String process, final Message m ) {

		final String data = (String) m.getBody(); // Data packed in Message
		out.printf( "%s %s: %s%n", process, m, data );
	} // print()

} // MultipleMessagesSample