Package com.google.cloud.spring.pubsub.support

Class CachingPublisherFactory

java.lang.Object

com.google.cloud.spring.pubsub.support.CachingPublisherFactory

All Implemented Interfaces:

PublisherFactory

public class CachingPublisherFactory
extends Object
implements PublisherFactory

The caching implementation of the PublisherFactory.

Creates Publishers for topics once using delegate, caches and reuses them.

Constructor Summary

Constructors

Constructor	Description
CachingPublisherFactory(PublisherFactory delegate)	Constructs a caching PublisherFactory using the delegate.

Method Summary

Modifier and Type	Method	Description
com.google.cloud.pubsub.v1.Publisher	createPublisher(String topic)	Creates a Publisher for a given topic.
PublisherFactory	getDelegate()	Returns the delegate.
void	shutdown()	Shutdown all cached Publisher gracefully.

Methods inherited from class java.lang.Object

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

Constructor Details

CachingPublisherFactory

public CachingPublisherFactory(PublisherFactory delegate)

Constructs a caching PublisherFactory using the delegate.

Parameters:

delegate - a PublisherFactory that needs to be cached.

Method Details

createPublisher

public com.google.cloud.pubsub.v1.Publisher createPublisher(String topic)

Description copied from interface: PublisherFactory

Creates a Publisher for a given topic.

Specified by:

createPublisher in interface PublisherFactory

Parameters:

topic - destination topic

Returns:

fully configured publisher

getDelegate

public PublisherFactory getDelegate()

Returns the delegate.

Returns:

the delegate.

shutdown

@PreDestroy
public void shutdown()

Shutdown all cached Publisher gracefully.