<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<html>
<body link="#355491" alink="#4262a1" vlink="#355491" style="background: #e2e2e2; margin: 0; padding: 20px;">
<div>
<table cellpadding="0" bgcolor="#FFFFFF" border="0" cellspacing="0" style="border: 1px solid #dadada; margin-bottom: 30px; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td>
<table border="0" cellpadding="0" cellspacing="0" bgcolor="#FFFFFF" style="border: solid 2px #ccc; background: #dadada; width: 100%; -moz-border-radius: 6px; -webkit-border-radius: 6px;">
<tbody>
<tr>
<td bgcolor="#000000" valign="middle" height="58px" style="border-bottom: 1px solid #ccc; padding: 20px; -moz-border-radius-topleft: 3px; -moz-border-radius-topright: 3px; -webkit-border-top-right-radius: 5px; -webkit-border-top-left-radius: 5px;">
<h1 style="color: #333333; font: bold 22px Arial, Helvetica, sans-serif; margin: 0; display: block !important;">
<!-- To have a header image/logo replace the name below with your img tag -->
<!-- Email clients will render the images when the message is read so any image -->
<!-- must be made available on a public server, so that all recipients can load the image. -->
<a href="http://community.jboss.org/index.jspa" style="text-decoration: none; color: #E1E1E1">JBoss Community</a></h1>
</td>
</tr>
<tr>
<td bgcolor="#FFFFFF" style="font: normal 12px Arial, Helvetica, sans-serif; color:#333333; padding: 20px; -moz-border-radius-bottomleft: 4px; -moz-border-radius-bottomright: 4px; -webkit-border-bottom-right-radius: 5px; -webkit-border-bottom-left-radius: 5px;"><h3 style="margin: 10px 0 5px; font-size: 17px; font-weight: normal;">
Re: close jms conection cause block
</h3>
<span style="margin-bottom: 10px;">
created by <a href="http://community.jboss.org/people/ivannushev">Ivan Nushev</a> in <i>JBoss Messaging</i> - <a href="http://community.jboss.org/message/610497#610497">View the full discussion</a>
</span>
<hr style="margin: 20px 0; border: none; background-color: #dadada; height: 1px;">
<div class="jive-rendered-content"><p>Hi all. I've fixed my blocking problem. I'm exposing below how I overcome it.</p><p>First of all, the blocking issue wasn't in JBoss Messaging itself, but in the way I used it. That's why I have to explain a bit more about my use case. Our business needs supposed to have multiple subscribers interesting in a set of business events. Events are fired when some business objects are modified. Then subscribers are notified about these changes and they take appropriate actions. These business needs were designed to be fulfilled as using a chain of JMS destinations. Business events are registered to the first JMS destination. Then a MDB consumes them and based on existing subscriptions decides whether to publish business messages to the second JMS destination (of type Topic because it has to notify multiple subscribers). That design was chosen in order to make processing of events to happen asynchronously from their generation and to eliminate delay when events are turned into business messages. Moreover publishing of business events and their consuming was put in distributed transaction management. </p><p>So the first JMS misuse was that the business event destination (the first one of the chain) was of type Queue. As JMS documentation states in case of chaining all destinations have to be of same type. The second design misuse was that both destinations don't know about each other: as JBoss Messaging examples exposes, in case of chaining the second destination have to be set as JMSReplyTo property to each message (this is not a proper JMS requirement and I suppose it is needed in order JBM to make appropriate synchronization of JMS resources). I turn the JMS Queue into JMS Topic because the second destination is to be Topic for our business needs. As its messages are consumed by a MDB, then a durable subscription has to be done for it. </p><p>There was a chance to have JMS resource leaking because I implemented JMS resource reusing inside SLSB-s responsible for JMS message publishing following the tutorial examples and that's why I remove that i.e. JMS resources are obtained and released for each call.</p><p>I have to mention our business needs requires to use HTTPS for transport protocol and that's why SSLServlet remoting transport was chosen for JMS. This circumstance added a lot complications to the service because that transport is unidirectional, initiated from clients to the server and not so reliable as the practice showed. I still haven't found reliable JMS configuration for SSLServlet transport which makes JMS MessageListener-s (subscribed to the second Topic in our case) to survive 'forever': I mean that somehow they stop receiving messages, their subscription is seen in jmx-console, but it is registered that some number of messages are not delivered (112 is the number of not delivered messages):</p><p>Topic,Subscription.ir5-t38dfnog-1-en8m8nog-76nur7-x305o4c5,-,false,0,0,117,117,- </p><p>I attach the configuration file asking for hints what settings could be wrong. Thanks.</p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p><mbean code="org.jboss.remoting.transport.Connector"</p><p>    name="jboss.remoting:service=connector,transport=sslservlet,target=jms,loc=public"</p><p>    display-name="JMS Public Servlet transport Connector"></p><p>    <attribute name="Configuration"></p><p>        <config></p><p>            <invoker transport="sslservlet"></p><p>                <!--</p><p>                    There should be no reason to change these parameters - warning!</p><p>                    Changing them may stop JBoss Messaging working correctly</p><p>                --></p><p>                <attribute name="marshaller" isParam="true">org.jboss.jms.wireformat.JMSWireFormat</attribute></p><p>                <attribute name="unmarshaller" isParam="true">org.jboss.jms.wireformat.JMSWireFormat</attribute></p><p>                <attribute name="dataType" isParam="true">jms</attribute></p><p>                <attribute name="serverBindAddress">${jboss.bind.address}</attribute></p><p>                <attribute name="serverBindPort">443</attribute></p><p>                <attribute name="clientConnectAddress">${public.firewall.address}</attribute></p><p>                <attribute name="clientConnectPort">443</attribute></p><p>                <attribute name="numberOfCallRetries" isParam="true">3</attribute></p><p>                <attribute name="pingFrequency" isParam="true">1200000</attribute></p><p>                <attribute name="pingWindowFactor" isParam="true">2</attribute></p><p>                <attribute name="onewayThreadPool">org.jboss.jms.server.remoting.DirectThreadPool</attribute></p><p>                <attribute name="callbackStore">org.jboss.remoting.callback.BlockingCallbackStore</attribute></p><p>                <attribute name="unwrapSingletonArrays">true</attribute></p><p>                <attribute name="path">unified-invoker/PublicJmsServerInvokerServlet</attribute></p><p>                <attribute name="return-exception">true</attribute></p><p>                <attribute name="createUniqueObjectName">true</attribute></p><p>                <attribute name="useAllParams" isParam="true">true</attribute></p><p>                <!-- End immutable parameters --></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                <attribute name="generalizeSocketException" isParam="true">true</attribute></p><p>                <attribute name="callbackErrorsAllowed">1</attribute></p><p>                <attribute name="stopLeaseOnFailure" isParam="true">true</attribute></p><p>                <attribute name="socketTimeout" isParam="true">120000</attribute></p><p>                <attribute name="writeTimeout" isParam="true">30000</attribute></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                <attribute name="callbackTimeout" isParam="true">10000</attribute></p><p>                <attribute name="JBM_clientMaxPoolSize" isParam="true">200</attribute></p><p>                <attribute name="maxPoolSize" isParam="true">300</attribute></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                <!--</p><p>                    Periodicity of client pings. Server window by default is twice this</p><p>                    figure</p><p>                --></p><p>                <attribute name="clientLeasePeriod" isParam="true">50000</attribute></p><p>                <attribute name="validatorPingPeriod" isParam="true">50000</attribute></p><p>                <attribute name="validatorPingTimeout" isParam="true">25000</attribute></p><p>                <attribute name="registerCallbackListener" isParam="true">true</attribute></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                <attribute name="timeout" isParam="true">3600000</attribute></p><p>                <attribute name="continueAfterTimeout" isParam="true">false</attribute></p><p>                <!--</p><p>                    Set this to true if you want the servlet transport to block waiting</p><p>                    for server->client traffic. Or false if you want it to poll for new</p><p>                    traffic periodically. Recommended is blocking</p><p>                --></p><p>                <attribute name="blockingMode" isParam="true">blocking</attribute></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                <!--</p><p>                    Timeout for blocking. Only has relevance if blockingMode = blocking</p><p>                --></p><p>                <attribute name="blockingTimeout" isParam="true">30000</attribute></p><p style="min-height: 8pt; height: 8pt; padding: 0px;"> </p><p>                <!--</p><p>                    The periodicity of polling. Only has relevance if blockingMode =</p><p>                    nonblocking</p><p>                --></p><p>                <!--</p><p>                    attribute name="callbackPollPeriod" isParam="true">10000</attribute</p><p>                --></p><p>            </invoker></p><p>            <handlers></p><p>                <handler subsystem="JMS">org.jboss.jms.server.remoting.JMSServerInvocationHandler</handler></p><p>            </handlers></p><p>        </config></p><p>    </attribute></p><p></mbean></p></div>
<div style="background-color: #f4f4f4; padding: 10px; margin-top: 20px;">
<p style="margin: 0;">Reply to this message by <a href="http://community.jboss.org/message/610497#610497">going to Community</a></p>
<p style="margin: 0;">Start a new discussion in JBoss Messaging at <a href="http://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2042">Community</a></p>
</div></td>
</tr>
</tbody>
</table>
</td>
</tr>
</tbody>
</table>
</div>
</body>
</html>