--- a/flys-aft/src/main/java/de/intevation/aft/Rivers.java	Fri Dec 16 11:26:12 2011 +0000
+++ b/flys-aft/src/main/java/de/intevation/aft/Rivers.java	Fri Dec 16 16:21:59 2011 +0000
@@ -20,14 +20,13 @@
     public Rivers() {
     }
 
-    public void sync(
-        ConnectedStatements aftStatements,
-        ConnectedStatements flysStatements
-    )
-    throws SQLException
-    {
+    public void sync(SyncContext context) throws SQLException {
+
         log.info("sync: rivers");
 
+        ConnectedStatements flysStatements = context.getFlysStatements();
+        ConnectedStatements aftStatements  = context.getAftStatements();
+
         Map<String, Integer> flysRivers = new HashMap<String, Integer>();
 
         ResultSet flysRs = flysStatements
@@ -60,7 +59,7 @@
         aftRs.close();
 
         for (River river: commonRivers) {
-            river.sync(aftStatements, flysStatements);
+            river.sync(context);
         }
     }
 }