You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Justin Bertram (JIRA)" <ji...@apache.org> on 2017/03/12 20:00:05 UTC

[jira] [Comment Edited] (ARTEMIS-1032) Cannot call conn.setExceptionListener due Java EE7 JMS spec, inside Wildfly 10.x

    [ https://issues.apache.org/jira/browse/ARTEMIS-1032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15906666#comment-15906666 ] 

Justin Bertram edited comment on ARTEMIS-1032 at 3/12/17 7:59 PM:
------------------------------------------------------------------

Hi ,

thanks for your reply, 
Indeed I am using JMS bridge to connect Artemis <--> websphereMQ.
here is messaging subsystem :
{code:xml}
<subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
            <server name="default">
                <security-setting name="#">
                    <role name="guest" delete-non-durable-queue="true" create-non-durable-queue="true" consume="true" send="true"/>
                </security-setting>
                <address-setting name="#" message-counter-history-day-limit="10" page-size-bytes="2097152" max-size-bytes="10485760" expiry-address="jms.queue.ExpiryQueue" dead-letter-address="jms.queue.DLQ"/>
                <http-connector name="http-connector" endpoint="http-acceptor" socket-binding="http"/>
                <http-connector name="http-connector-throughput" endpoint="http-acceptor-throughput" socket-binding="http">
                    <param name="batch-delay" value="50"/>
                </http-connector>
                <in-vm-connector name="in-vm" server-id="0"/>
                <http-acceptor name="http-acceptor" http-listener="default"/>
                <http-acceptor name="http-acceptor-throughput" http-listener="default">
                    <param name="batch-delay" value="50"/>
                    <param name="direct-deliver" value="false"/>
                </http-acceptor>
                <in-vm-acceptor name="in-vm" server-id="0"/>
                <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
                <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
                <jms-queue name="IVTQueueProxy" entries="java:/jms/ivt/IVTQueueProxy java:jboss/exported/jms/ivt/IVTQueueProxy"/>
                <jms-queue name="IVTQueueProxyReply" entries="java:/jms/ivt/IVTQueueProxyReply java:jboss/exported/jms/ivt/IVTQueueProxyReply"/>
                <connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm"/>
                <connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
                <pooled-connection-factory name="activemq-ra" transaction="xa" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm"/>
            </server>
            <jms-bridge name="amq-wmq" max-batch-time="100" max-batch-size="10" max-retries="1" failure-retry-interval="500" quality-of-service="AT_MOST_ONCE" module="org.apache.activemq.artemis">
                <source destination="java:/jms/ivt/IVTQueueProxy" connection-factory="java:/ConnectionFactory"/>
                <target destination="jms/ivt/IVTQueueProxyWMQ" connection-factory="jms/ivt/IVTCF"/>
            </jms-bridge>
            <jms-bridge name="wmq-amq" max-batch-time="100" max-batch-size="10" max-retries="1" failure-retry-interval="500" quality-of-service="AT_MOST_ONCE" module="org.apache.activemq.artemis">
                <source destination="jms/ivt/IVTQueueProxyWMQReply" connection-factory="jms/ivt/IVTCF"/>
                <target destination="java:/jms/ivt/IVTQueueProxyReply" connection-factory="java:/ConnectionFactory"/>
            </jms-bridge>
        </subsystem>
{code}
and JCA for WMQ 
{code:xml}
<subsystem xmlns="urn:jboss:domain:resource-adapters:4.0">
            <resource-adapters>
                <resource-adapter id="wmq.jmsra.rar" statistics-enabled="true">
                    <archive>
                        wmq.jmsra.rar
                    </archive>
                    <transaction-support>LocalTransaction</transaction-support>
                    <connection-definitions>
                        <connection-definition class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" jndi-name="jms/ivt/IVTCF" use-java-context="false" pool-name="IVTCF">
                            <config-property name="hostName">
                                ${websphere.hostName:localhost}
                            </config-property>
                            <config-property name="password">
                                ${websphere.password:mqm}
                            </config-property>
                            <config-property name="queueManager">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                            <config-property name="port">
                                ${websphere.port:1414}
                            </config-property>
                            <config-property name="channel">
                                ${websphere.channel:SYSTEM.AUTO.SVRCONN}
                            </config-property>
                            <config-property name="transportType">
                                ${websphere.transportType:CLIENT}
                            </config-property>
                            <config-property name="username">
                                ${websphere.username:mqm}
                            </config-property>
                        </connection-definition>
                        <connection-definition class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" jndi-name="JMS2CF" use-java-context="false" pool-name="JMS2CF">
                            <config-property name="hostName">
                                ${websphere.hostName:localhost}
                            </config-property>
                            <config-property name="password">
                                ${websphere.password:mqm}
                            </config-property>
                            <config-property name="queueManager">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                            <config-property name="port">
                                ${websphere.port:1414}
                            </config-property>
                            <config-property name="channel">
                                ${websphere.channel:SYSTEM.AUTO.SVRCONN}
                            </config-property>
                            <config-property name="transportType">
                                ${websphere.transportType:CLIENT}
                            </config-property>
                            <config-property name="username">
                                ${websphere.username:mqm}
                            </config-property>
                        </connection-definition>
                    </connection-definitions>
                    <admin-objects>
                        <admin-object class-name="com.ibm.mq.connector.outbound.MQQueueProxy" jndi-name="jms/ivt/IVTQueueProxyWMQ" enabled="true" use-java-context="false" pool-name="QueuePool">
                            <config-property name="baseQueueName">
                                ${websphere.queueName:Q_QUEUE}
                            </config-property>
                            <config-property name="baseQueueManagerName">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                        </admin-object>
                        <admin-object class-name="com.ibm.mq.connector.outbound.MQQueueProxy" jndi-name="jms/ivt/IVTQueueProxyWMQReply" enabled="true" use-java-context="false" pool-name="QueuePoolReply">
                            <config-property name="baseQueueName">
                                ${websphere.queueName:Q_QUEUE}
                            </config-property>
                            <config-property name="baseQueueManagerName">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                        </admin-object>
                    </admin-objects>
                </resource-adapter>
            </resource-adapters>
        </subsystem>
{code}
where can I find I cannot use JCA provider for JMS bridge ?  


was (Author: gautric):
Hi ,

thanks for your reply, 
Indeed I am using JMS bridge to connect Artemis <--> websphereMQ.
here is messaging subsystem :
<subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
            <server name="default">
                <security-setting name="#">
                    <role name="guest" delete-non-durable-queue="true" create-non-durable-queue="true" consume="true" send="true"/>
                </security-setting>
                <address-setting name="#" message-counter-history-day-limit="10" page-size-bytes="2097152" max-size-bytes="10485760" expiry-address="jms.queue.ExpiryQueue" dead-letter-address="jms.queue.DLQ"/>
                <http-connector name="http-connector" endpoint="http-acceptor" socket-binding="http"/>
                <http-connector name="http-connector-throughput" endpoint="http-acceptor-throughput" socket-binding="http">
                    <param name="batch-delay" value="50"/>
                </http-connector>
                <in-vm-connector name="in-vm" server-id="0"/>
                <http-acceptor name="http-acceptor" http-listener="default"/>
                <http-acceptor name="http-acceptor-throughput" http-listener="default">
                    <param name="batch-delay" value="50"/>
                    <param name="direct-deliver" value="false"/>
                </http-acceptor>
                <in-vm-acceptor name="in-vm" server-id="0"/>
                <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
                <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
                <jms-queue name="IVTQueueProxy" entries="java:/jms/ivt/IVTQueueProxy java:jboss/exported/jms/ivt/IVTQueueProxy"/>
                <jms-queue name="IVTQueueProxyReply" entries="java:/jms/ivt/IVTQueueProxyReply java:jboss/exported/jms/ivt/IVTQueueProxyReply"/>
                <connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm"/>
                <connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
                <pooled-connection-factory name="activemq-ra" transaction="xa" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm"/>
            </server>
            <jms-bridge name="amq-wmq" max-batch-time="100" max-batch-size="10" max-retries="1" failure-retry-interval="500" quality-of-service="AT_MOST_ONCE" module="org.apache.activemq.artemis">
                <source destination="java:/jms/ivt/IVTQueueProxy" connection-factory="java:/ConnectionFactory"/>
                <target destination="jms/ivt/IVTQueueProxyWMQ" connection-factory="jms/ivt/IVTCF"/>
            </jms-bridge>
            <jms-bridge name="wmq-amq" max-batch-time="100" max-batch-size="10" max-retries="1" failure-retry-interval="500" quality-of-service="AT_MOST_ONCE" module="org.apache.activemq.artemis">
                <source destination="jms/ivt/IVTQueueProxyWMQReply" connection-factory="jms/ivt/IVTCF"/>
                <target destination="java:/jms/ivt/IVTQueueProxyReply" connection-factory="java:/ConnectionFactory"/>
            </jms-bridge>
        </subsystem>


and JCA for WMQ 

<subsystem xmlns="urn:jboss:domain:resource-adapters:4.0">
            <resource-adapters>
                <resource-adapter id="wmq.jmsra.rar" statistics-enabled="true">
                    <archive>
                        wmq.jmsra.rar
                    </archive>
                    <transaction-support>LocalTransaction</transaction-support>
                    <connection-definitions>
                        <connection-definition class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" jndi-name="jms/ivt/IVTCF" use-java-context="false" pool-name="IVTCF">
                            <config-property name="hostName">
                                ${websphere.hostName:localhost}
                            </config-property>
                            <config-property name="password">
                                ${websphere.password:mqm}
                            </config-property>
                            <config-property name="queueManager">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                            <config-property name="port">
                                ${websphere.port:1414}
                            </config-property>
                            <config-property name="channel">
                                ${websphere.channel:SYSTEM.AUTO.SVRCONN}
                            </config-property>
                            <config-property name="transportType">
                                ${websphere.transportType:CLIENT}
                            </config-property>
                            <config-property name="username">
                                ${websphere.username:mqm}
                            </config-property>
                        </connection-definition>
                        <connection-definition class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" jndi-name="JMS2CF" use-java-context="false" pool-name="JMS2CF">
                            <config-property name="hostName">
                                ${websphere.hostName:localhost}
                            </config-property>
                            <config-property name="password">
                                ${websphere.password:mqm}
                            </config-property>
                            <config-property name="queueManager">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                            <config-property name="port">
                                ${websphere.port:1414}
                            </config-property>
                            <config-property name="channel">
                                ${websphere.channel:SYSTEM.AUTO.SVRCONN}
                            </config-property>
                            <config-property name="transportType">
                                ${websphere.transportType:CLIENT}
                            </config-property>
                            <config-property name="username">
                                ${websphere.username:mqm}
                            </config-property>
                        </connection-definition>
                    </connection-definitions>
                    <admin-objects>
                        <admin-object class-name="com.ibm.mq.connector.outbound.MQQueueProxy" jndi-name="jms/ivt/IVTQueueProxyWMQ" enabled="true" use-java-context="false" pool-name="QueuePool">
                            <config-property name="baseQueueName">
                                ${websphere.queueName:Q_QUEUE}
                            </config-property>
                            <config-property name="baseQueueManagerName">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                        </admin-object>
                        <admin-object class-name="com.ibm.mq.connector.outbound.MQQueueProxy" jndi-name="jms/ivt/IVTQueueProxyWMQReply" enabled="true" use-java-context="false" pool-name="QueuePoolReply">
                            <config-property name="baseQueueName">
                                ${websphere.queueName:Q_QUEUE}
                            </config-property>
                            <config-property name="baseQueueManagerName">
                                ${websphere.queueManager:QUEUE.MANAGER}
                            </config-property>
                        </admin-object>
                    </admin-objects>
                </resource-adapter>
            </resource-adapters>
        </subsystem>

where can I find I cannot use JCA provider for JMS bridge ?  

> Cannot call conn.setExceptionListener due Java EE7 JMS spec, inside Wildfly 10.x
> --------------------------------------------------------------------------------
>
>                 Key: ARTEMIS-1032
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-1032
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 1.5.3, 2.0.0
>         Environment: Wildfly 10.x/ JBoss EAP 7.x
>            Reporter: Greg A.
>            Assignee: Justin Bertram
>
> conn.setExceptionListener "must not be used in a Java EE web or EJB application. Doing so may cause a JMSException to be thrown though this is not guaranteed." from JMS spec 
> https://github.com/apache/activemq-artemis/blob/1.5.4/artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java#L1013



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)