Class DirectWithAttributesChannel

java.lang.Object
org.springframework.cloud.stream.messaging.DirectWithAttributesChannel
public class DirectWithAttributesChannel extends Object
Since:
2.1
Author:
Oleg Zhurakousky

  • Field Details

    • COMPANION_ATTR

      public static String COMPANION_ATTR
      Name of the attribute that is considered to be a companion of this channel.

    • INDEFINITE_TIMEOUT

      static final long INDEFINITE_TIMEOUT
      See Also:

    • interceptors

      protected final org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList interceptors

    • meters

      protected final Set<org.springframework.integration.support.management.metrics.MeterFacade> meters

    • METER_PREFIX

      static final String METER_PREFIX
      See Also:

    • SEND_TIMER_NAME

      static final String SEND_TIMER_NAME
      See Also:

    • RECEIVE_COUNTER_NAME

      static final String RECEIVE_COUNTER_NAME
      See Also:

    • EXPRESSION_PARSER

      protected static final org.springframework.expression.ExpressionParser EXPRESSION_PARSER

    • logger

      protected final org.springframework.core.log.LogAccessor logger

  • Constructor Details

    • DirectWithAttributesChannel

      public DirectWithAttributesChannel()

  • Method Details

    • setAttribute

      public void setAttribute(String key, Object value)

    • getAttribute

      public Object getAttribute(String key)

    • getBeanName

      public String getBeanName()

    • destroy

      public void destroy()

    • subscribe

      public boolean subscribe(org.springframework.messaging.MessageHandler handler)

    • setFailover

      public void setFailover(boolean arg0)

    • setFailoverStrategy

      public void setFailoverStrategy(Predicate<Exception> arg0)

    • setMaxSubscribers

      public void setMaxSubscribers(int arg0)

    • getDispatcher

      protected org.springframework.integration.dispatcher.UnicastingDispatcher getDispatcher()

    • onInit

      protected void onInit()

    • getSubscriberCount

      public int getSubscriberCount()

    • unsubscribe

      public boolean unsubscribe(org.springframework.messaging.MessageHandler arg0)

    • doSend

      protected boolean doSend(org.springframework.messaging.Message<?> arg0, long arg1)

    • send

      default boolean send(org.springframework.messaging.Message<?> arg0)

    • send

      boolean send(org.springframework.messaging.Message<?> arg0, long arg1)

    • getComponentType

      public String getComponentType()

    • getIntegrationPatternType

      public org.springframework.integration.IntegrationPatternType getIntegrationPatternType()

    • setShouldTrack

      public void setShouldTrack(boolean arg0)

    • registerMetricsCaptor

      public void registerMetricsCaptor(org.springframework.integration.support.management.metrics.MetricsCaptor arg0)

    • getMetricsCaptor

      protected @Nullable org.springframework.integration.support.management.metrics.MetricsCaptor getMetricsCaptor()

    • isLoggingEnabled

      public boolean isLoggingEnabled()

    • setLoggingEnabled

      public void setLoggingEnabled(boolean arg0)

    • setDatatypes

      public void setDatatypes(Class<?>... arg0)

    • setInterceptors

      public void setInterceptors(List<org.springframework.messaging.support.ChannelInterceptor> arg0)

    • addInterceptor

      public void addInterceptor(org.springframework.messaging.support.ChannelInterceptor arg0)

    • addInterceptor

      public void addInterceptor(int arg0, org.springframework.messaging.support.ChannelInterceptor arg1)

    • setMessageConverter

      public void setMessageConverter(org.springframework.messaging.converter.MessageConverter arg0)

    • setObservationConvention

      public void setObservationConvention(@Nullable org.springframework.integration.support.management.observation.MessageSenderObservationConvention arg0)

    • getInterceptors

      public List<org.springframework.messaging.support.ChannelInterceptor> getInterceptors()

    • removeInterceptor

      public boolean removeInterceptor(org.springframework.messaging.support.ChannelInterceptor arg0)

    • removeInterceptor

      public org.springframework.messaging.support.ChannelInterceptor removeInterceptor(int arg0)

    • getIChannelInterceptorList

      protected org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList getIChannelInterceptorList()

    • getOverrides

      public org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides getOverrides()

    • registerObservationRegistry

      public void registerObservationRegistry(io.micrometer.observation.ObservationRegistry arg0)

    • isObserved

      public boolean isObserved()

    • getFullChannelName

      public String getFullChannelName()

    • send

      public boolean send(org.springframework.messaging.Message<?> arg0)

    • send

      public boolean send(org.springframework.messaging.Message<?> arg0, long arg1)

    • isApplicationRunning

      protected boolean isApplicationRunning()

    • getComponentName

      String getComponentName()

    • setManagedName

      default void setManagedName(String arg0)

    • getManagedName

      default @Nullable String getManagedName()

    • setManagedType

      default void setManagedType(String arg0)

    • getManagedType

      default @Nullable String getManagedType()

    • getThisAs

      default <T> T getThisAs()

    • setBeanName

      public final void setBeanName(String arg0)

    • getComponentName

      public String getComponentName()

    • setComponentName

      public void setComponentName(String arg0)

    • setComponentSource

      public void setComponentSource(Object arg0)

    • getComponentSource

      public @Nullable Object getComponentSource()

    • setComponentDescription

      public void setComponentDescription(String arg0)

    • getComponentDescription

      public @Nullable String getComponentDescription()

    • getBeanDescription

      public String getBeanDescription()

    • setBeanFactory

      public void setBeanFactory(org.springframework.beans.factory.BeanFactory arg0)

    • setApplicationContext

      public void setApplicationContext(org.springframework.context.ApplicationContext arg0) throws org.springframework.beans.BeansException
      Throws:
      org.springframework.beans.BeansException

    • setChannelResolver

      public void setChannelResolver(org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> arg0)

    • getExpression

      public @Nullable org.springframework.expression.Expression getExpression()

    • setPrimaryExpression

      public final void setPrimaryExpression(org.springframework.expression.Expression arg0)

    • afterPropertiesSet

      public final void afterPropertiesSet()

    • isInitialized

      protected boolean isInitialized()

    • getBeanFactory

      protected org.springframework.beans.factory.BeanFactory getBeanFactory()

    • setTaskScheduler

      public void setTaskScheduler(org.springframework.scheduling.TaskScheduler arg0)

    • getTaskScheduler

      protected org.springframework.scheduling.TaskScheduler getTaskScheduler()

    • getChannelResolver

      protected org.springframework.messaging.core.DestinationResolver<org.springframework.messaging.MessageChannel> getChannelResolver()

    • setConversionService

      public void setConversionService(org.springframework.core.convert.ConversionService arg0)

    • getConversionService

      public org.springframework.core.convert.ConversionService getConversionService()

    • getApplicationContextId

      public @Nullable String getApplicationContextId()

    • getApplicationContext

      protected org.springframework.context.ApplicationContext getApplicationContext()

    • getIntegrationProperties

      protected org.springframework.integration.context.IntegrationProperties getIntegrationProperties()

    • getMessageBuilderFactory

      protected org.springframework.integration.support.MessageBuilderFactory getMessageBuilderFactory()

    • setMessageBuilderFactory

      public void setMessageBuilderFactory(org.springframework.integration.support.MessageBuilderFactory arg0)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • extractTypeIfPossible

      public static <T> @Nullable T extractTypeIfPossible(@Nullable Object arg0, Class<T> arg1)

    • generateId

      public static UUID generateId()