io.jenkins.plugins.aws.kinesisconsumer

Class KinesisConsumerManager

java.lang.Object

hudson.model.listeners.ItemListener

io.jenkins.plugins.aws.kinesisconsumer.KinesisConsumerManager

All Implemented Interfaces:

ExtensionPoint

@Extension
public class KinesisConsumerManager
extends ItemListener

Manager of stream connections

Author:

Antonio Barone

Nested Class Summary

Nested classes/interfaces inherited from interface hudson.ExtensionPoint

ExtensionPoint.LegacyInstancesAreScopedToHudson

Constructor Summary

Constructors

Constructor and Description
KinesisConsumerManager()
KinesisConsumerManager(GlobalKinesisConfiguration configuration, KinesisConsumer.Factory kinesisConsumerFactory)

Method Summary

Modifier and Type	Method and Description
static KinesisConsumerManager	get() Gets this extension's instance.
void	onBeforeShutdown()
void	onLoaded()
void	restartAllConsumers(GlobalKinesisConfiguration configuration)
void	shutDownAllConsumers()
void	startAllConsumers(GlobalKinesisConfiguration configuration)

Methods inherited from class hudson.model.listeners.ItemListener

all, checkBeforeCopy, fireLocationChange, fireOnCopied, fireOnCreated, fireOnDeleted, fireOnUpdated, onCheckCopy, onCopied, onCreated, onDeleted, onLocationChanged, onRenamed, onUpdated, register

Methods inherited from class java.lang.Object

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

Constructor Detail

KinesisConsumerManager

@Inject
public KinesisConsumerManager(GlobalKinesisConfiguration configuration,
                                      KinesisConsumer.Factory kinesisConsumerFactory)

KinesisConsumerManager

public KinesisConsumerManager()

Method Detail

onLoaded

public final void onLoaded()

Overrides:

onLoaded in class ItemListener

onBeforeShutdown

public final void onBeforeShutdown()

Overrides:

onBeforeShutdown in class ItemListener

get

public static KinesisConsumerManager get()

Gets this extension's instance.

Returns:

the instance of this extension.

startAllConsumers

public void startAllConsumers(GlobalKinesisConfiguration configuration)

shutDownAllConsumers

public void shutDownAllConsumers()

restartAllConsumers

public void restartAllConsumers(GlobalKinesisConfiguration configuration)