Package com.atlassian.bamboo.v2.build.agent

Class 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 Description
      BambooJmsTemplate​(javax.jms.ConnectionFactory connectionFactory, org.springframework.jms.support.converter.MessageConverter messageConverter)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected @Nullable 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

    • Constructor Detail

      • BambooJmsTemplate

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

    • Method Detail

      • doReceive

        @Nullable
protected @Nullable 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