org.springframework.cloud.gcp.pubsub.integration.outbound

Class PubSubMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.MessageHandlerSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.cloud.gcp.pubsub.integration.outbound.PubSubMessageHandler

All Implemented Interfaces:

org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, org.springframework.integration.context.ExpressionCapable, org.springframework.integration.context.Orderable, org.springframework.integration.IntegrationPattern, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.BaseHandlerMetrics, org.springframework.integration.support.management.ConfigurableMetricsAware<org.springframework.integration.support.management.AbstractMessageHandlerMetrics>, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.IntegrationStatsManagement, org.springframework.integration.support.management.MessageHandlerMetrics, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>

public class PubSubMessageHandler
extends org.springframework.integration.handler.AbstractMessageHandler

Outbound channel adapter to publish messages to Google Cloud Pub/Sub.

It delegates Google Cloud Pub/Sub interaction to PubSubTemplate.

Author:

João André Martins, Mike Eltsufin, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
PubSubMessageHandler(PubSubPublisherOperations pubSubPublisherOperations, String topic)

Method Summary

Modifier and Type	Method and Description
protected org.springframework.util.concurrent.ListenableFutureCallback<String>	getPublishCallback()
org.springframework.expression.Expression	getPublishTimeoutExpression()
org.springframework.expression.Expression	getTopicExpression()
protected void	handleMessageInternal(org.springframework.messaging.Message<?> message)
boolean	isSync()
protected void	onInit()
void	setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Map<String,String>> headerMapper) Set the header mapper to map headers from Message into outbound PubsubMessage.
void	setPublishCallback(org.springframework.util.concurrent.ListenableFutureCallback<String> publishCallback) Set the callback to be activated when the publish call resolves.
void	setPublishTimeout(long timeoutMillis) Set the timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub.
void	setPublishTimeoutExpression(org.springframework.expression.Expression publishTimeoutExpression) Set the SpEL expression to evaluate a timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub.
void	setPublishTimeoutExpressionString(String publishTimeoutExpression) Set the SpEL expression to evaluate a timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub from a string.
void	setSync(boolean sync) Set publish method to be synchronous or asynchronous.
void	setTopic(String topic) Set the topic where this adapter sends messages to.
void	setTopicExpression(org.springframework.expression.Expression topicExpression) Set the SpEL expression for the topic this adapter sends messages to.
void	setTopicExpressionString(String topicExpressionString) Set the topic expression string that is evaluated into an actual expression.

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

handleMessage, onComplete, onError, onNext, onSubscribe

Methods inherited from class org.springframework.integration.handler.MessageHandlerSupport

buildSendTimer, configureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getHandlerMetrics, getIntegrationPatternType, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, isCountsEnabled, isLoggingEnabled, isStatsEnabled, registerMetricsCaptor, reset, sendTimer, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled, shouldTrack

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Methods inherited from interface org.springframework.integration.support.management.MessageHandlerMetrics

errorCount, handleCount

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getBeanName, getComponentName

Constructor Detail

PubSubMessageHandler

public PubSubMessageHandler(PubSubPublisherOperations pubSubPublisherOperations,
                            String topic)

Method Detail

isSync

public boolean isSync()

setSync

public void setSync(boolean sync)

Set publish method to be synchronous or asynchronous.

Publish is asynchronous be default.

Parameters:

sync - true for synchronous, false for asynchronous

getPublishTimeoutExpression

public org.springframework.expression.Expression getPublishTimeoutExpression()

setPublishTimeoutExpression

public void setPublishTimeoutExpression(org.springframework.expression.Expression publishTimeoutExpression)

Set the SpEL expression to evaluate a timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub.

Parameters:

publishTimeoutExpression - the Expression for the publish timeout in milliseconds

setPublishTimeoutExpressionString

public void setPublishTimeoutExpressionString(String publishTimeoutExpression)

Set the SpEL expression to evaluate a timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub from a string.

Parameters:

publishTimeoutExpression - a string with an expression for the publish timeout in milliseconds

setPublishTimeout

public void setPublishTimeout(long timeoutMillis)

Set the timeout in milliseconds for a synchronous publish call to Google Cloud Pub/Sub.

Parameters:

timeoutMillis - timeout in milliseconds

getPublishCallback

protected org.springframework.util.concurrent.ListenableFutureCallback<String> getPublishCallback()

setPublishCallback

public void setPublishCallback(org.springframework.util.concurrent.ListenableFutureCallback<String> publishCallback)

Set the callback to be activated when the publish call resolves.

Parameters:

publishCallback - callback for the publish future

getTopicExpression

public org.springframework.expression.Expression getTopicExpression()

setTopicExpression

public void setTopicExpression(org.springframework.expression.Expression topicExpression)

Set the SpEL expression for the topic this adapter sends messages to.

Parameters:

topicExpression - the SpEL expression representing the topic name

setTopic

public void setTopic(String topic)

Set the topic where this adapter sends messages to.

Parameters:

topic - topic name

setTopicExpressionString

public void setTopicExpressionString(String topicExpressionString)

Set the topic expression string that is evaluated into an actual expression.

Parameters:

topicExpressionString - topic expression string

setHeaderMapper

public void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<Map<String,String>> headerMapper)

Set the header mapper to map headers from Message into outbound PubsubMessage.

Parameters:

headerMapper - the header mapper

handleMessageInternal

protected void handleMessageInternal(org.springframework.messaging.Message<?> message)

Specified by:

handleMessageInternal in class org.springframework.integration.handler.AbstractMessageHandler

onInit

protected void onInit()

Overrides:

onInit in class org.springframework.integration.handler.MessageHandlerSupport