services.moleculer.transporter

Class KafkaTransporter.KafkaPoller

java.lang.Object

services.moleculer.transporter.KafkaTransporter.KafkaPoller

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

KafkaTransporter

protected static class KafkaTransporter.KafkaPoller
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]>	consumer
protected static boolean	firstError
protected java.util.concurrent.atomic.AtomicInteger	status
protected static int	STOPPING
protected static int	SUBSCRIBED
protected java.util.HashSet<java.lang.String>	subscriptions
protected KafkaTransporter	transporter
protected static int	UNSUBSCRIBED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	KafkaPoller(KafkaTransporter transporter)

Method Summary

Modifier and Type	Method and Description
void	run()
protected void	stop()
protected void	subscribe(java.lang.String channel)

Methods inherited from class java.lang.Object

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

Field Detail

UNSUBSCRIBED

protected static final int UNSUBSCRIBED

See Also:

Constant Field Values

SUBSCRIBED

protected static final int SUBSCRIBED

See Also:

Constant Field Values

STOPPING

protected static final int STOPPING

See Also:

Constant Field Values

consumer

protected org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> consumer

transporter

protected final KafkaTransporter transporter

status

protected final java.util.concurrent.atomic.AtomicInteger status

firstError

protected static boolean firstError

subscriptions

protected java.util.HashSet<java.lang.String> subscriptions

Constructor Detail

KafkaPoller

protected KafkaPoller(KafkaTransporter transporter)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

subscribe

protected void subscribe(java.lang.String channel)

stop

protected void stop()