MCPcopy
hub / github.com/apache/answer / Send

Method Send

internal/base/queue/queue.go:31–31  ·  view source on GitHub ↗

Send enqueues a message to be processed asynchronously.

(ctx context.Context, msg T)

Source from the content-addressed store, hash-verified

29type Service[T any] interface {
30 // Send enqueues a message to be processed asynchronously.
31 Send(ctx context.Context, msg T)
32
33 // RegisterHandler sets the handler function for processing messages.
34 RegisterHandler(handler func(ctx context.Context, msg T) error)

Callers 15

QuestionInfoMethod · 0.65
CloseQuestionMethod · 0.65
UpdateSMTPConfigMethod · 0.65
AddTagMethod · 0.65
ObjectChangeTagMethod · 0.65
UpdateTagMethod · 0.65
SendNotificationToAllFollowerMethod · 0.65
AddCommentMethod · 0.65
RemoveCommentMethod · 0.65
UpdateCommentMethod · 0.65
notificationQuestionCommentMethod · 0.65
notificationAnswerCommentMethod · 0.65

Calls

no outgoing calls

Tested by 7

TestQueue_SendAndReceiveFunction · 0.52
TestQueue_MultipleMessagesFunction · 0.52
TestQueue_NoHandlerDropsMessageFunction · 0.52
TestQueue_RegisterHandlerAfterSendFunction · 0.52
TestQueue_CloseFunction · 0.52
TestQueue_ConcurrentSendFunction · 0.52
TestQueue_SendCloseRaceFunction · 0.52