com.atlassian.bamboo.v2.build.agent

Class BambooJmsTemplate

java.lang.Object

org.springframework.jms.support.JmsAccessor

org.springframework.jms.support.destination.JmsDestinationAccessor

org.springframework.jms.core.JmsTemplate

com.atlassian.bamboo.v2.build.agent.BambooJmsTemplate

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, org.springframework.jms.core.JmsOperations

public class BambooJmsTemplate
extends org.springframework.jms.core.JmsTemplate

In addition to standard JmsTemplate, this closes the message consumer if it has been interrupted while waiting for the message. Interrupted status is preserved.

Field Summary

Fields inherited from class org.springframework.jms.support.destination.JmsDestinationAccessor

RECEIVE_TIMEOUT_INDEFINITE_WAIT, RECEIVE_TIMEOUT_NO_WAIT

Fields inherited from class org.springframework.jms.support.JmsAccessor

logger

Constructor Summary

Constructors

Constructor and Description
BambooJmsTemplate(javax.jms.ConnectionFactory connectionFactory, org.springframework.jms.support.converter.MessageConverter messageConverter)

Method Summary

Modifier and Type	Method and Description
protected javax.jms.Message	doReceive(javax.jms.Session session, javax.jms.MessageConsumer consumer)

Methods inherited from class org.springframework.jms.core.JmsTemplate

browse, browse, browse, browseSelected, browseSelected, browseSelected, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, createBrowser, createConsumer, createProducer, doConvertFromMessage, doCreateProducer, doReceive, doSend, doSend, doSendAndReceive, execute, execute, execute, execute, execute, getConnection, getDefaultDestination, getDefaultDestinationName, getDeliveryDelay, getDeliveryMode, getMessageConverter, getPriority, getReceiveTimeout, getSession, getTimeToLive, initDefaultStrategies, isExplicitQosEnabled, isMessageIdEnabled, isMessageTimestampEnabled, isPubSubNoLocal, isSessionLocallyTransacted, receive, receive, receive, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveSelected, receiveSelected, receiveSelected, receiveSelectedAndConvert, receiveSelectedAndConvert, receiveSelectedAndConvert, send, send, send, sendAndReceive, sendAndReceive, sendAndReceive, setDefaultDestination, setDefaultDestinationName, setDeliveryDelay, setDeliveryMode, setDeliveryPersistent, setExplicitQosEnabled, setMessageConverter, setMessageIdEnabled, setMessageTimestampEnabled, setPriority, setPubSubNoLocal, setQosSettings, setReceiveTimeout, setTimeToLive

Methods inherited from class org.springframework.jms.support.destination.JmsDestinationAccessor

getDestinationResolver, isPubSubDomain, receiveFromConsumer, resolveDestinationName, setDestinationResolver, setPubSubDomain

Methods inherited from class org.springframework.jms.support.JmsAccessor

afterPropertiesSet, convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, obtainConnectionFactory, setConnectionFactory, setSessionAcknowledgeMode, setSessionAcknowledgeModeName, setSessionTransacted

Methods inherited from class java.lang.Object

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

Constructor Detail

BambooJmsTemplate

public BambooJmsTemplate(javax.jms.ConnectionFactory connectionFactory,
                         org.springframework.jms.support.converter.MessageConverter messageConverter)

Method Detail

doReceive

@Nullable
protected javax.jms.Message doReceive(javax.jms.Session session,
                                                javax.jms.MessageConsumer consumer)
                                         throws javax.jms.JMSException

Overrides:

doReceive in class org.springframework.jms.core.JmsTemplate

Throws:

javax.jms.JMSException