You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomee.apache.org by Jean-Louis MONTEIRO <je...@gmail.com> on 2012/11/15 10:09:07 UTC

Re: svn commit: r1409700 - /openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java

Andy,

can you fill a JIRA please?
That's an important information to share on release notes I think.

Jean-Louis


2012/11/15 <an...@apache.org>

> Author: andygumbrecht
> Date: Thu Nov 15 09:06:27 2012
> New Revision: 1409700
>
> URL: http://svn.apache.org/viewvc?rev=1409700&view=rev
> Log:
> Now we hold the broker instance it is up to us to 'stop' it ;-)
>
> Modified:
>
> openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java
>
> Modified:
> openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java
> URL:
> http://svn.apache.org/viewvc/openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java?rev=1409700&r1=1409699&r2=1409700&view=diff
>
> ==============================================================================
> ---
> openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java
> (original)
> +++
> openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java
> Thu Nov 15 09:06:27 2012
> @@ -121,9 +121,9 @@ public class ActiveMQResourceAdapter ext
>          ActiveMQFactory.setThreadProperties(properties);
>
>          try {
> -
> +            //The returned broker should be started, but calling start is
> harmless.
> +            //We do not need to track the instance as the factory takes
> care of this.
>
>  ActiveMQFactory.createBroker(URI.create(getBrokerXmlConfig())).start();
> -            //super.start(bootstrapContext);
>          } catch (Exception e) {
>
>  org.apache.openejb.util.Logger.getInstance(LogCategory.OPENEJB_STARTUP,
> ActiveMQResourceAdapter.class).getChildLogger("service").fatal("Failed to
> start ActiveMQ", e);
>          } finally {
> @@ -191,8 +191,12 @@ public class ActiveMQResourceAdapter ext
>          final Iterator<BrokerService> it = brokers.iterator();
>
>          while (it.hasNext()) {
> +
> +            final BrokerService bs = it.next();
> +
>              try {
> -                it.next().waitUntilStopped();
> +                bs.stop();
> +                bs.waitUntilStopped();
>              } catch (Throwable t) {
>                  //Ignore
>              }
>
>
>


-- 
Jean-Louis

Re: svn commit: r1409700 - /openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java

Posted by Jean-Louis MONTEIRO <je...@gmail.com>.
Thanks you Andy, I will update commit logs.
It will also appear in release notes.

Thanks
JLouis


2012/11/16 AndyG <an...@orprovision.com>

> Done.
>
> https://issues.apache.org/jira/browse/OPENEJB-1938
>
> Andy.
>
>
>
> --
> View this message in context:
> http://openejb.979440.n4.nabble.com/Re-svn-commit-r1409700-openejb-trunk-openejb-container-openejb-core-src-main-java-org-apache-openejba-tp4658619p4658638.html
> Sent from the OpenEJB Dev mailing list archive at Nabble.com.
>



-- 
Jean-Louis

Re: svn commit: r1409700 - /openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/ActiveMQResourceAdapter.java

Posted by AndyG <an...@orprovision.com>.
Done.

https://issues.apache.org/jira/browse/OPENEJB-1938

Andy.



--
View this message in context: http://openejb.979440.n4.nabble.com/Re-svn-commit-r1409700-openejb-trunk-openejb-container-openejb-core-src-main-java-org-apache-openejba-tp4658619p4658638.html
Sent from the OpenEJB Dev mailing list archive at Nabble.com.