MCPcopy
hub / github.com/IBM/sarama / IsTransactional

Method IsTransactional

mocks/sync_producer.go:227–229  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

225}
226
227func (sp *SyncProducer) IsTransactional() bool {
228 return sp.isTransactional
229}
230
231func (sp *SyncProducer) BeginTxn() error {
232 sp.txnLock.Lock()

Callers 2

TestSyncProducerUseTxnFunction · 0.95
SendMessageMethod · 0.95

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 1

TestSyncProducerUseTxnFunction · 0.76