package producer

import (
	"context"
	"joybuywork/internal/service/queue/types"
)

type FissionBiReceiver struct {
	ctx   context.Context
	topic string
}

func NewFissionBiReceiver(ctx context.Context) FissionBiReceiver {
	return FissionBiReceiver{
		ctx:   ctx,
		topic: types.FissionBiReceiverTopic,
	}
}

func (p FissionBiReceiver) FissionAction(data types.FissionAction) {
	_ = AP.Produce(p.ctx, p.topic, types.FbrFissionActionKey, data)
}