Compare commits

...

2 Commits

Author SHA1 Message Date
Kyle Isom 129094ac4f ignore build products, config file 2023-05-13 18:49:48 -07:00
Kyle Isom ce5a66cfd6 updating pubsub, go version 2023-05-13 18:49:14 -07:00
4 changed files with 5 additions and 3 deletions

2
.gitignore vendored
View File

@ -1,3 +1,5 @@
build build
__pycache__ __pycache__
.idea .idea
sensenet
sensenet.yaml

2
go.mod
View File

@ -1,6 +1,6 @@
module git.wntrmute.dev/kyle/sensenet module git.wntrmute.dev/kyle/sensenet
go 1.17 go 1.19
require ( require (
github.com/Masterminds/squirrel v1.5.2 github.com/Masterminds/squirrel v1.5.2

View File

@ -30,7 +30,7 @@ func NewPublisher(addr string) (*Publisher, error) {
} }
func (pub *Publisher) connect() error { func (pub *Publisher) connect() error {
return pub.sock.Dial(pub.addr) return pub.sock.Listen(pub.addr)
} }
func (pub *Publisher) Conflate(n int) { func (pub *Publisher) Conflate(n int) {

View File

@ -55,7 +55,7 @@ func (sub *Subscriber) Conflate(n int) {
func (sub *Subscriber) connect() error { func (sub *Subscriber) connect() error {
log.Printf("subscriber dialing %s", sub.addr) 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) { func (sub *Subscriber) Subscribe(topic string) {