net.bluemind.forest.cloud.service

Class ForestJoinService

java.lang.Object

net.bluemind.forest.cloud.service.ForestJoinService

All Implemented Interfaces:

IForestJoin

public class ForestJoinService
extends java.lang.Object
implements IForestJoin

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ForestJoinService.FJoinServiceFactory

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.UUID	JVM_ID
static java.lang.String	ORIGIN
static IKafkaBroker	storageLayer

Constructor Summary

Constructors

Constructor and Description
ForestJoinService(BmContext context, org.apache.kafka.clients.producer.KafkaProducer<java.lang.String,java.lang.String> kafkaProducer, com.hazelcast.core.HazelcastInstance hz, java.lang.String sharedAlias)

Method Summary

Modifier and Type	Method and Description
ForestTopology	handshake(Instance inst) Register the given instance if necessary.
static void	init()
static void	withAdminClient(java.util.function.BiConsumer<org.apache.kafka.clients.admin.AdminClient,IKafkaBroker> needsAdmin)

Methods inherited from class java.lang.Object

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

Field Detail

storageLayer

public static final IKafkaBroker storageLayer

JVM_ID

public static final java.util.UUID JVM_ID

ORIGIN

public static final java.lang.String ORIGIN

Constructor Detail

ForestJoinService

public ForestJoinService(BmContext context,
                         org.apache.kafka.clients.producer.KafkaProducer<java.lang.String,java.lang.String> kafkaProducer,
                         com.hazelcast.core.HazelcastInstance hz,
                         java.lang.String sharedAlias)

Method Detail

init

public static void init()

withAdminClient

public static void withAdminClient(java.util.function.BiConsumer<org.apache.kafka.clients.admin.AdminClient,IKafkaBroker> needsAdmin)

handshake

public ForestTopology handshake(Instance inst)

Description copied from interface: IForestJoin

Register the given instance if necessary. The forest server returns one usable kafka broker for the instance.

Specified by:

handshake in interface IForestJoin

Returns: