Package org.jenkinsci.plugins.pubsub

Class GuavaPubsubBus

java.lang.Object

org.jenkinsci.plugins.pubsub.PubsubBus

org.jenkinsci.plugins.pubsub.GuavaPubsubBus

All Implemented Interfaces:

ExtensionPoint

public final class GuavaPubsubBus
extends PubsubBus

Default PubsubBus implementation.

An in-memory implementation based on Google's Guava EventBus.

Use system property org.jenkins.pubsub.GuavaPubsubBus.MAX_THREADS to configure the thread pool size used by the bus. The default value is 5 threads (falling back to 0 when idle).

Author:

tom.fennelly@gmail.com

Nested Class Summary

Nested classes/interfaces inherited from interface hudson.ExtensionPoint

ExtensionPoint.LegacyInstancesAreScopedToHudson

Constructor Summary

Constructors

Constructor	Description
GuavaPubsubBus()

Method Summary

Modifier and Type	Method	Description
protected ChannelPublisher	publisher(String channelName)	Get/create a new ChannelPublisher instance for the specified channel name.
void	shutdown()	Shutdown the bus.
void	start()	will start the bus if it has been shutdown do not restart if already started
void	subscribe2(String channelName, ChannelSubscriber subscriber, org.springframework.security.core.Authentication authentication, EventFilter eventFilter)	Subscribe to events on the specified event channel.
void	unsubscribe(String channelName, ChannelSubscriber subscriber)	Unsubscribe from events on the specified event channel.

Methods inherited from class org.jenkinsci.plugins.pubsub.PubsubBus

getBus, publish, subscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

GuavaPubsubBus

public GuavaPubsubBus()

Method Detail

publisher

@NonNull
protected ChannelPublisher publisher(@NonNull
                                     String channelName)

Description copied from class: PubsubBus

Get/create a new ChannelPublisher instance for the specified channel name.

Specified by:

publisher in class PubsubBus

Parameters:

channelName - The channel name.

Returns:

The ChannelPublisher instance.

subscribe2

public void subscribe2(@NonNull
                       String channelName,
                       @NonNull
                       ChannelSubscriber subscriber,
                       @NonNull
                       org.springframework.security.core.Authentication authentication,
                       @CheckForNull
                       EventFilter eventFilter)

Description copied from class: PubsubBus

Subscribe to events on the specified event channel.

Overrides:

subscribe2 in class PubsubBus

Parameters:

channelName - The channel name.

subscriber - The subscriber instance that will receive the events.

authentication - The authentication to which the subscription is associated.

eventFilter - A message filter, or null if no filtering is to be applied. This tells the bus to only forward messages that match the properties (names and values) specified in the filter.

unsubscribe

public void unsubscribe(@NonNull
                        String channelName,
                        @NonNull
                        ChannelSubscriber subscriber)

Description copied from class: PubsubBus

Unsubscribe from events on the specified event channel.

Specified by:

unsubscribe in class PubsubBus

Parameters:

channelName - The channel name.

subscriber - The subscriber instance that was used to receive events.

start

public void start()

Description copied from class: PubsubBus

will start the bus if it has been shutdown do not restart if already started

Overrides:

start in class PubsubBus

shutdown

public void shutdown()

Description copied from class: PubsubBus

Shutdown the bus.

Specified by:

shutdown in class PubsubBus