You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Marek Schmidt (JIRA)" <ji...@apache.org> on 2015/08/19 08:47:46 UTC
[jira] [Updated] (CAMEL-9087) camel-pgevent payload always null
[ https://issues.apache.org/jira/browse/CAMEL-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Marek Schmidt updated CAMEL-9087:
---------------------------------
Attachment: pgevent.patch
> camel-pgevent payload always null
> ---------------------------------
>
> Key: CAMEL-9087
> URL: https://issues.apache.org/jira/browse/CAMEL-9087
> Project: Camel
> Issue Type: Bug
> Affects Versions: 2.15.2
> Environment: PostgreSQL 9.4.4
> Reporter: Marek Schmidt
> Labels: camel-pgevent
> Attachments: pgevent.patch
>
>
> (note, camel-pgevent doesn't seem to have a component listed in JIRA)
> Having the following reproducer
> {code}
> @ContextName("myCdiCamelContext")
> public class MyRoutes extends RouteBuilder {
> @Inject
> @Uri("pgevent://localhost:5432/postgres/foobar?user=postgres&pass=mysecretpassword")
> private Endpoint listenEndpoint;
> @Inject
> @Uri("pgevent://localhost:5432/postgres/foobar?user=postgres&pass=mysecretpassword")
> private Endpoint notifyEndpoint;
> @Inject
> @Uri("timer:foo?period=5000")
> private Endpoint timerEndpoint;
> @Inject
> @Uri("log:output")
> private Endpoint resultEndpoint;
> @Inject
> private SomeBean someBean;
> @Override
> public void configure() throws Exception {
> from(timerEndpoint)
> .transform().simple("hello")
> .to(notifyEndpoint);
> from(listenEndpoint)
> .to(resultEndpoint);
> }
> }
> {code}
> together with
> {code}
> docker run --name some-postgres -p 5432:5432 -e POSTGRES_PASSWORD=mysecretpassword -d postgres
> {code}
> the notify payload is always null
> {noformat}
> 2015-08-19 08:40:51,216 [0 - timer://foo] DEBUG SendProcessor - >>>> Endpoint[pgevent://localhost:5432/postgres/foobar?pass=mysecretpassword&user=postgres] Exchange[Message: hello]
> 2015-08-19 08:40:51,227 [C EventLoop (2)] DEBUG SendProcessor - >>>> Endpoint[log://output] Exchange[Message: null]
> 2015-08-19 08:40:51,228 [C EventLoop (2)] INFO output - Exchange[ExchangePattern: InOnly, BodyType: null, Body: [Body is null]]
> 2015-08-19 08:40:56,199 [0 - timer://foo] DEBUG SendProcessor - >>>> Endpoint[pgevent://localhost:5432/postgres/foobar?pass=mysecretpassword&user=postgres] Exchange[Message: hello]
> 2015-08-19 08:40:56,200 [C EventLoop (2)] DEBUG SendProcessor - >>>> Endpoint[log://output] Exchange[Message: null]
> 2015-08-19 08:40:56,201 [C EventLoop (2)] INFO output - Exchange[ExchangePattern: InOnly, BodyType: null, Body: [Body is null]]
> 2015-08-19 08:41:01,199 [0 - timer://foo] DEBUG SendProcessor - >>>> Endpoint[pgevent://localhost:5432/postgres/foobar?pass=mysecretpassword&user=postgres] Exchange[Message: hello]
> 2015-08-19 08:41:01,201 [C EventLoop (2)] DEBUG SendProcessor - >>>> Endpoint[log://output] Exchange[Message: null]
> 2015-08-19 08:41:01,201 [C EventLoop (2)] INFO output - Exchange[ExchangePattern: InOnly, BodyType: null, Body: [Body is null]]
> {noformat}
> It seems that the camel-pgevent consumer uses
> outOnly.setOut(msg);
> instead of
> outOnly.setIn(msg);
> and the producer
> exchange.getOut()
> instead of
> exchange.getIn()
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)