package com.perforce.p4camel;
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import org.apache.camel.impl.DefaultProducer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class P4Producer extends DefaultProducer {
private static Logger logger = LoggerFactory.getLogger(P4Producer.class);
public P4Producer(Endpoint endpoint) {
super(endpoint);
logger.info("Producer: constructor");
}
@Override
public void process(Exchange exchange) throws Exception {
P4Endpoint p4 = (P4Endpoint) getEndpoint();
logger.info("pass: " + p4.getFoo());
logger.info(exchange.getIn().getBody(String.class));
}
}