我在一个普通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.接收与发布计数。我怎样才能做到这一点?
1条答案
按热度按时间oalqel3c1#
目前,这个实现没有记录发布了多少,这是我需要传递给调用publish()的客户机的。
因为这个实现没有为客户机提供一种方法来知道发布了多少项,而且因为您说过
The client app is using spring batch
,您将无法获取该信息并将其存储到spring批处理的执行上下文中。您需要修复接口并使其返回比boolean更丰富的类型。