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    *               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.io.InputStream;
28  import java.io.OutputStream;
29  
30  import org.jumpmind.symmetric.service.IDataLoaderService;
31  
32  public class PushResourceHandler extends AbstractTransportResourceHandler {
33  
34      private IDataLoaderService dataLoaderService;
35  
36      public void push(InputStream inputStream, OutputStream outputStream) throws IOException {
37          getDataLoaderService().loadData(inputStream, outputStream);
38      }
39  
40      private IDataLoaderService getDataLoaderService() {
41          return dataLoaderService;
42      }
43  
44      public void setDataLoaderService(IDataLoaderService dataLoaderService) {
45          this.dataLoaderService = dataLoaderService;
46      }
47  
48  }