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

  • Method Summary

    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

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • BambooJmsTemplate

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

  • Method Details

    • 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