[jira] [Created] (CAMEL-9087) camel-pgevent payload always null

[Marek Schmidt (JIRA)]

Marek Schmidt created CAMEL-9087:
------------------------------------

             Summary: 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


(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)