com.yahoo.bullet.rest

Class PubSubConfiguration

java.lang.Object

com.yahoo.bullet.rest.PubSubConfiguration

@Configuration
public class PubSubConfiguration
extends Object

Constructor Summary

Constructors

Constructor and Description
PubSubConfiguration()

Method Summary

Modifier and Type	Method and Description
List<com.yahoo.bullet.pubsub.Publisher>	publishers(com.yahoo.bullet.pubsub.PubSub pubSub, int publishers) Creates the specified number of Publisher instances from the given PubSub.
com.yahoo.bullet.pubsub.PubSub	pubSub(com.yahoo.bullet.common.BulletConfig pubSubConfig) Creates a PubSub instance from a provided config.
com.yahoo.bullet.common.BulletConfig	pubSubConfig(String config) Creates a BulletConfig from a file path.
com.yahoo.bullet.pubsub.PubSubMessageSerDe	pubSubMessageSendSerDe(com.yahoo.bullet.common.BulletConfig pubSubConfig) Creates a PubSubMessageSerDe from a given BulletConfig to use for sending messages to the PubSub.
QueryService	queryService(com.yahoo.bullet.storage.StorageManager<com.yahoo.bullet.pubsub.PubSubMessage> queryStorageManager, HandlerService handlerService, AsyncConfiguration.ResponderClasses responderClasses, List<com.yahoo.bullet.pubsub.Publisher> publishers, List<com.yahoo.bullet.pubsub.Subscriber> subscribers, com.yahoo.bullet.pubsub.PubSubMessageSerDe pubSubMessageSendSerDe, int sleep) Creates a QueryService instance from various necessary components.
AsyncConfiguration.ResponderClasses	responderClasses()
List<com.yahoo.bullet.pubsub.Subscriber>	subscribers(com.yahoo.bullet.pubsub.PubSub pubSub, int subscribers) Creates the specified number of Subscriber instances from the given PubSub.

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubConfiguration

public PubSubConfiguration()

Method Detail

responderClasses

@Bean
 @ConditionalOnMissingBean
public AsyncConfiguration.ResponderClasses responderClasses()

queryService

@Bean
public QueryService queryService(com.yahoo.bullet.storage.StorageManager<com.yahoo.bullet.pubsub.PubSubMessage> queryStorageManager,
                                       HandlerService handlerService,
                                       AsyncConfiguration.ResponderClasses responderClasses,
                                       List<com.yahoo.bullet.pubsub.Publisher> publishers,
                                       List<com.yahoo.bullet.pubsub.Subscriber> subscribers,
                                       com.yahoo.bullet.pubsub.PubSubMessageSerDe pubSubMessageSendSerDe,
                                       @Value(value="${bullet.pubsub.sleep-ms}")
                                       int sleep)

Creates a QueryService instance from various necessary components.

Parameters:

queryStorageManager - The non-null StorageManager to use.

handlerService - The HandlerService to use.

responderClasses - The responders to use for asynchronous queries. May be empty.

publishers - The non-empty List of Publisher to use.

subscribers - The non-empty List of Subscriber to use.

pubSubMessageSendSerDe - The PubSubMessageSerDe to use.

sleep - The time to sleep between checking for messages from the pubsub.

Returns:

The created QueryService instance.

pubSubConfig

@Bean
public com.yahoo.bullet.common.BulletConfig pubSubConfig(@Value(value="${bullet.pubsub.config}")
                                                               String config)

Creates a BulletConfig from a file path.

Parameters:

config - The path to the settings file.

Returns:

A BulletConfig.

pubSub

@Bean
public com.yahoo.bullet.pubsub.PubSub pubSub(com.yahoo.bullet.common.BulletConfig pubSubConfig)
                                            throws com.yahoo.bullet.pubsub.PubSubException

Creates a PubSub instance from a provided config.

Parameters:

pubSubConfig - The BulletConfig containing settings for configuring the PubSub.

Returns:

An instance of the particular PubSub indicated in the config.

Throws:

com.yahoo.bullet.pubsub.PubSubException - if there were issues creating the PubSub instance.

publishers

@Bean
public List<com.yahoo.bullet.pubsub.Publisher> publishers(com.yahoo.bullet.pubsub.PubSub pubSub,
                                                                @Value(value="${bullet.pubsub.publishers}")
                                                                int publishers)
                                                         throws com.yahoo.bullet.pubsub.PubSubException

Creates the specified number of Publisher instances from the given PubSub.

Parameters:

pubSub - The PubSub providing the instances.

publishers - The number of publishers to create using PubSub.getPublishers(int).

Returns:

A List of Publisher provided by the PubSub instance.

Throws:

com.yahoo.bullet.pubsub.PubSubException - if there were issues creating the instances.

subscribers

@Bean
public List<com.yahoo.bullet.pubsub.Subscriber> subscribers(com.yahoo.bullet.pubsub.PubSub pubSub,
                                                                  @Value(value="${bullet.pubsub.subscribers}")
                                                                  int subscribers)
                                                           throws com.yahoo.bullet.pubsub.PubSubException

Creates the specified number of Subscriber instances from the given PubSub.

Parameters:

pubSub - The PubSub providing the instances.

subscribers - The number of subscribers to create using PubSub.getSubscribers(int).

Returns:

A List of Subscriber provided by the PubSub instance.

Throws:

com.yahoo.bullet.pubsub.PubSubException - if there were issues creating the instances.

pubSubMessageSendSerDe

@Bean
public com.yahoo.bullet.pubsub.PubSubMessageSerDe pubSubMessageSendSerDe(com.yahoo.bullet.common.BulletConfig pubSubConfig)

Creates a PubSubMessageSerDe from a given BulletConfig to use for sending messages to the PubSub.

Parameters:

pubSubConfig - The BulletConfig containing relevant settings for the PubSubMessageSerDe.

Returns:

A created PubSubMessageSerDe.