View Javadoc

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    *
7    * This library is free software; you can redistribute it and/or
8    * modify it under the terms of the GNU Lesser General Public
9    * License as published by the Free Software Foundation; either
10   * version 3 of the License, or (at your option) any later version.
11   *
12   * This library is distributed in the hope that it will be useful,
13   * but WITHOUT ANY WARRANTY; without even the implied warranty of
14   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15   * Lesser General Public License for more details.
16   *
17   * You should have received a copy of the GNU Lesser General Public
18   * License along with this library; if not, see
19   * <http://www.gnu.org/licenses/>.
20   */
21  
22  package org.jumpmind.symmetric.service;
23  
24  import java.util.List;
25  
26  import org.jumpmind.symmetric.model.NodeChannel;
27  import org.jumpmind.symmetric.model.OutgoingBatch;
28  import org.jumpmind.symmetric.model.OutgoingBatchHistory;
29  import org.jumpmind.symmetric.model.OutgoingBatch.Status;
30  
31  public interface IOutgoingBatchService {
32      public void insertOutgoingBatch(final OutgoingBatch outgoingBatch);
33  
34      @Deprecated
35      public void buildOutgoingBatches(String nodeId, final List<NodeChannel> channels);
36  
37      public void buildOutgoingBatches(final String nodeId, final NodeChannel channel);
38  
39      public List<OutgoingBatch> getOutgoingBatches(String nodeId);
40  
41      public List<OutgoingBatch> getOutgoingBatchRange(String startBatchId, String endBatchId);
42  
43      public List<OutgoingBatch> getOutgoingBatcheErrors(int maxRows);
44  
45      @Deprecated
46      public void markOutgoingBatchSent(OutgoingBatch batch);
47  
48      public void setBatchStatus(long batchId, Status status);
49  
50      public boolean isInitialLoadComplete(String nodeId);
51  
52      public List<OutgoingBatchHistory> findOutgoingBatchHistory(long batchId, String nodeId);
53  
54      public void insertOutgoingBatchHistory(OutgoingBatchHistory history);
55  
56  }