当前位置: 首页 > 知识库问答 >
问题:

spring boot+apache camel+jpa

宗政昱
2023-03-14

我正在使用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);

共有1个答案

薛朝
2023-03-14

通过@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。这是