com.google.cloud.spring.autoconfigure.pubsub

Class GcpPubSubEmulatorAutoConfiguration

java.lang.Object

com.google.cloud.spring.autoconfigure.pubsub.GcpPubSubEmulatorAutoConfiguration

@Configuration(proxyBeanMethods=false)
 @ConditionalOnClass(value={io.grpc.ManagedChannel.class,PubSubTemplate.class})
 @ConditionalOnProperty(prefix="spring.cloud.gcp.pubsub",
                       name="enabled",
                       matchIfMissing=true)
 @AutoConfigureBefore(value=GcpPubSubAutoConfiguration.class)
 @EnableConfigurationProperties(value=GcpPubSubProperties.class)
public class GcpPubSubEmulatorAutoConfiguration
extends Object

If spring.cloud.gcp.pubsub.emulator-host is set, spring stream will connect to a running pub/sub emulator.

Author:

Andreas Berger, Mike Eltsufin

Constructor Summary

Constructors

Constructor and Description
GcpPubSubEmulatorAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
void	closeManagedChannel()
com.google.api.gax.rpc.TransportChannelProvider	transportChannelProvider(GcpPubSubProperties gcpPubSubProperties)

Methods inherited from class java.lang.Object

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

Constructor Detail

GcpPubSubEmulatorAutoConfiguration

public GcpPubSubEmulatorAutoConfiguration()

Method Detail

transportChannelProvider

@Bean(name={"subscriberTransportChannelProvider","publisherTransportChannelProvider"})
 @ConditionalOnMissingBean(name={"subscriberTransportChannelProvider","publisherTransportChannelProvider"})
 @ConditionalOnProperty(prefix="spring.cloud.gcp.pubsub",
                       name="emulator-host")
public com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider(GcpPubSubProperties gcpPubSubProperties)

closeManagedChannel

@PreDestroy
public void closeManagedChannel()