diff --git a/go.mod b/go.mod
index 8f41735..be8636a 100644
--- a/go.mod
+++ b/go.mod
@@ -1,6 +1,6 @@
 module git.wntrmute.dev/kyle/sensenet
 
-go 1.17
+go 1.19
 
 require (
 	github.com/Masterminds/squirrel v1.5.2
diff --git a/pubsub/publisher.go b/pubsub/publisher.go
index a0d71e1..163255b 100644
--- a/pubsub/publisher.go
+++ b/pubsub/publisher.go
@@ -30,7 +30,7 @@ func NewPublisher(addr string) (*Publisher, error) {
 }
 
 func (pub *Publisher) connect() error {
-	return pub.sock.Dial(pub.addr)
+	return pub.sock.Listen(pub.addr)
 }
 
 func (pub *Publisher) Conflate(n int) {
diff --git a/pubsub/subscriber.go b/pubsub/subscriber.go
index b4cc36b..9e89b1a 100644
--- a/pubsub/subscriber.go
+++ b/pubsub/subscriber.go
@@ -55,7 +55,7 @@ func (sub *Subscriber) Conflate(n int) {
 
 func (sub *Subscriber) connect() error {
 	log.Printf("subscriber dialing %s", sub.addr)
-	return sub.sock.Listen(sub.addr)
+	return sub.sock.Dial(sub.addr)
 }
 
 func (sub *Subscriber) Subscribe(topic string) {