我正在使用spring boot+apache camel+JPA创建一个新项目。
它应该很简单,但有些东西配置错误,我找不到它是什么。
@SpringBootApplication
@EnableAutoConfiguration
public class PolicyUpdateWebServiceApplication {
protected static final Logger LOG = Logger.getLogger(PolicyUpdateWebServiceApplication.class);
public static void main(String[] args) {
new SpringApplication(PolicyUpdateWebServiceApplication.class).run(args);
}
@Bean
public ServletRegistrationBean dispatcherServlet() {
return new ServletRegistrationBean(new CXFServlet(), "/webservices/*");
}
@Bean(name= Bus.DEFAULT_BUS_ID)
public SpringBus springBus() {
return new SpringBus();
}
}
@Entity
@XmlRootElement(
name = "TransactionInfo"
)
@XmlCDATA({"bookingXML"})
@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(
name = "TransactionInfo",
propOrder = {"transactionId", "CCVB", "quoteNumber", "policyNumber", "bookingXML", "creationDate", "lastModified", "status", "statusDescription"}
)
public class TransactionInfo implements Serializable {
private static final long serialVersionUID = -2368497973443507661L;
@Id
private String transactionId;
@Embedded
@Column(nullable = false)
private CCVB CCVB;
@Column(nullable = false, length = 50)
private String quoteNumber;
@Column(nullable = false, length = 50)
private String policyNumber;
@Column(nullable = false)
private String bookingXML;
@XmlJavaTypeAdapter(XMLDateAdapter.class)
@Column(nullable = false, updatable = false)
private Date creationDate;
@XmlJavaTypeAdapter(XMLDateAdapter.class)
@Column(nullable = false)
private Date lastModified;
@Column(length = 4, nullable = false)
private IntegrationStatus status;
@Column(length = 100)
private String statusDescription;
存储库:
@Repository
public interface TransactionInfoRepository extends CrudRepository<TransactionInfo, String> {
TransactionInfo findByTransactionId(String name);
TransactionInfo save(TransactionInfo TransactionInfo);
}
服务:
public interface TransactionInfoService {
void saveTransactionInfo(TransactionInfo transactionInfo);
}
服务实现:
@Component("transactionInfoService")
@Transactional
public class TransactionInfoServiceImpl implements TransactionInfoService {
@Autowired
TransactionInfoRepository transactionInfoRepository;
public void saveTransactionInfo(TransactionInfo transactionInfo) {
transactionInfoRepository.save(transactionInfo);
}
}
public class PolicyPublishProcessor implements Processor {
@Autowired
TransactionInfoService transactionInfoService;
TransactionInfo transactionInfo = new TransactionInfo();
// save a couple of customers
transactionInfoService.saveTransactionInfo(transactionInfo);
通过@component
注释使您的Camel处理器成为一个Spring bean。
我正在尝试向异步路由发送消息,但它不起作用。我刚刚在github上创建了一个项目来模拟这个问题
我正在使用apache camel cxf开发一个Web服务(肥皂),我遇到了这个错误。 Java . lang . illegalargumentexception:Part { http://blue print . camel . ngt . TN/}返回的类型应为[ltn . ngt . camel . blue print . WB _ subscriptions;,而不是org . A
我有一个restendpoint示例。org,返回表单的json响应 我的路线是这样的 我读过关于轮询消费者的内容,但找不到如何继续轮询endpoint的示例,直到它返回“success”响应。 是否应该使用轮询消费者?如果是这样的话,可以举一个与我的案例相关的例子。用于轮询restendpoint的任何其他资源都非常有用。
我试图在聚合器完成后获得一个回复,但是我得到一个异常,我没有指定任何聚合器子项,但是当我指定一个。to()endpoint我没有收到聚合结果。。。这可能吗? 控制器: 聚合器:
我想测试以下骆驼路线。我在网上找到的所有例子都有以文件开头的路由,在我的例子中,我有一个Springbean方法,每隔几分钟就会被调用一次,最后消息被转换并移动到jms以及审计目录。 我对这条路线的写测试毫无头绪。目前我在测试用例中所拥有的是
我从基于apache-camel-spark的rest接口获得一个json数组作为输入。开始时,我想通过apache camels路线分割json-array来处理每个元素。我该怎么做? 我的测试输入json: 对于这个问题,我在stackoverflow上找到了一些间接描述的问题: link 1, link 2, link 3。 根据这些示例,我尝试了以下骆驼路线: 当我这样做时,我总是得到以下
Apache Camel:2.12.2,activemq:5.7 我们注意到,在下面的路由中,对于前100次交换,节流工作正常。此后,它不是每秒发送100次交换,而是每秒仅发送1次交换。现在,如果我们将timePeriodMillis设置为100,它似乎可以正常工作。注意,我们同时发送500个交换。
我需要将文件从文件夹同步到restendpoint。因此,如果文件被放置在特定文件夹中,我需要将该文件发送到接受多部分文件的RESTendpoint。我正在使用ApacheCamel来实现这一点。 RESTendpoint在Spring中编写,如下所示: 我是Camel的新手,并且已经弄清楚了如何通过构建路由并获取文件来轮询目录,但是我无法弄清楚如何使用此路由将此文件放入其余endpoint。这是