MCPcopy Create free account
hub / github.com/33cn/chain33 / Notify

Method Notify

client/queueprotocolapi.go:17–17  ·  view source on GitHub ↗
(topic string, ty int64, data interface{})

Source from the content-addressed store, hash-verified

15 Close()
16 NewMessage(topic string, msgid int64, data interface{}) *queue.Message
17 Notify(topic string, ty int64, data interface{}) (*queue.Message, error)
18 // +++++++++++++++ mempool interfaces begin
19 // 同步发送交易信息到指定模块,获取应答消息 types.EventTx
20 SendTx(param *types.Transaction) (*types.Reply, error)

Callers 5

TestQueueProtocolAPIFunction · 0.65
StartMethod · 0.65
dispatchSyncMsgMethod · 0.65
NewHeadsMethod · 0.65
LogsMethod · 0.65

Implementers 2

QueueProtocolclient/queueprotocol.go
QueueProtocolAPIclient/mocks/api.go

Calls

no outgoing calls

Tested by 1

TestQueueProtocolAPIFunction · 0.52