mirror of
https://github.com/luxfi/czmq.git
synced 2026-10-30 16:59:02 +00:00
zeekay
66d1c4d404
- Updated module path to github.com/luxfi/czmq/v4 - All imports and dependencies updated for v4 compatibility - Tests passing with ZeroMQ libraries from Homebrew
75 lines
1.1 KiB
Go
75 lines
1.1 KiB
Go
package czmq
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
)
|
|
|
|
// TestBeacon tests sending a UDP beacon to a listener
|
|
func TestBeacon(t *testing.T) {
|
|
speaker := NewBeacon()
|
|
|
|
var err error
|
|
if testing.Verbose() {
|
|
err := speaker.Verbose()
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
}
|
|
|
|
_, err = speaker.Configure(9999)
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
|
|
listener := NewBeacon()
|
|
|
|
if testing.Verbose() {
|
|
err = listener.Verbose()
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
}
|
|
|
|
_, err = listener.Configure(9999)
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
|
|
err = listener.Subscribe("HI")
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
|
|
err = speaker.Publish("HI", 100)
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
|
|
msg := listener.Recv(500)
|
|
if len(msg) == 2 {
|
|
t.Logf("Address: %s", string(msg[0]))
|
|
t.Logf("Beacon: %s", string(msg[1]))
|
|
}
|
|
|
|
listener.Destroy()
|
|
speaker.Destroy()
|
|
}
|
|
|
|
func ExampleBeacon() {
|
|
beacon := NewBeacon()
|
|
defer beacon.Destroy()
|
|
|
|
address, err := beacon.Configure(9999)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
fmt.Printf("started beacon on: %s", address)
|
|
|
|
err = beacon.Publish("HI", 100)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|