You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
23 lines
445 B
Go
23 lines
445 B
Go
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)
|
|
}
|