diff --git a/geomagio/edge/EdgeFactory.py b/geomagio/edge/EdgeFactory.py
index 3c1d72db155345a85ab3bd49ce989e3200f74b5a..af00ee0612e2528d6c1332f77744e52dbf223b18 100644
--- a/geomagio/edge/EdgeFactory.py
+++ b/geomagio/edge/EdgeFactory.py
@@ -65,8 +65,8 @@ class EdgeFactory(TimeseriesFactory):
         for reading.
     """
 
-    def __init__(self, host=None, port=None, observatory=None,
-            channels=None, type=None, interval=None,
+    def __init__(self, host=None, port=None, write_port=None,
+            observatory=None, channels=None, type=None, interval=None,
             observatoryMetadata=None, locationCode=None,
             cwbhost=None, cwbport=0, tag='GeomagAlg'):
         TimeseriesFactory.__init__(self, observatory, channels, type, interval)
@@ -78,6 +78,7 @@ class EdgeFactory(TimeseriesFactory):
         self.interval = interval
         self.host = host
         self.port = port
+        self.write_port = write_port
         self.cwbhost = cwbhost or ''
         self.cwbport = cwbport
 
@@ -595,7 +596,7 @@ class EdgeFactory(TimeseriesFactory):
             port = self.cwbport
         else:
             host = self.host
-            port = self.port
+            port = self.write_port
 
         ric = RawInputClient(self.tag, host, port, station,
                 edge_channel, location, network)