package logging

import (
	"gitee.com/bambuo/lock"
	"github.com/google/uuid"
)

// 作者:  chenchong
// 时间:  2021/7/15 上午10:44
// 版本:  1.0

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//生产者
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

type DefaultProductionObserver struct {
	lock.RecursiveMutex
	topic    string
	observer Consumer
}

// NewDefaultProductionObserver 创建生产者
func NewDefaultProductionObserver(topic string, observer ProductionConsumptionObserver) Producer {
	producer := &DefaultProductionObserver{
		topic:    topic,
		observer: observer,
	}
	_ = observer.Registration(topic, uuid.NewString(), producer)
	return producer
}

// Production 生产
func (dp *DefaultProductionObserver) Production(data ...interface{}) {
	dp.Lock()
	defer dp.Unlock()

	dp.observer.Consumption(dp.topic, data...)
}