public class LocalConsumer extends Object implements EventConsumer
Constructor and Description |
---|
LocalConsumer(EnvConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
initConsumer(ConsumerHandler consumerHandler) |
void |
poll() |
void |
stop() |
void |
updateStatus(State state) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get
public LocalConsumer(EnvConfig config)
public void initConsumer(ConsumerHandler consumerHandler)
initConsumer
in interface EventConsumer
public void poll()
poll
in interface EventConsumer
public void stop()
stop
in interface EventConsumer
public void updateStatus(State state)
updateStatus
in interface LeadershipCallback
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.