public class JmsChannelFactoryBean extends AbstractFactoryBean<AbstractJmsChannel> implements SmartLifecycle, BeanNameAware
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Constructor and Description |
---|
JmsChannelFactoryBean() |
JmsChannelFactoryBean(boolean messageDriven) |
Modifier and Type | Method and Description |
---|---|
protected AbstractJmsChannel |
createInstance() |
protected void |
destroyInstance(AbstractJmsChannel instance) |
Class<?> |
getObjectType() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping) |
void |
setAutoStartup(boolean autoStartup) |
void |
setBeanName(String name) |
void |
setCacheLevel(Integer cacheLevel) |
void |
setCacheLevelName(String cacheLevelName) |
void |
setClientId(String clientId) |
void |
setConcurrency(String concurrency) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setContainerType(Class<? extends AbstractMessageListenerContainer> containerType) |
void |
setDeliveryPersistent(boolean deliveryPersistent) |
void |
setDestination(Destination destination) |
void |
setDestinationName(String destinationName) |
void |
setDestinationResolver(DestinationResolver destinationResolver) |
void |
setDurableSubscriptionName(String durableSubscriptionName) |
void |
setErrorHandler(ErrorHandler errorHandler) |
void |
setExceptionListener(ExceptionListener exceptionListener) |
void |
setExplicitQosEnabled(boolean explicitQosEnabled) |
void |
setExposeListenerSession(boolean exposeListenerSession) |
void |
setIdleTaskExecutionLimit(int idleTaskExecutionLimit) |
void |
setInterceptors(List<ChannelInterceptor> interceptors) |
void |
setMaxConcurrentConsumers(int maxConcurrentConsumers) |
void |
setMaxMessagesPerTask(int maxMessagesPerTask) |
void |
setMaxSubscribers(int maxSubscribers) |
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setMessageIdEnabled(boolean messageIdEnabled) |
void |
setMessageSelector(String messageSelector) |
void |
setMessageTimestampEnabled(boolean messageTimestampEnabled) |
void |
setPhase(int phase) |
void |
setPriority(int priority) |
void |
setPubSubDomain(boolean pubSubDomain) |
void |
setPubSubNoLocal(boolean pubSubNoLocal) |
void |
setReceiveTimeout(long receiveTimeout) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setSessionAcknowledgeMode(int sessionAcknowledgeMode) |
void |
setSessionTransacted(boolean sessionTransacted) |
void |
setSubscriptionDurable(boolean subscriptionDurable) |
void |
setSubscriptionShared(boolean subscriptionShared) |
void |
setTaskExecutor(Executor taskExecutor) |
void |
setTimeToLive(long timeToLive) |
void |
setTransactionManager(PlatformTransactionManager transactionManager) |
void |
setTransactionName(String transactionName) |
void |
setTransactionTimeout(int transactionTimeout) |
void |
start() |
void |
stop() |
void |
stop(Runnable callback) |
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
public JmsChannelFactoryBean()
public JmsChannelFactoryBean(boolean messageDriven)
public void setInterceptors(List<ChannelInterceptor> interceptors)
public void setDeliveryPersistent(boolean deliveryPersistent)
public void setExplicitQosEnabled(boolean explicitQosEnabled)
public void setMessageConverter(MessageConverter messageConverter)
public void setMessageIdEnabled(boolean messageIdEnabled)
public void setMessageTimestampEnabled(boolean messageTimestampEnabled)
public void setPriority(int priority)
public void setTimeToLive(long timeToLive)
public void setAcceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
public void setAutoStartup(boolean autoStartup)
public void setCacheLevelName(String cacheLevelName)
public void setCacheLevel(Integer cacheLevel)
public void setClientId(String clientId)
public void setConcurrency(String concurrency)
public void setConcurrentConsumers(int concurrentConsumers)
public void setConnectionFactory(ConnectionFactory connectionFactory)
public void setContainerType(Class<? extends AbstractMessageListenerContainer> containerType)
public void setDestination(Destination destination)
public void setDestinationName(String destinationName)
public void setDestinationResolver(DestinationResolver destinationResolver)
public void setDurableSubscriptionName(String durableSubscriptionName)
public void setErrorHandler(ErrorHandler errorHandler)
public void setExceptionListener(ExceptionListener exceptionListener)
public void setExposeListenerSession(boolean exposeListenerSession)
public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
public void setMaxMessagesPerTask(int maxMessagesPerTask)
public void setMessageSelector(String messageSelector)
public void setPhase(int phase)
public void setPubSubDomain(boolean pubSubDomain)
public void setPubSubNoLocal(boolean pubSubNoLocal)
public void setReceiveTimeout(long receiveTimeout)
public void setRecoveryInterval(long recoveryInterval)
public void setSessionAcknowledgeMode(int sessionAcknowledgeMode)
public void setSessionTransacted(boolean sessionTransacted)
public void setSubscriptionDurable(boolean subscriptionDurable)
public void setTaskExecutor(Executor taskExecutor)
public void setTransactionManager(PlatformTransactionManager transactionManager)
public void setTransactionName(String transactionName)
public void setTransactionTimeout(int transactionTimeout)
public void setMaxSubscribers(int maxSubscribers)
public void setSubscriptionShared(boolean subscriptionShared)
public void setBeanName(String name)
setBeanName
in interface BeanNameAware
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<AbstractJmsChannel>
getObjectType
in class AbstractFactoryBean<AbstractJmsChannel>
protected AbstractJmsChannel createInstance()
createInstance
in class AbstractFactoryBean<AbstractJmsChannel>
public boolean isAutoStartup()
isAutoStartup
in interface SmartLifecycle
public int getPhase()
getPhase
in interface Phased
getPhase
in interface SmartLifecycle
public void stop(Runnable callback)
stop
in interface SmartLifecycle
protected void destroyInstance(AbstractJmsChannel instance)
destroyInstance
in class AbstractFactoryBean<AbstractJmsChannel>