com.google.cloud.spring.stream.binder.pubsub

Class PubSubMessageChannelBinder

java.lang.Object

org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,C,P>

org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>

com.google.cloud.spring.stream.binder.pubsub.PubSubMessageChannelBinder

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>>, org.springframework.cloud.stream.binder.ExtendedBindingProperties<PubSubConsumerProperties,PubSubProducerProperties>, org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,PubSubConsumerProperties,PubSubProducerProperties>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware

public class PubSubMessageChannelBinder
extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>
implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,PubSubConsumerProperties,PubSubProducerProperties>

Message channel binder for Pub/Sub.

Author:

João André Martins, Mike Eltsufin, Artem Bilan, Daniel Zou, Emmanouil Gkatziouras

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure, org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources

Field Summary

Fields inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

provisioningProvider

Fields inherited from class org.springframework.cloud.stream.binder.AbstractBinder

logger

Constructor Summary

Constructors

Constructor and Description
PubSubMessageChannelBinder(String[] headersToEmbed, PubSubChannelProvisioner provisioningProvider, PubSubTemplate pubSubTemplate, PubSubExtendedBindingProperties pubSubExtendedBindingProperties)

Method Summary

Modifier and Type	Method and Description
protected void	afterUnbindConsumer(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties)
protected org.springframework.integration.core.MessageProducer	createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties)
protected org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources	createPolledConsumerResources(String name, String group, org.springframework.cloud.stream.provisioning.ConsumerDestination destination, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties)
protected org.springframework.messaging.MessageHandler	createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
protected PubSubMessageSource	createPubSubMessageSource(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties)
protected String	errorsBaseName(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties)
String	getDefaultsPrefix()
PubSubConsumerProperties	getExtendedConsumerProperties(String channelName)
PubSubProducerProperties	getExtendedProducerProperties(String channelName)
Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>	getExtendedPropertiesEntryClass()
void	setHealthTrackerRegistry(HealthTrackerRegistry healthTrackerRegistry)

Methods inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

afterUnbindProducer, bindPollableConsumer, createProducerMessageHandler, doBindConsumer, doBindProducer, errorsBaseName, getApplicationEventPublisher, getContainerCustomizer, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandler, getErrorMessageHandlerName, getErrorMessageStrategy, getErrorRecovererName, getMessageSourceCustomizer, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, postProcessOutputChannel, postProcessPollableSource, registerErrorInfrastructure, registerErrorInfrastructure, setApplicationEventPublisher, setConsumerEndpointCustomizer, setProducerMessageHandlerCustomizer, useNativeEncoding

Methods inherited from class org.springframework.cloud.stream.binder.AbstractBinder

afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getEvaluationContext, groupedName, onInit, setApplicationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.cloud.stream.binder.Binder

bindConsumer, bindProducer

Methods inherited from interface org.springframework.cloud.stream.binder.ExtendedBindingProperties

getBindings

Constructor Detail

PubSubMessageChannelBinder

public PubSubMessageChannelBinder(String[] headersToEmbed,
                                  PubSubChannelProvisioner provisioningProvider,
                                  PubSubTemplate pubSubTemplate,
                                  PubSubExtendedBindingProperties pubSubExtendedBindingProperties)

Method Detail

setHealthTrackerRegistry

public void setHealthTrackerRegistry(HealthTrackerRegistry healthTrackerRegistry)

createProducerMessageHandler

protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination,
                                                                                    org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties> producerProperties,
                                                                                    org.springframework.messaging.MessageChannel errorChannel)

Specified by:

createProducerMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>

createConsumerEndpoint

protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                                                      String group,
                                                                                      org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties)

Specified by:

createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>

errorsBaseName

protected String errorsBaseName(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                String group,
                                org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> properties)

Overrides:

errorsBaseName in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>

getExtendedConsumerProperties

public PubSubConsumerProperties getExtendedConsumerProperties(String channelName)

Specified by:

getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<PubSubConsumerProperties,PubSubProducerProperties>

getExtendedProducerProperties

public PubSubProducerProperties getExtendedProducerProperties(String channelName)

Specified by:

getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<PubSubConsumerProperties,PubSubProducerProperties>

getDefaultsPrefix

public String getDefaultsPrefix()

Specified by:

getDefaultsPrefix in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<PubSubConsumerProperties,PubSubProducerProperties>

getExtendedPropertiesEntryClass

public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()

Specified by:

getExtendedPropertiesEntryClass in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<PubSubConsumerProperties,PubSubProducerProperties>

afterUnbindConsumer

protected void afterUnbindConsumer(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                   String group,
                                   org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties)

Overrides:

afterUnbindConsumer in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>

createPolledConsumerResources

protected org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources createPolledConsumerResources(String name,
                                                                                                                                     String group,
                                                                                                                                     org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                                                                                                     org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties)

Overrides:

createPolledConsumerResources in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<PubSubProducerProperties>,PubSubChannelProvisioner>

createPubSubMessageSource

protected PubSubMessageSource createPubSubMessageSource(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                        org.springframework.cloud.stream.binder.ExtendedConsumerProperties<PubSubConsumerProperties> consumerProperties)