1 /*
2 * SymmetricDS is an open source database synchronization solution.
3 *
4 * Copyright (C) Chris Henson <chenson42@users.sourceforge.net>,
5 * Eric Long <erilong@users.sourceforge.net>,
6 * Keith Naas <knaas@users.sourceforge.net>
7 *
8 *
9 * This library is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU Lesser General Public
11 * License as published by the Free Software Foundation; either
12 * version 3 of the License, or (at your option) any later version.
13 *
14 * This library is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 * Lesser General Public License for more details.
18 *
19 * You should have received a copy of the GNU Lesser General Public
20 * License along with this library; if not, see
21 * <http://www.gnu.org/licenses/>.
22 */
23
24 package org.jumpmind.symmetric.transport.handler;
25
26 import java.io.IOException;
27 import java.util.List;
28
29 import org.jumpmind.symmetric.model.BatchInfo;
30 import org.jumpmind.symmetric.service.IAcknowledgeService;
31
32 public class AckResourceHandler extends AbstractTransportResourceHandler {
33 private IAcknowledgeService acknowledgeService;
34
35 public void ack(List<BatchInfo> batches) throws IOException {
36 for (BatchInfo batchInfo : batches) {
37 acknowledgeService.ack(batchInfo);
38 }
39 }
40
41 public void setAcknowledgeService(IAcknowledgeService acknowledgeService) {
42 this.acknowledgeService = acknowledgeService;
43 }
44 }