Compare commits
2 Commits
Author | SHA1 | Date |
---|---|---|
|
129094ac4f | |
|
ce5a66cfd6 |
|
@ -1,3 +1,5 @@
|
|||
build
|
||||
__pycache__
|
||||
.idea
|
||||
sensenet
|
||||
sensenet.yaml
|
||||
|
|
2
go.mod
2
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
|
||||
|
|
|
@ -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) {
|
||||
|
|
|
@ -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) {
|
||||
|
|
Loading…
Reference in New Issue