Package com.zendesk.maxwell.producer

Class MaxwellPubsubProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.MaxwellPubsubProducer

public class MaxwellPubsubProducer
extends AbstractProducer

Field Summary

Fields

Modifier and Type	Field	Description
static org.slf4j.Logger	LOGGER

Fields inherited from class com.zendesk.maxwell.producer.AbstractProducer

context, failedMessageCount, failedMessageMeter, messageLatencySloViolationCount, messageLatencyTimer, messagePublishTimer, outputConfig, succeededMessageCount, succeededMessageMeter

Constructor Summary

Constructors

Constructor	Description
MaxwellPubsubProducer(MaxwellContext context, String pubsubProjectId, String pubsubTopic, String ddlPubsubTopic, String pubsubMessageOrderingKey, String pubsubEmulator)

Method Summary

Modifier and Type	Method	Description
StoppableTask	getStoppableTask()
void	push(RowMap r)

Methods inherited from class com.zendesk.maxwell.producer.AbstractProducer

getDiagnostic, getFailedMessageMeter

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

public static final org.slf4j.Logger LOGGER

Constructor Detail

MaxwellPubsubProducer

public MaxwellPubsubProducer(MaxwellContext context,
                             String pubsubProjectId,
                             String pubsubTopic,
                             String ddlPubsubTopic,
                             String pubsubMessageOrderingKey,
                             String pubsubEmulator)
                      throws IOException

Throws:

IOException

Method Detail

push

public void push(RowMap r)
          throws Exception

Specified by:

push in class AbstractProducer

Throws:

Exception

getStoppableTask

public StoppableTask getStoppableTask()

Overrides:

getStoppableTask in class AbstractProducer