[
https://issues.apache.org/jira/browse/CAMEL-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pascal Schumacher updated CAMEL-12184:
--------------------------------------
Description:
I'm using an EventNotifier with Camel Spring, which is basically a copy of
[https://github.com/apache/camel/blob/f6ac3d81420d3f53b029a0f0c31dd4610810e2c2/camel-core/src/test/java/org/apache/camel/processor/MyLoggingSentEventNotifer.java]
After upgrading to Camel 2.20.1 from 2.19.1 it does not receive
ExchangeSentEvents anymore. It is still picked up by Camel according to log:
"org.apache.camel.core.xml.AbstractCamelContextFactoryBean - Using custom
EventNotifier with id: myLoggingEventNotifier and implementation:
test.MyLoggingSentEventNotifer@5f7b97da" and ExchangeCreatedEvents,
ExchangeSendingEvents, ExchangeCompletedEvents are received as before. Only
ExchangeSentEvents are missing.
Complete example to reproduce this issue:
{code:title=MyLoggingSentEventNotifer.java}
public class MyLoggingSentEventNotifer extends EventNotifierSupport {
public void notify(EventObject event) throws Exception {
if (event instanceof ExchangeSentEvent) {
ExchangeSentEvent sent = (ExchangeSentEvent) event;
log.info("Took {} millis to send to: {}", sent.getTimeTaken(),
sent.getEndpoint());
}
}
public boolean isEnabled(EventObject event) {
return event instanceof ExchangeSentEvent;
}
protected void doStart() throws Exception {
}
protected void doStop() throws Exception {
}
}
{code:title=test-beans.xml}
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd";>
<bean id="myLoggingEventNotifier" class="test.MyLoggingSentEventNotifer" />
<camelContext xmlns="http://camel.apache.org/schema/spring";>
<route>
<from uri="direct:start" />
<to uri="direct:bar" />
<to uri="mock:result" />
</route>
<route>
<from uri="direct:bar" />
<delay>
<constant>1000</constant>
</delay>
</route>
</camelContext>
</beans>
{code}
{code}
{code:title=EventNotifierExchangeSentExampleTest.java}
@RunWith(CamelSpringRunner.class)
@BootstrapWith(CamelTestContextBootstrapper.class)
@ContextConfiguration(locations = {"classpath:/test-beans.xml"})
public class EventNotifierExchangeSentExampleTest {
@EndpointInject(uri = "direct:start")
ProducerTemplate producer;
@EndpointInject(uri = "mock:result")
MockEndpoint out;
@Test
public void testExchangeSent() throws Exception {
out.expectedMessageCount(1);
producer.sendBody("Hello World");
out.assertIsSatisfied();
}
}
{code}
{code:title=pom.xml}
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
<modelVersion>4.0.0</modelVersion>
<groupId>com.test</groupId>
<artifactId>CamelSpringEventNotifierExchangeSentEventsBug</artifactId>
<version>0.0.1-SNAPSHOT</version>
<properties>
<camel.version>2.20.1</camel.version>
<!-- camel.version>2.19.1</camel.version -->
</properties>
<dependencies>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring</artifactId>
<version>${camel.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-test-spring</artifactId>
<version>${camel.version}</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.2</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.7.0</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
{code}
Complete code on github:
https://github.com/PascalSchumacher/CamelSpringEventNotifierExchangeSentEventsBug
was:
I'm using an EventNotifier with Camel Spring, which is basically a copy of
[{color:#0000FF}+https://github.com/apache/camel/blob/f6ac3d81420d3f53b029a0f0c31dd4610810e2c2/camel-core/src/test/java/org/apache/camel/processor/MyLoggingSentEventNotifer.java+{color}]
After upgrading to Camel 2.20.1 from 2.19.1 it does not receive
ExchangeSentEvents anymore. It is still picked up by Camel according to log:
"org.apache.camel.core.xml.AbstractCamelContextFactoryBean - Using custom
EventNotifier with id: myLoggingEventNotifier and implementation:
test.MyLoggingSentEventNotifer@5f7b97da" and ExchangeCreatedEvents,
ExchangeSendingEvents, ExchangeCompletedEvents are received as before. Only
ExchangeSentEvents are missing.
Complete example to reproduce this issue:
{code:title=MyLoggingSentEventNotifer.java}
public class MyLoggingSentEventNotifer extends EventNotifierSupport {
public void notify(EventObject event) throws Exception {
if (event instanceof ExchangeSentEvent) {
ExchangeSentEvent sent = (ExchangeSentEvent) event;
log.info("Took {} millis to send to: {}", sent.getTimeTaken(),
sent.getEndpoint());
}
}
public boolean isEnabled(EventObject event) {
return event instanceof ExchangeSentEvent;
}
protected void doStart() throws Exception {
}
protected void doStop() throws Exception {
}
}
{code:title=test-beans.xml}
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd";>
<bean id="myLoggingEventNotifier" class="test.MyLoggingSentEventNotifer" />
<camelContext xmlns="http://camel.apache.org/schema/spring";>
<route>
<from uri="direct:start" />
<to uri="direct:bar" />
<to uri="mock:result" />
</route>
<route>
<from uri="direct:bar" />
<delay>
<constant>1000</constant>
</delay>
</route>
</camelContext>
</beans>
{code}
{code}
{code:title=EventNotifierExchangeSentExampleTest.java}
@RunWith(CamelSpringRunner.class)
@BootstrapWith(CamelTestContextBootstrapper.class)
@ContextConfiguration(locations = {"classpath:/test-beans.xml"})
public class EventNotifierExchangeSentExampleTest {
@EndpointInject(uri = "direct:start")
ProducerTemplate producer;
@EndpointInject(uri = "mock:result")
MockEndpoint out;
@Test
public void testExchangeSent() throws Exception {
out.expectedMessageCount(1);
producer.sendBody("Hello World");
out.assertIsSatisfied();
}
}
{code}
{code:title=pom.xml}
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
<modelVersion>4.0.0</modelVersion>
<groupId>com.test</groupId>
<artifactId>CamelSpringEventNotifierExchangeSentEventsBug</artifactId>
<version>0.0.1-SNAPSHOT</version>
<properties>
<camel.version>2.20.1</camel.version>
<!-- camel.version>2.19.1</camel.version -->
</properties>
<dependencies>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-spring</artifactId>
<version>${camel.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-test-spring</artifactId>
<version>${camel.version}</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.2</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.7.0</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
{code}
Complete Code on github:
https://github.com/PascalSchumacher/CamelSpringEventNotifierExchangeSentEventsBug
> Camel-Spring: EventNotifierSupport does not receive ExchangeSentEvents anymore
> ------------------------------------------------------------------------------
>
> Key: CAMEL-12184
> URL: https://issues.apache.org/jira/browse/CAMEL-12184
> Project: Camel
> Issue Type: Bug
> Components: camel-spring
> Affects Versions: 2.20.1
> Reporter: Pascal Schumacher
> Priority: Minor
>
> I'm using an EventNotifier with Camel Spring, which is basically a copy of
> [https://github.com/apache/camel/blob/f6ac3d81420d3f53b029a0f0c31dd4610810e2c2/camel-core/src/test/java/org/apache/camel/processor/MyLoggingSentEventNotifer.java]
> After upgrading to Camel 2.20.1 from 2.19.1 it does not receive
> ExchangeSentEvents anymore. It is still picked up by Camel according to log:
> "org.apache.camel.core.xml.AbstractCamelContextFactoryBean - Using custom
> EventNotifier with id: myLoggingEventNotifier and implementation:
> test.MyLoggingSentEventNotifer@5f7b97da" and ExchangeCreatedEvents,
> ExchangeSendingEvents, ExchangeCompletedEvents are received as before. Only
> ExchangeSentEvents are missing.
> Complete example to reproduce this issue:
> {code:title=MyLoggingSentEventNotifer.java}
> public class MyLoggingSentEventNotifer extends EventNotifierSupport {
> public void notify(EventObject event) throws Exception {
> if (event instanceof ExchangeSentEvent) {
> ExchangeSentEvent sent = (ExchangeSentEvent) event;
> log.info("Took {} millis to send to: {}", sent.getTimeTaken(),
> sent.getEndpoint());
> }
> }
> public boolean isEnabled(EventObject event) {
> return event instanceof ExchangeSentEvent;
> }
> protected void doStart() throws Exception {
> }
> protected void doStop() throws Exception {
> }
> }
> {code:title=test-beans.xml}
> <?xml version="1.0" encoding="UTF-8"?>
> <beans xmlns="http://www.springframework.org/schema/beans";
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd";>
> <bean id="myLoggingEventNotifier" class="test.MyLoggingSentEventNotifer"
> />
> <camelContext xmlns="http://camel.apache.org/schema/spring";>
> <route>
> <from uri="direct:start" />
> <to uri="direct:bar" />
> <to uri="mock:result" />
> </route>
> <route>
> <from uri="direct:bar" />
> <delay>
> <constant>1000</constant>
> </delay>
> </route>
> </camelContext>
> </beans>
> {code}
> {code}
> {code:title=EventNotifierExchangeSentExampleTest.java}
> @RunWith(CamelSpringRunner.class)
> @BootstrapWith(CamelTestContextBootstrapper.class)
> @ContextConfiguration(locations = {"classpath:/test-beans.xml"})
> public class EventNotifierExchangeSentExampleTest {
> @EndpointInject(uri = "direct:start")
> ProducerTemplate producer;
> @EndpointInject(uri = "mock:result")
> MockEndpoint out;
> @Test
> public void testExchangeSent() throws Exception {
> out.expectedMessageCount(1);
> producer.sendBody("Hello World");
> out.assertIsSatisfied();
> }
> }
> {code}
> {code:title=pom.xml}
> <project xmlns="http://maven.apache.org/POM/4.0.0";
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
> http://maven.apache.org/xsd/maven-4.0.0.xsd";>
> <modelVersion>4.0.0</modelVersion>
> <groupId>com.test</groupId>
> <artifactId>CamelSpringEventNotifierExchangeSentEventsBug</artifactId>
> <version>0.0.1-SNAPSHOT</version>
> <properties>
> <camel.version>2.20.1</camel.version>
> <!-- camel.version>2.19.1</camel.version -->
> </properties>
> <dependencies>
> <dependency>
> <groupId>org.apache.camel</groupId>
> <artifactId>camel-spring</artifactId>
> <version>${camel.version}</version>
> </dependency>
> <dependency>
> <groupId>org.apache.camel</groupId>
> <artifactId>camel-test-spring</artifactId>
> <version>${camel.version}</version>
> </dependency>
> <dependency>
> <groupId>ch.qos.logback</groupId>
> <artifactId>logback-classic</artifactId>
> <version>1.2.2</version>
> </dependency>
> </dependencies>
> <build>
> <plugins>
> <plugin>
> <groupId>org.apache.maven.plugins</groupId>
> <artifactId>maven-compiler-plugin</artifactId>
> <version>3.7.0</version>
> <configuration>
> <source>1.8</source>
> <target>1.8</target>
> </configuration>
> </plugin>
> </plugins>
> </build>
> </project>
> {code}
> Complete code on github:
> https://github.com/PascalSchumacher/CamelSpringEventNotifierExchangeSentEventsBug
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
