springmvc camel mybatis集成实例

package com.ugarden.service; import org.apache.camel.CamelContext; import org.apache.camel.Exchange; import org.apache.camel.ExchangePattern; import org.apache.camel.ProducerTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.ugarden.entity.User; /** * @creator fanly * @date 2013-3-27 上午10:30:19 * @email fanly1987444@126.com */ @Service public class UserService { @Autowired private ProducerTemplate producerTemplate; @Autowired private CamelContext camelContext; public void insertUser() throws Exception { //init test user entity User user = new User(); user.setEmail("fanly" + System.currentTimeMillis() + "@126.com"); user.setPassword("123456"); user.setId(String.valueOf(System.currentTimeMillis())); user.setRealName("张双"); Exchange in = this.camelContext.getEndpoint("direct:start").createExchange(ExchangePattern.InOut); in.getIn().setBody(user); Exchange out = this.producerTemplate.send("mybatis:insert?statementType=Insert", in); if (null != out.getException()) { throw out.getException(); } } }