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.core.JmsTemplate

DEFAULT_RECEIVE_TIMEOUT

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

logger

Constructor Summary

BambooJmsTemplate()

BambooJmsTemplate(javax.jms.ConnectionFactory connectionFactory)

Method Summary

protected javax.jms.Message

doReceive(javax.jms.Session session, javax.jms.MessageConsumer consumer)

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

convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, createConsumer, createProducer, doConvertFromMessage, doCreateProducer, doReceive, doSend, doSend, execute, execute, execute, getConnection, getDefaultDestination, getDefaultDestinationName, 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, setDefaultDestination, setDefaultDestinationName, setDeliveryMode, setDeliveryPersistent, setExplicitQosEnabled, setMessageConverter, setMessageIdEnabled, setMessageTimestampEnabled, setPriority, setPubSubNoLocal, setReceiveTimeout, setTimeToLive

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

getDestinationResolver, isPubSubDomain, resolveDestinationName, setDestinationResolver, setPubSubDomain

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

afterPropertiesSet, convertJmsAccessException, createConnection, createSession, getConnectionFactory, getSessionAcknowledgeMode, isClientAcknowledge, isSessionTransacted, 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()

BambooJmsTemplate

public BambooJmsTemplate(javax.jms.ConnectionFactory connectionFactory)

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