diff --git a/geomagio/Controller.py b/geomagio/Controller.py index 7111ef576923149835b1d7146fad99ef34f0cb38..3305ecb683635b1e426134f3fbb518825ee2350d 100644 --- a/geomagio/Controller.py +++ b/geomagio/Controller.py @@ -424,7 +424,7 @@ def get_output_factory(args): elif output_type == "miniseed": # TODO: deal with other miniseed arguments locationcode = args.outlocationcode or args.locationcode or None - output_factory = edge.EdgeFactory( + output_factory = edge.MiniSeedFactory( host=args.output_host, port=args.output_read_port, write_port=args.output_port, diff --git a/geomagio/edge/MiniSeedInputClient.py b/geomagio/edge/MiniSeedInputClient.py index 906c37e32e2e4bd821c4696234c2dbce87b31394..0e6a20728718ab4adc9f2e653125fa3b66c99fdc 100644 --- a/geomagio/edge/MiniSeedInputClient.py +++ b/geomagio/edge/MiniSeedInputClient.py @@ -48,7 +48,7 @@ class MiniSeedInputClient(object): attempts += 1 try: s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) - s.connect(self.host, self.port) + s.connect((self.host, self.port)) break except socket.error as e: if attempts >= max_attempts: @@ -73,4 +73,4 @@ class MiniSeedInputClient(object): buf = io.BytesIO() stream.write(buf, format="MSEED") # send data - self.socket.sendall(buf) + self.socket.sendall(buf.read())