camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Randy H <randy.heming...@lmco.com>
Subject Aggregator Pattern
Date Wed, 27 Aug 2008 20:13:31 GMT

Does the Camel Aggregator pattern currently work?  I'm using
camel-core-1.3.4.0-fuse.jar.  I tried to add an aggregator to a camel route
and when the configure method runs it generates an
UnsupportedOperationException (see below).  The error occurs when the camel
route is being built, not when I attempt to send actual data through the
route.  Since the documentation on the Camel aggregator pattern is so
minimal, I could be doing something wrong with the aggregator.  Here is my
test code (junit test):


    public void testAggregator()
        throws Exception {

        LOG.info( "Starting testAggregator" );

        try {
            CamelContext context = new DefaultCamelContext();

            context.getEndpoint( "mock:test", MockEndpoint.class );
        
            //********************************************************
            // Create a camel route that uses an aggregator
            //********************************************************
            context.addRoutes( new RouteBuilder() {

                public void configure() {

                    streamCaching();
                    LOG.info( "Configuring CAMEL Aggregator rules." );

                    //************************************************
                    // Send any queryRequest nodes from the workflow
                    //  message to a file in the output directory.
                    //************************************************
                    from( "file://samples/input" ).
                        to( "log:theLoggingCategory?level=info" ).
                        aggregator( header( "CheeseWhiz" ) ).
                        to( "mock:test" );

                }
            } );

            // Now everything is set up - lets start the context
            context.start();

            //************************************************************
            // Test - Copy the XML data to the CAMEL input directory. 
            //  Camel should aggregate the two 'queryRequest' nodes
            //  and write them to the output directory.
            //************************************************************
            LOG.info( "Start Test - Aggregator processing with Camel" );
            _doCamelRouteTest( 4, "workFlowNoNS.xml", ALERT_DIR, 3 );

            context.stop();
            context = null;
        }
        catch( Exception e ) {
            e.printStackTrace();
            LOG.error( "Unexpected Camel exception: " + e );
        }
        

        LOG.info( "testAggregator completed!" );
    }


When I execute the test code,  an exception is generated.  Here is log
output including the exception stack trace:


13:43:47.720 INFO  [RouteAlertsTest] - Setting up for Camel test
13:43:53.238 INFO  [RouteAlertsTest] - Starting testAggregator
13:43:58.05 INFO  [RouteAlertsTest] - Configuring CAMEL Aggregator rules.
java.lang.UnsupportedOperationException: Not implemented yet for class:
org.apache.camel.model.AggregatorType
	at
org.apache.camel.model.ProcessorType.createProcessor(ProcessorType.java:80)
	at
org.apache.camel.model.ProcessorType.createOutputsProcessor(ProcessorType.java:1500)
	at
org.apache.camel.model.ProcessorType.createOutputsProcessor(ProcessorType.java:85)
	at
org.apache.camel.model.InterceptorRef.createProcessor(InterceptorRef.java:59)
	at
org.apache.camel.model.ProcessorType.makeProcessor(ProcessorType.java:1406)
	at org.apache.camel.model.ProcessorType.addRoutes(ProcessorType.java:89)
	at org.apache.camel.model.RouteType.addRoutes(RouteType.java:189)
	at org.apache.camel.model.RouteType.addRoutes(RouteType.java:83)
	at
org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:438)
	at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:430)
	at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:47)
	at
com.lmco.bais.query.alerts.RouteAlertsTest.testAggregator(RouteAlertsTest.java:341)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at junit.framework.TestCase.runTest(TestCase.java:168)
	at junit.framework.TestCase.runBare(TestCase.java:134)
	at junit.framework.TestResult$1.protect(TestResult.java:110)
	at junit.framework.TestResult.runProtected(TestResult.java:128)
	at junit.framework.TestResult.run(TestResult.java:113)
	at junit.framework.TestCase.run(TestCase.java:124)
	at junit.framework.TestSuite.runTest(TestSuite.java:232)
	at junit.framework.TestSuite.run(TestSuite.java:227)
	at
org.junit.internal.runners.JUnit38ClassRunner.run(JUnit38ClassRunner.java:81)
	at
org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:38)
	at
org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
	at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
	at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
	at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
	at
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
13:44:10.337 ERROR [RouteAlertsTest] - Unexpected Camel exception:
java.lang.UnsupportedOperationException: Not implemented yet for class:
org.apache.camel.model.AggregatorType



Any insight would be greatly appreciated.
-- 
View this message in context: http://www.nabble.com/Aggregator-Pattern-tp19188820s22882p19188820.html
Sent from the Camel - Development mailing list archive at Nabble.com.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message