com.yahoo.bullet.pubsub

Class PubSubResponder

java.lang.Object

com.yahoo.bullet.pubsub.PubSubResponder

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

BulletPubSubResponder

public abstract class PubSubResponder
extends Object
implements AutoCloseable

This can be extended by any class that needs to respond to a PubSubMessage.

Field Summary

Fields

Modifier and Type	Field and Description
protected BulletConfig	config

Constructor Summary

Constructors

Constructor and Description
PubSubResponder(BulletConfig config) Constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
abstract void	respond(String id, PubSubMessage message) Respond to a PubSubMessage.

Methods inherited from class java.lang.Object

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

Field Detail

config

protected BulletConfig config

Constructor Detail

PubSubResponder

public PubSubResponder(BulletConfig config)

Constructor.

Parameters:

config - The BulletConfig to use.

Method Detail

respond

public abstract void respond(String id,
                             PubSubMessage message)

Respond to a PubSubMessage.

Parameters:

id - The id of the response.

message - The actual PubSubMessage containing the response.

close

public void close()

Specified by:

close in interface AutoCloseable