updating pubsub, go version

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

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) {

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) {