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 and Description
CachingPublisherFactory(PublisherFactory delegate) Constructs a caching PublisherFactory using the delegate.

Method Summary

Modifier and Type	Method and Description
Publisher	createPublisher(String topic) Creates a Publisher for a given topic.
PublisherFactory	getDelegate() Returns the delegate.

Methods inherited from class java.lang.Object

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

Constructor Detail

CachingPublisherFactory

public CachingPublisherFactory(PublisherFactory delegate)

Constructs a caching PublisherFactory using the delegate.

Parameters:

delegate - a PublisherFactory that needs to be cachecd.

Method Detail

createPublisher

public 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.