camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matt Raible <m...@raibledesigns.com>
Subject Email Error on Route Exception
Date Thu, 22 May 2014 15:41:34 GMT
Hello all,

I'm getting up to speed on Apache Camel and trying to replace a "message
flow" that was originally written for IBM Message Broker 6.1. The flow
involves receiving input from a SOAP service, looking up a value in a
database, and returning that to the client (again, via SOAP). I have a
route that works and now I'm trying to add exception handling to it.
Ideally, an email can be generated when an exception occurs.

Here's my Route:

public class FooRoute extends RouteBuilder {

private String uri = "cxf:/foo?serviceClass=" + FooService.class.getName();

private Log log = LogFactory.getLog(FooRoute.class);

@Autowired
private MailSender mailSender;

@Autowired
private SimpleMailMessage mailMessage;

@Override
 public void configure() throws Exception {
onException(Exception.class)
.process(new Processor() {
 public void process(Exchange exchange) throws Exception {
Exception exception = (Exception)
exchange.getProperty(Exchange.EXCEPTION_CAUGHT);
 // email error
mailMessage.setTo("mraible@apache.org");
 mailMessage.setSubject("ERROR!!");
mailMessage.setText("WTF?!\n\n " + exception.getMessage());
 mailSender.send(mailMessage);
}
});
 from(uri)
.to("log:input")
// send the request to the route to handle the operation
 // the name of the operation is in that header
.recipientList(simple("direct:${header.operationName}"));
 from("direct:findById")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
 // get the id from the input
String id = exchange.getIn().getBody(FooRequest.class).getId();
 exchange.getOut().setBody(id);
}
})
.to("sql:select value from table where id = #?dataSource=ds")
 .to("log:output")
.process(new Processor() {
public void process(Exchange exchange) throws Exception {
 // get the value from the input
List<HashMap> data = (ArrayList<HashMap>) exchange.getIn().getBody();
 // todo: handle value is empty
FooResponse response = new FooResponse();
response.setGpi(String.valueOf(data.get(0).get("value")));
 exchange.getOut().setBody(response);
}
}).end();
 }
}

The problem that I'm experiencing is that the Autowired dependencies from
Spring are not getting set. Do I need to do something special to allow
Spring dependencies in my route or is there an easier way to send exception
emails?

Here's how I have my routes configured using Spring's JavaConfig:

@Configuration
@ImportResource("classpath:META-INF/cxf/cxf.xml")
public class CamelConfig extends CamelConfiguration implements
InitializingBean {

/**
 * Returns the CamelContext which support Spring
 */
 @Override
protected CamelContext createCamelContext() throws Exception {
return new SpringCamelContext(getApplicationContext());
 }

@Override
public List<RouteBuilder> routes() {
 List<RouteBuilder> routes = new ArrayList<>();
routes.add(new FooRoute());
return routes;
 }

public void afterPropertiesSet() throws Exception {}
}

Thanks,

Matt

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