example

package main

import (
	"context"

	plugin "github.com/LeKovr/mqbridge/plugins/example"
	"github.com/LeKovr/mqbridge/types"
)

func main() {
	ctx, cancel := context.WithCancel(context.Background())
	epa := types.NewBlankEndPointAttr(ctx)
	plug, _ := plugin.New(epa, "test")
	pipe := make(chan string)
	plug.Listen(0, "1:100", pipe)
	plug.Notify(0, "", pipe)
	<-epa.Abort
	cancel()
	epa.WG.Wait()
}

Output:

sample 0