spring-retry

    1热度

    2回答

    我正在对另一个服务进行REST调用以保存数据库上的项目。数据非常重要,所以我们不能承受任何损失。 如果网络出现问题,此消息将会丢失,而这种情况不会发生。我已经搜索了关于Spring Retry的信息,并且我看到它旨在处理暂时的网络故障,这不是我所需要的。 我需要一种方法把某种队列(如Active MQ)的REST调用和维护秩序(因为我得到保存,删除,这是非常重要的,更新REST调用。) 任何想法?

    1热度

    1回答

    我的设置: 我有一个消息守护进程使用ActiveMQ将消耗JSON消息。 JSON消息的发布者添加了具有值的type头,例如,com.example.Foo这是json消息的类型。我用这个将json转换成pojo。 Spring配置: 一旦接收到消息,这些都是它通过以下步骤: 1.变压器:来变换JSON来POJO 2.净荷类型路由器:基于POJO的类型,将pojo路由到适当的服务激活者。 3.服务

    3热度

    1回答

    是否可以根据特定条件重试?如果我使用Retryable进行注释,它将根据某些异常重试,但如果捕获该异常并满足相应的条件,我想重试。 实施例: @Retryable(value={MyException.class},maxAttempts=2) public myMethod(Request request){ try{ doSomething(); } Cat

    1热度

    1回答

    是否可以根据错误状态码在春季重试中设置RetryPolicy?例如我不想在HttpStatus.BAD_REQUEST状态码为400时重试HttpClientErrorException。因此,它应该忽略所有其他错误码 - 4XX。 我正在使用Spring集成http outboundGateway调用服务器。 现在在我RequestHandlerRetryAdvice我作为 SimpleRetr

    0热度

    1回答

    我找不到任何有关我需要的操作可能性的信息。我正在使用@Retry处理方法使用@Retryable注释。 Smth像这样: @Retryable(value = {Exception.class}, maxAttempts = 5, backoff = @Backoff(delay = 10000)) public void update(Integer id) {

    0热度

    1回答

    在Spring Core Advice API docs有两种意见的定义: 每个类的建议 - 这一定不是“依赖于代理对象的状态或添加新的状态” 基于实例的通知 - 即“添加状态到被代理对象” RequestHandlerRetryAdvice,每次的javadoc,有一个无状态和操作的状态模式。 在哪些情况下可以使用RequestHandlerRetryAdvice作为每个类的建议? (即使用单个

    0热度

    1回答

    我想测试,如果我的方法调用被重试几次,如果发生一些异常。如果我直接调用方法,它可以正常工作。但是如果我在单独的线程中调用它,我的测试方法失败,它不会看到任何重试尝试。 这是我的方法: public class MyClass { @Inject private ServiceClass service; @Retryable(value = {Exceptio

    0热度

    1回答

    当我在@Transactional和@Retryable(value = StaleStateException.class) method foo()的末尾发布CustomEvent时,它是如何处理的? 如果我在方法执行后提交期间得到StaleStateException,那么@TransactionalEventListener(phase = TransactionPhase.AFTER_C

    1热度

    1回答

    我发布消息到RabbitMQ的,我想跟踪误差时RabbitMQ的下跌,为了这个,我增加了一个RetryTemplate与恢复回调,但回调的恢复只提供此方法getLastThrowable()和我不确定如何提供RabbitMQ关闭时失败的消息的详细信息。 (按照文档“的RecoveryCallback有一定的限制,该重试上下文只包含 lastThrowable场。对于更复杂的使用情况下,你应该使用一

    2热度

    2回答

    我已经使用Spring声明重试在我的项目像 @Service class Service { @Async @Retryable(maxAttempts=12, [email protected](delay=100, maxDelay=500)) public service() { // ... do something } } 现在,我有两个