package tieventbus

import (
	"github.com/ThreeDotsLabs/watermill/message"
	"github.com/tidbcloud/tiinf/transport/tieventbus/log"
)

var logger = &log.PingCAPLoggerWatermillAdapter{}

type disabledPublisher struct{}

func (disabledPublisher) Publish(topic string, messages ...*message.Message) error {
	return message.ErrOutputInNoPublisherHandler
}

func (disabledPublisher) Close() error {
	return nil
}

func newRouter() (*message.Router, error) {
	router, err := message.NewRouter(message.RouterConfig{}, &log.PingCAPLoggerWatermillAdapter{})
	if err != nil {
		return nil, err
	}
	return router, nil
}