Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 30448200BAA for ; Thu, 27 Oct 2016 19:41:30 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 2EE29160AF6; Thu, 27 Oct 2016 17:41:30 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 4EC69160AE6 for ; Thu, 27 Oct 2016 19:41:29 +0200 (CEST) Received: (qmail 63951 invoked by uid 500); 27 Oct 2016 17:41:28 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 63939 invoked by uid 99); 27 Oct 2016 17:41:27 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Oct 2016 17:41:27 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 134131A9548 for ; Thu, 27 Oct 2016 17:41:27 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.48 X-Spam-Level: X-Spam-Status: No, score=0.48 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=pronoia-solutions-com.20150623.gappssmtp.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 4jyZyj4cymrn for ; Thu, 27 Oct 2016 17:41:25 +0000 (UTC) Received: from mail-yw0-f169.google.com (mail-yw0-f169.google.com [209.85.161.169]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id B5F095F1B3 for ; Thu, 27 Oct 2016 17:41:24 +0000 (UTC) Received: by mail-yw0-f169.google.com with SMTP id w3so51009016ywg.1 for ; Thu, 27 Oct 2016 10:41:24 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=pronoia-solutions-com.20150623.gappssmtp.com; s=20150623; h=from:content-transfer-encoding:mime-version:subject:date:references :to:in-reply-to:message-id; bh=DEcrMD0cRO+XW/hCmfLE1eCoS0EmhINBnUKKBKynlm8=; b=UxUW+6lHq3AGEFgASsm/2XPDxxV9+n83lkWcEqatZ3c0zGRvtkw5+qeM9juPO3kb3R DVXcQu/Swr3pjnTIDjxWW0fkRvzOAYttK+LJZqy6FL1tWKfiL7wxFjNIrEYWaXk8Lsc6 5kreQd9G0USNQF/ytLZEQs53gTvvnvggJu4AAbZcPe5ygFxV4E1vs5Nu81GUgCVdUUt0 mFOY2+D0CWBxw10JVF9ytyWTPxLKH8F66sndQsJQFsAhHT9/cntIBYT+7zWoGsqN/gXc esSl+M5CyCJCxFgxaGaSUjNBMIXApkjgUScNoHVAbh8k+Jd6hBOKl2pCubBh3il9mqXZ fk7A== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:content-transfer-encoding:mime-version :subject:date:references:to:in-reply-to:message-id; bh=DEcrMD0cRO+XW/hCmfLE1eCoS0EmhINBnUKKBKynlm8=; b=Q1pgD6GBYTdVGHuQ0DKkj+MM8rZw6j6s/OshvOfR14KpA6+7xHCNly6d5EyXUJtugd 7t6J0VT3GAgDXo1ehepwL2DM28jB4eVTGzKrF5IH5jCI2Kze9jjXkEThs30kx/zg1pxk AS2uwBdVQwbB9tJDHYhVfnAt2/UDiXv5CmueXniQ9h8hQm/GZTv6KM9Yu3GHVhUAIJJr g5S68Z4JkliQRTlSDp5DvriCyhueVUNsX1ESV86ZEkC+pTOU73NjTUZR+wF2yelR3WAg aBPJPWvXj2XFEtBTv6oLZiUafwjUN7rn/uAkgmt30kvgZ7kLy4skYfX56afOqwyQyYrI m9aA== X-Gm-Message-State: ABUngvfAt7Iyk64+hIYrs1kJp4yngGqoIVXTgasN9HYiO5qtUduT0efmtUiSzvZzeMoekA== X-Received: by 10.107.132.206 with SMTP id o75mr7624682ioi.234.1477590045865; Thu, 27 Oct 2016 10:40:45 -0700 (PDT) Received: from macpro.pronoia.local (c-24-10-239-245.hsd1.ut.comcast.net. [24.10.239.245]) by smtp.gmail.com with ESMTPSA id f103sm3251795iod.25.2016.10.27.10.40.45 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Thu, 27 Oct 2016 10:40:45 -0700 (PDT) From: Quinn Stevenson Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable Mime-Version: 1.0 (Mac OS X Mail 10.1 \(3251\)) Subject: Re: Losing mi sanity on pipeline testing Date: Thu, 27 Oct 2016 11:40:44 -0600 References: <1B239748-C69D-4F48-AACD-235710BB40B1@gmail.com> To: users@camel.apache.org In-Reply-To: <1B239748-C69D-4F48-AACD-235710BB40B1@gmail.com> Message-Id: <1F7AACAB-3F90-443A-899B-1DB1D3D4AF54@pronoia-solutions.com> X-Mailer: Apple Mail (2.3251) archived-at: Thu, 27 Oct 2016 17:41:30 -0000 I=E2=80=99m assuming you=E2=80=99re just trying to get the DataSet to = work for testing - correct? (DataSet isn=E2=80=99t really meant for = anything other than testing). If that=E2=80=99s the case, use the DataSet as the Consumer - i.e. = from(=E2=80=9Cdataset://source=E2=80=9D) and you should be OK. > On Oct 27, 2016, at 7:15 AM, Edoardo Causarano = wrote: >=20 > Hi, >=20 > answers inline: >=20 >> On 27 Oct 2016, at 14:50, Brad Johnson = wrote: >>=20 >> Try putting in .log(${body}) in between each of the lines and see = what you >> get. It appears you are using the SimpleDataSet which takes a single >> String. What behavior are you expecting from ti? Is it throwing an >> exception? Have you tried sending in a List with a = ListDataSet to >> see what behavior it gives you? >=20 > I=E2=80=99m expecting the SimpleDataSet to provide 1 message body = consisting of a List (a list of items from a DropBox query.) > It=E2=80=99s throwing when trying to assert that the body correspond = to the data provided by the direct producer template (I only figured = that out after step debugging, is this the intended behavior?)=20 >=20 >> Is there a specific reason you are using a .pipeline() call = explicitly? I >> believe that's the default behavior. The only reason I can think of >> explicitly using it is when you just want to use it as a short hand = for >> routing as shown in the Camel documentation. You don't have to chain = a >> bunch of to() method calls then. >=20 > Because I=E2=80=99d like to broadcast a timer trigger to a couple = pipelines consisting of remote API getters and transformers. Otherwise = all stages - including the transformers - would be directly wired to the = timer and that would make no sense.=20 >=20 > timer --> pipeline(dropbox, transformer) --> doStuff > |-> pipeline(google, transformer) --| =20 >=20 >=20 > Best, > Edoardo >=20 >> from("direct:a").pipeline("direct:x", "direct:y", "direct:z", >> "mock:result"); >>=20 >> On Thu, Oct 27, 2016 at 7:03 AM, Edoardo Causarano < >> edoardo.causarano@gmail.com> wrote: >>=20 >>> Hi all, >>>=20 >>> I=E2=80=99m trying to do something relatively simple, yet it=E2=80=99s= been eluding me for >>> hours already! >>>=20 >>> I=E2=80=99d like to have a timer trigger a broadcast to a couple = pipelines to >>> invoke a remote cloud component, transform the responses to a common = type >>> and merge the results in one homogenous list to further process. >>>=20 >>> It=E2=80=99s been a nightmare so far and even testing is proving to = be nigh >>> impossible, even this simple setup is failing with a : >>>=20 >>> @Override >>> protected RouteBuilder createRouteBuilder() { >>> return new RouteBuilder() { >>> @Override >>> public void configure() throws Exception { >>> from("direct:start").pipeline() >>> .to("dataset:source") >>> .to("dropBoxTranslator") >>> .end() >>> .to("mock:result"); >>> } >>> }; >>> } >>>=20 >>> Seems that the dataset endpoint tries to assert that its=E2=80=99 = own output equal >>> the dummy string I sent from the direct:start producer to execute an >>> exchange (in = org.apache.camel.component.dataset.DataSetSupport#assertMessageExpected). >>> What on earth is going on?! >>>=20 >>>=20 >>> Best, >>> Edoardo >=20