java—跟踪发布到事件中心并存储在执行上下文中的项的计数

j8yoct9x  于 2021-07-13  发布在  Java
关注(0)|答案(1)|浏览(390)

我在一个普通maven项目中有一个接口,有两个发布方法都返回布尔值:

public interface IPublisher<T, U> {    
    boolean publish(Context ctx, T model);    
    boolean publish(Context ctx, List<? extends ModelHolder> model);    
}

我有一个接口的实现:

public class Publisher implements IPublisher<PriceHolder, JSONObject> {

    private final DataPublisher dataPublisher;

    public Publisher(final DataPublisher dataPublisher) {
        this.dataPublisher = dataPublisher;
    }

    @Override
    public boolean publish(Context context, PriceHolder priceHolder) {

        if (isInvalid(priceHolder)) {
            return false;
        }

        try {
            dataPublisher.publish(data);

        } catch (ConnectionException | DataBuilderException ex) {
            String message = "someMessage";
            LOGGER.error(message, ex);
        } catch (TimeoutException e) {
            LOGGER.error(message, e);
        }

        return true;
    }

    @Override
    public boolean publish(Context ctx, List<? extends ModelHolder> list) {
        if (list == null) {
            return false;
        }

        for (ModelHolder item : list) {
            publish(ctx, (PriceHolder) item);
        }

        return true;
    }

    private boolean isInvalid(PriceHolder priceHolder) {
    }
}

目前,这个实现没有记录发布了多少,这是我需要传递给正在调用的客户机的 publish() .
客户端示例化publisher类的spring bean:

@Bean
public IPublisher publisher(DataItemPublisher dataItemPublisher) {
    return new Publisher(dataItemPublisher);
}

客户端应用程序正在使用spring批处理,它在工作流配置类中发布如下:

@Bean
@Scope(value = "step", proxyMode = ScopedProxyMode.INTERFACES)
public ItemWriter<PriceHolder> publish(@Value("#{jobExecutionContext['MY_CONTEXT']}") Context ctx) {
    return items -> {
        publisher.publish(ctx, items);
    };
}

哪里 publisher 是ipublisher示例。这些项是以块的形式处理的,在处理结束时,我需要一个已发布数量的摘要计数,但我不确定如何实现这一点,因为publish()返回布尔值。我想得到总的发布计数,然后我可以在executioncontext中保存它。以便我可以在工作流的后续步骤中使用此计数进行报告。e、 g.接收与发布计数。我怎样才能做到这一点?

oalqel3c

oalqel3c1#

目前,这个实现没有记录发布了多少,这是我需要传递给调用publish()的客户机的。
因为这个实现没有为客户机提供一种方法来知道发布了多少项,而且因为您说过 The client app is using spring batch ,您将无法获取该信息并将其存储到spring批处理的执行上下文中。您需要修复接口并使其返回比boolean更丰富的类型。

相关问题