io.druid.segment.realtime.firehose

Class ServiceAnnouncingChatHandlerProvider

java.lang.Object

io.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider

All Implemented Interfaces:

ChatHandlerProvider

public class ServiceAnnouncingChatHandlerProvider
extends Object
implements ChatHandlerProvider

Provides a way for the outside world to talk to objects in the indexing service. The get(String) method allows anyone with a reference to this object to obtain a particular ChatHandler. An embedded ServiceAnnouncer will be used to advertise handlers on this host.

Constructor Summary

Constructors

Constructor and Description
ServiceAnnouncingChatHandlerProvider(DruidNode node, ServiceAnnouncer serviceAnnouncer)

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.base.Optional<ChatHandler>	get(String key)
void	register(String service, ChatHandler handler)
void	unregister(String service)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceAnnouncingChatHandlerProvider

@Inject
public ServiceAnnouncingChatHandlerProvider(DruidNode node,
                                           ServiceAnnouncer serviceAnnouncer)

Method Detail

register

public void register(String service,
            ChatHandler handler)

Specified by:

register in interface ChatHandlerProvider

unregister

public void unregister(String service)

Specified by:

unregister in interface ChatHandlerProvider

get

public com.google.common.base.Optional<ChatHandler> get(String key)

Specified by:

get in interface ChatHandlerProvider