Package com.zendesk.maxwell.producer

Class AbstractProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

Direct Known Subclasses:

AbstractAsyncProducer, AbstractProfilingProducer, BufferedProducer, FileProducer, MaxwellBigQueryProducer, MaxwellKafkaProducer, MaxwellPubsubProducer, MaxwellRedisProducer, NatsProducer, NoneProducer, RabbitmqProducer, StdoutProducer

public abstract class AbstractProducer
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected MaxwellContext	context
protected com.codahale.metrics.Counter	failedMessageCount
protected com.codahale.metrics.Meter	failedMessageMeter
protected com.codahale.metrics.Counter	messageLatencySloViolationCount
protected com.codahale.metrics.Timer	messageLatencyTimer
protected com.codahale.metrics.Timer	messagePublishTimer
protected MaxwellOutputConfig	outputConfig
protected com.codahale.metrics.Counter	succeededMessageCount
protected com.codahale.metrics.Meter	succeededMessageMeter

Constructor Summary

Constructors

Constructor	Description
AbstractProducer(MaxwellContext context)

Method Summary

Modifier and Type	Method	Description
MaxwellDiagnostic	getDiagnostic()
com.codahale.metrics.Meter	getFailedMessageMeter()
StoppableTask	getStoppableTask()
abstract void	push(RowMap r)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

context

protected final MaxwellContext context

outputConfig

protected final MaxwellOutputConfig outputConfig

succeededMessageCount

protected final com.codahale.metrics.Counter succeededMessageCount

succeededMessageMeter

protected final com.codahale.metrics.Meter succeededMessageMeter

failedMessageCount

protected final com.codahale.metrics.Counter failedMessageCount

failedMessageMeter

protected final com.codahale.metrics.Meter failedMessageMeter

messagePublishTimer

protected final com.codahale.metrics.Timer messagePublishTimer

messageLatencyTimer

protected final com.codahale.metrics.Timer messageLatencyTimer

messageLatencySloViolationCount

protected final com.codahale.metrics.Counter messageLatencySloViolationCount

Constructor Detail

AbstractProducer

public AbstractProducer(MaxwellContext context)

Method Detail

push

public abstract void push(RowMap r)
                   throws Exception

Throws:

Exception

getStoppableTask

public StoppableTask getStoppableTask()

getFailedMessageMeter

public com.codahale.metrics.Meter getFailedMessageMeter()

getDiagnostic

public MaxwellDiagnostic getDiagnostic()