Examples of org.springframework.jms.core.JmsTemplate102

org.springframework.jms.core.JmsTemplate102
A subclass of {@link JmsTemplate} for the JMS 1.0.2 specification, not relyingon JMS 1.1 methods like JmsTemplate itself. This class can be used for JMS 1.0.2 providers, offering the same API as JmsTemplate does for JMS 1.1 providers.
You must specify the domain (or style) of messaging to be either Point-to-Point (Queues) or Publish/Subscribe (Topics), using the {@link #setPubSubDomain "pubSubDomain" property}. Point-to-Point (Queues) is the default domain.
The "pubSubDomain" property is an important setting due to the use of similar but separate class hierarchies in the JMS 1.0.2 API. JMS 1.1 provides a new domain-independent API that allows for easy mix-and-match use of Point-to-Point and Publish/Subscribe styles.
This template uses a {@link org.springframework.jms.support.destination.DynamicDestinationResolver}and a {@link org.springframework.jms.support.converter.SimpleMessageConverter102}as default strategies for resolving a destination name and converting a message, respectively. @author Mark Pollack @author Juergen Hoeller @since 1.1 @see #setConnectionFactory @see #setPubSubDomain @see javax.jms.Queue @see javax.jms.Topic @see javax.jms.QueueSession @see javax.jms.TopicSession @see javax.jms.QueueSender @see javax.jms.TopicPublisher @see javax.jms.QueueReceiver @see javax.jms.TopicSubscriber

     */
    public static JmsTemplate createJmsTemplate(JMSConfiguration jmsConfig, JMSMessageHeadersType headers) {
        if (jmsConfig.getJmsTemplate() != null) {
            return jmsConfig.getJmsTemplate();
        }
        JmsTemplate jmsTemplate = jmsConfig.isUseJms11() ? new JmsTemplate() : new JmsTemplate102();
        jmsTemplate.setConnectionFactory(jmsConfig.getOrCreateWrappedConnectionFactory());
        jmsTemplate.setPubSubDomain(jmsConfig.isPubSubDomain());
        if (jmsConfig.getReceiveTimeout() != null) {
            jmsTemplate.setReceiveTimeout(jmsConfig.getReceiveTimeout());
        }

View Full Code Here

    conControl.replay();
    cfControl.replay();


    JmsTransactionManager tm = new JmsTransactionManager102(cf, false);
    TransactionStatus ts = tm.getTransaction(new DefaultTransactionDefinition());
    JmsTemplate jt = new JmsTemplate102(cf, false);
    jt.execute(new SessionCallback() {
      public Object doInJms(Session sess) {
        assertTrue(sess == session);
        return null;
      }
    });

View Full Code Here

    conControl.replay();
    cfControl.replay();


    JmsTransactionManager tm = new JmsTransactionManager102(cf, true);
    TransactionStatus ts = tm.getTransaction(new DefaultTransactionDefinition());
    JmsTemplate jt = new JmsTemplate102(cf, true);
    jt.execute(new SessionCallback() {
      public Object doInJms(Session sess) {
        assertTrue(sess == session);
        return null;
      }
    });

View Full Code Here

    }


    protected JmsTemplate createTemplate() {
        JmsTemplate tplt;
        if (isJms102()) {
            tplt = new JmsTemplate102();
        } else {
            tplt = new JmsTemplate();
        }
        tplt.setConnectionFactory(getConnectionFactory());
        if (getDestination() != null) {

View Full Code Here

    
    public synchronized void start() throws Exception {
        super.start();
        if (template == null) {
            if (isJms102()) {
                template = new JmsTemplate102(getConnectionFactory(), isPubSubDomain());
            } else {
                template = new JmsTemplate(getConnectionFactory());
            }
        }
        if (store == null && !stateless) {

View Full Code Here

        if (template instanceof JmsTemplate) {
            JmsTemplate jmsTemplate = (JmsTemplate) template;
            jmsTemplate.setReceiveTimeout(timeout);
        }
        else if (template instanceof JmsTemplate102) {
            JmsTemplate102 jmsTemplate102 = (JmsTemplate102) template;
            jmsTemplate102.setReceiveTimeout(timeout);
        }
        else {
            throw new IllegalArgumentException("Cannot set the receiveTimeout property on unknown JmsOperations type: " + template);
        }
    }

View Full Code Here

    }


    public JmsOperations createJmsOperations(boolean pubSubDomain, String destination) {
        ConnectionFactory factory = getTemplateConnectionFactory();
        JmsTemplate template = useVersion102
                ? new JmsTemplate102(factory, pubSubDomain)
                : new JmsTemplate(factory);
        template.setPubSubDomain(pubSubDomain);
        template.setDefaultDestinationName(destination);


        template.setExplicitQosEnabled(explicitQosEnabled);

View Full Code Here

     * @param jmsConfig configuration information
     * @param headers context headers
     * @return
     */
    public static JmsTemplate createJmsTemplate(JMSConfiguration jmsConfig, JMSMessageHeadersType headers) {
        JmsTemplate jmsTemplate = jmsConfig.isUseJms11() ? new JmsTemplate() : new JmsTemplate102();
        jmsTemplate.setConnectionFactory(jmsConfig.getConnectionFactory());
        jmsTemplate.setPubSubDomain(jmsConfig.isPubSubDomain());
        jmsTemplate.setReceiveTimeout(jmsConfig.getReceiveTimeout());
        jmsTemplate.setTimeToLive(jmsConfig.getTimeToLive());
        int priority = (headers != null && headers.isSetJMSPriority())

View Full Code Here

     * @param jmsConfig configuration information
     * @param headers context headers
     * @return
     */
    public static JmsTemplate createJmsTemplate(JMSConfiguration jmsConfig, JMSMessageHeadersType headers) {
        JmsTemplate jmsTemplate = jmsConfig.isUseJms11() ? new JmsTemplate() : new JmsTemplate102();
        jmsTemplate.setConnectionFactory(jmsConfig.getOrCreateWrappedConnectionFactory());
        jmsTemplate.setPubSubDomain(jmsConfig.isPubSubDomain());
        jmsTemplate.setReceiveTimeout(jmsConfig.getReceiveTimeout());
        jmsTemplate.setTimeToLive(jmsConfig.getTimeToLive());
        int priority = (headers != null && headers.isSetJMSPriority())

View Full Code Here

    protected void setReceiveTimeout(long timeout) {
        if (template instanceof JmsTemplate) {
            JmsTemplate jmsTemplate = (JmsTemplate)template;
            jmsTemplate.setReceiveTimeout(timeout);
        } else if (template instanceof JmsTemplate102) {
            JmsTemplate102 jmsTemplate102 = (JmsTemplate102)template;
            jmsTemplate102.setReceiveTimeout(timeout);
        } else {
            throw new IllegalArgumentException("Cannot set the receiveTimeout property on unknown JmsOperations type: " + template);
        }
    }

View Full Code Here

0 1 2 3

TOP

Related Classes of org.springframework.jms.core.JmsTemplate102

com.apress.prospring.ch12.business.JTAAccountManager

org.apache.camel.component.jms.JmsConfiguration

org.apache.camel.component.jms.JmsPollingConsumer

org.apache.cxf.transport.jms.JMSFactory

org.apache.servicemix.jms.endpoints.AbstractConsumerEndpoint

org.apache.servicemix.jms.endpoints.JmsProviderEndpoint

org.springframework.jms.connection.JmsTransactionManagerTests

org.springframework.jms.support.converter.SimpleMessageConverter102

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.