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
PublisherInterface	createPublisher(String 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 PublisherInterface createPublisher(String topic)

Specified by:

createPublisher in interface PublisherFactory

getDelegate

public PublisherFactory getDelegate()

Returns the delegate.

Returns:

the delgate.