Package com.boutouil.binder.jms

Class JmsMessageChannelBinder

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<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

com.boutouil.binder.jms.JmsMessageChannelBinder

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<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>, org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>, org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,JmsConsumerProperties,JmsProducerProperties>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware

public class JmsMessageChannelBinder
extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>
implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,JmsConsumerProperties,JmsProducerProperties>

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

Description

JmsMessageChannelBinder(org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>> provisioningProvider, JmsMessageHandlerFactory jmsMessageHandlerFactory, org.springframework.jms.config.DefaultJmsListenerContainerFactory jmsListenerContainerFactory, org.springframework.cloud.stream.config.ListenerContainerCustomizer<org.springframework.jms.listener.AbstractMessageListenerContainer> containerCustomizer)

Method Summary

Modifier and Type	Method	Description
protected org.springframework.integration.core.MessageProducer	createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)
protected org.springframework.messaging.MessageHandler	createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
String	getDefaultsPrefix()
protected org.springframework.messaging.MessageHandler	getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)
protected org.springframework.integration.support.ErrorMessageStrategy	getErrorMessageStrategy()
JmsConsumerProperties	getExtendedConsumerProperties(String channelName)
JmsProducerProperties	getExtendedProducerProperties(String channelName)
Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>	getExtendedPropertiesEntryClass()
protected void	postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel, org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties)
void	setExtendedBindingProperties(JmsExtendedBindingProperties extendedBindingProperties)

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

afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, createProducerMessageHandler, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getApplicationEventPublisher, getContainerCustomizer, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandlerName, getErrorRecovererName, getMessageSourceCustomizer, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, onInit, 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, 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

JmsMessageChannelBinder

public JmsMessageChannelBinder(org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>> provisioningProvider,
                               JmsMessageHandlerFactory jmsMessageHandlerFactory,
                               org.springframework.jms.config.DefaultJmsListenerContainerFactory jmsListenerContainerFactory,
                               org.springframework.cloud.stream.config.ListenerContainerCustomizer<org.springframework.jms.listener.AbstractMessageListenerContainer> containerCustomizer)

Method Detail

setExtendedBindingProperties

public void setExtendedBindingProperties(JmsExtendedBindingProperties extendedBindingProperties)

getExtendedConsumerProperties

public JmsConsumerProperties getExtendedConsumerProperties(String channelName)

Specified by:

getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

getExtendedProducerProperties

public JmsProducerProperties getExtendedProducerProperties(String channelName)

Specified by:

getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

getDefaultsPrefix

public String getDefaultsPrefix()

Specified by:

getDefaultsPrefix in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

getExtendedPropertiesEntryClass

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

Specified by:

getExtendedPropertiesEntryClass in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<JmsConsumerProperties,JmsProducerProperties>

createProducerMessageHandler

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

Specified by:

createProducerMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

postProcessOutputChannel

protected void postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel,
                                        org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties> producerProperties)

Overrides:

postProcessOutputChannel in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

createConsumerEndpoint

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

Specified by:

createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

getErrorMessageStrategy

protected org.springframework.integration.support.ErrorMessageStrategy getErrorMessageStrategy()

Overrides:

getErrorMessageStrategy in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>

getErrorMessageHandler

protected org.springframework.messaging.MessageHandler getErrorMessageHandler(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                                              String group,
                                                                              org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties> properties)

Overrides:

getErrorMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>,org.springframework.cloud.stream.provisioning.ProvisioningProvider<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<JmsConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<JmsProducerProperties>>>