org.springframework.integration.jms
Class SubscribableJmsChannel

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.channel.AbstractMessageChannel
          extended by org.springframework.integration.jms.AbstractJmsChannel
              extended by org.springframework.integration.jms.SubscribableJmsChannel
All Implemented Interfaces:
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.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.NamedComponent, org.springframework.integration.core.SubscribableChannel, org.springframework.integration.history.TrackableComponent, org.springframework.integration.MessageChannel

public class SubscribableJmsChannel
extends AbstractJmsChannel
implements org.springframework.integration.core.SubscribableChannel, org.springframework.context.SmartLifecycle, org.springframework.beans.factory.DisposableBean

Since:
2.0

Nested Class Summary
 
Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorList
 
Field Summary
 
Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel
logger
 
Constructor Summary
SubscribableJmsChannel(org.springframework.jms.listener.AbstractMessageListenerContainer container, org.springframework.jms.core.JmsTemplate jmsTemplate)
           
 
Method Summary
 void destroy()
           
 int getPhase()
           
 boolean isAutoStartup()
           
 boolean isRunning()
           
 void onInit()
           
 void setMaxSubscribers(int maxSubscribers)
          Specify the maximum number of subscribers supported by the channel's dispatcher.
 void start()
           
 void stop()
           
 void stop(java.lang.Runnable callback)
           
 boolean subscribe(org.springframework.integration.core.MessageHandler handler)
           
 boolean unsubscribe(org.springframework.integration.core.MessageHandler handler)
           
 
Methods inherited from class org.springframework.integration.jms.AbstractJmsChannel
doSend
 
Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel
addInterceptor, getComponentType, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setShouldTrack
 
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setTaskScheduler, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.springframework.integration.MessageChannel
send, send
 
Methods inherited from interface org.springframework.integration.context.NamedComponent
getComponentName
 

Constructor Detail

SubscribableJmsChannel

public SubscribableJmsChannel(org.springframework.jms.listener.AbstractMessageListenerContainer container,
                              org.springframework.jms.core.JmsTemplate jmsTemplate)
Method Detail

setMaxSubscribers

public void setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the channel's dispatcher.

Parameters:
maxSubscribers -

subscribe

public boolean subscribe(org.springframework.integration.core.MessageHandler handler)
Specified by:
subscribe in interface org.springframework.integration.core.SubscribableChannel

unsubscribe

public boolean unsubscribe(org.springframework.integration.core.MessageHandler handler)
Specified by:
unsubscribe in interface org.springframework.integration.core.SubscribableChannel

onInit

public void onInit()
            throws java.lang.Exception
Overrides:
onInit in class org.springframework.integration.context.IntegrationObjectSupport
Throws:
java.lang.Exception

isAutoStartup

public boolean isAutoStartup()
Specified by:
isAutoStartup in interface org.springframework.context.SmartLifecycle

getPhase

public int getPhase()
Specified by:
getPhase in interface org.springframework.context.Phased

isRunning

public boolean isRunning()
Specified by:
isRunning in interface org.springframework.context.Lifecycle

start

public void start()
Specified by:
start in interface org.springframework.context.Lifecycle

stop

public void stop()
Specified by:
stop in interface org.springframework.context.Lifecycle

stop

public void stop(java.lang.Runnable callback)
Specified by:
stop in interface org.springframework.context.SmartLifecycle

destroy

public void destroy()
             throws java.lang.Exception
Specified by:
destroy in interface org.springframework.beans.factory.DisposableBean
Throws:
java.lang.Exception