Package com.zendesk.maxwell.producer

Class MaxwellRedisProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.MaxwellRedisProducer

All Implemented Interfaces:

StoppableTask

public class MaxwellRedisProducer
extends AbstractProducer
implements StoppableTask

Field Summary

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

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

Constructor Summary

Constructors

Constructor	Description
MaxwellRedisProducer(MaxwellContext context)
MaxwellRedisProducer(MaxwellContext context, String redisPubChannel, String redisListKey, String redisType)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	awaitStop(Long timeout)
StoppableTask	getStoppableTask()
void	push(RowMap r)
void	requestStop()

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

Constructor Detail

MaxwellRedisProducer

@Deprecated
public MaxwellRedisProducer(MaxwellContext context,
                            String redisPubChannel,
                            String redisListKey,
                            String redisType)

Deprecated.

MaxwellRedisProducer

public MaxwellRedisProducer(MaxwellContext context)

Method Detail

push

public void push(RowMap r)
          throws Exception

Specified by:

push in class AbstractProducer

Throws:

Exception

requestStop

public void requestStop()

Specified by:

requestStop in interface StoppableTask

awaitStop

public void awaitStop(Long timeout)

Specified by:

awaitStop in interface StoppableTask

getStoppableTask

public StoppableTask getStoppableTask()

Overrides:

getStoppableTask in class AbstractProducer