1

私たちのプロジェクトでは、「jms/ConnectionFactory」としてバインドされた ConnectionFactory と「jms/Queue」としてバインドされたキューで Glassfish v3.1.2.2 を使用します。両方とも、glassfish 管理コンソールで作成されます。

Spring 構成は次のように実装されます。

@Bean
public JndiTemplate jndiTemplate() {
    JndiTemplate jndiTemplate = new JndiTemplate();
    Properties props = new Properties();
    props.setProperty("java.naming.factory.initial", "com.sun.enterprise.naming.SerialInitContextFactory");
    props.setProperty("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
    props.setProperty("java.naming.factory.state", "com.sun.corba.ee.impl.presentation.rmi.JNDIStateFactoryImpl");
    props.setProperty("org.omg.CORBA.ORBInitialHost", "localhost");
    props.setProperty("org.omg.CORBA.ORBInitialPort", "3700");
    jndiTemplate.setEnvironment(props);

    return jndiTemplate;
}


@Bean
public JndiObjectFactoryBean connectionFactory() {
    JndiObjectFactoryBean connectionFactory = new JndiObjectFactoryBean();
    connectionFactory.setJndiTemplate(jndiTemplate());
    connectionFactory.setJndiName("jms/ConnectionFactory");

    return connectionFactory;
}

@Bean
public TransactionAwareConnectionFactoryProxy connectionFactoryProxy() {
    return new TransactionAwareConnectionFactoryProxy((ConnectionFactory) connectionFactory().getObject());
}

@Bean
public JndiObjectFactoryBean destination() {
    JndiObjectFactoryBean jndiObjectFactoryBean = new JndiObjectFactoryBean();
    jndiObjectFactoryBean.setJndiTemplate(jndiTemplate());
    jndiObjectFactoryBean.setJndiName("jms/Queue");
    return jndiObjectFactoryBean;
}

@Bean
public JmsTemplate jmsTemplate() {
    JmsTemplate jmsTemplate = new JmsTemplate();
    jmsTemplate.setConnectionFactory((ConnectionFactory) connectionFactory().getObject());
    jmsTemplate.setDefaultDestination((Destination) destination().getObject());
    return jmsTemplate;
}

@Bean
public DefaultMessageListenerContainer simpleMessageListenerContainer() {
    DefaultMessageListenerContainer listenerContainer = new DefaultMessageListenerContainer();
    listenerContainer.setConnectionFactory(connectionFactoryProxy());
    listenerContainer.setDestination((Destination) destination().getObject());
    listenerContainer.setMessageListener(messageDispatcher);
    listenerContainer.setSessionTransacted(true);
    listenerContainer.setTransactionManager(jtaTransactionManager());
    return listenerContainer;
}

これまでのところすべて正常に動作しており、メッセージは問題なくキューに送信され、キューから消費されます。RuntimeException によるメッセージのロールバックも機能します。

問題は、Activation Spec の RedeliveryAttempts や RedeliveryInterval などの基本的な設定を変更する方法です。MDBのみを使用してSpringでこれを変更する解決策が見つかりません。Glassfishs 管理コンソールまたは Spring 構成でこれを行う方法はありますか? 別の実装を使用する必要がありましたか、それともすべてでは不可能ですか?

誰かが助けてくれることを願っています。前もってありがとう、ダニー

4

1 に答える 1

1

いくつかの試行錯誤の結果、Glassfish 4 で動作する以下を見つけました。

@Bean
public JmsTemplate jmsTemplate() {
    JmsTemplate jmsTemplate = new JmsTemplate();
    jmsTemplate.setPubSubDomain(true);  //may be necessary if using topic
    jmsTemplate.setDefaultDestinationName("topicname");
    jmsTemplate.setConnectionFactory(connectionFactory());
    return jmsTemplate;
}

@Bean
public ConnectionFactory connectionFactory() {
    try {
        JndiObjectFactoryBean jndiFactory = new JndiObjectFactoryBean();
        jndiFactory.setJndiName("jms/ConnectionFactory");
        jndiFactory.setResourceRef(true);  //adds java:comp/env/ prefix
        jndiFactory.afterPropertiesSet();  //very important, actually causes the object to be loaded

        return (ConnectionFactory) jndiFactory.getObject();

    } catch (IllegalArgumentException | NamingException e) {
        throw new RuntimeException(e);
    }
}
于 2014-07-17T05:02:41.403 に答える