Package org.smallmind.bayeux.oumuamua.server.spi.backbone.kafka

Class KafkaBackbone<V extends Value<V>>

java.lang.Object

org.smallmind.bayeux.oumuamua.server.spi.backbone.kafka.KafkaBackbone<V>

All Implemented Interfaces:

Backbone<V>

public class KafkaBackbone<V extends Value<V>>
extends Object
implements Backbone<V>

Constructor Summary

Constructors

Constructor	Description
KafkaBackbone(String nodeName, int concurrencyLimit, int startupGracePeriodSeconds, String topicName, KafkaServer... servers)

Method Summary

Modifier and Type	Method	Description
void	publish(Packet<V> packet)
void	shutDown()
void	startUp(Server<V> server)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaBackbone

public KafkaBackbone(String nodeName,
 int concurrencyLimit,
 int startupGracePeriodSeconds,
 String topicName,
 KafkaServer... servers)
              throws OumuamuaException

Throws:

OumuamuaException

Method Details

startUp

public void startUp(Server<V> server)
             throws Exception

Specified by:

startUp in interface Backbone<V extends Value<V>>

Throws:

Exception

shutDown

public void shutDown()
              throws InterruptedException

Specified by:

shutDown in interface Backbone<V extends Value<V>>

Throws:

InterruptedException

publish

public void publish(Packet<V> packet)

Specified by:

publish in interface Backbone<V extends Value<V>>