Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of mohitanchlia@gmail.com
 designates 209.85.210.174 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAKS7T5OPYspvKoEyv2L0eEF1d31=D8RnEBKja=5_md-1C3VOwA@mail.gmail.com>
References: 
 <CAOT3TWoi_4PD81zzej6HZq4JChj8BbaSpapPdS9qTU3Ks2n=jA@mail.gmail.com>
	<CAKS7T5OPYspvKoEyv2L0eEF1d31=D8RnEBKja=5_md-1C3VOwA@mail.gmail.com>
Date: Wed, 30 Jan 2013 17:58:07 -0800
Message-ID: 
 <CAOT3TWqZhbzfPtinAaiD=s_B7prq03vn=5O7CLFryDmbFe7XUw@mail.gmail.com>
Subject: Re: EOFException
From: Mohit Anchlia <mohitanchlia@gmail.com>
To: users@activemq.apache.org
Content-Type: multipart/alternative; boundary=bcaec517c69050780c04d48bf50b

--bcaec517c69050780c04d48bf50b
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

Thanks for looking:

failover:(tcp://
daamq300.ie.i.net:61616?connectionTimeout=3D10000&soTimeout=3D8000&wireForm=
at.tcpNoDelayEnabled=3Dtrue,tcp://daamq304.ie.i.net:61616?connectionTimeout=
=3D10000&soTimeout=3D8000&wireFormat.tcpNoDelayEnabled=3Dtrue,tcp://daamq30=
5.ie.i.net:61616?connectionTimeout=3D10000&soTimeout=3D8000&wireFormat.tcpN=
oDelayEnabled=3Dtrue,tcp://daamq306.ie.i.net:61616?connectionTimeout=3D1000=
0&soTimeout=3D8000&wireFormat.tcpNoDelayEnabled=3Dtrue)?randomize=3Dtrue&jm=
s.prefetchPolicy.all=3D1

<beans
  xmlns=3D"http://www.springframework.org/schema/beans"
  xmlns:amq=3D"http://activemq.apache.org/schema/core"
  xmlns:xsi=3D"http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation=3D"http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
  http://activemq.apache.org/camel/schema/spring
http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">

    <!-- Allows us to use system properties as variables in this
configuration file -->
    <bean
class=3D"org.springframework.beans.factory.config.PropertyPlaceholderConfig=
urer"/>

    <broker xmlns=3D"http://activemq.apache.org/schema/core" brokerName=3D"
daamq305.ie.i.net" persistent=3D"true" dataDirectory=3D"${activemq.data}">

        <!-- Destination specific policies using destination names or
wildcards -->
        <destinationPolicy>
            <policyMap>
                <policyEntries>
                    <policyEntry queue=3D">" producerFlowControl=3D"true"
memoryLimit=3D"500mb" optimizedDispatch=3D"true" useCache=3D"false">
                        <deadLetterStrategy>
                          <individualDeadLetterStrategy queuePrefix=3D"DLQ.=
"
useQueueForQueueMessages=3D"true" />
                        </deadLetterStrategy>
                    </policyEntry>
                    <policyEntry topic=3D">" producerFlowControl=3D"true"
memoryLimit=3D"500mb">
                    </policyEntry>
                </policyEntries>
            </policyMap>
        </destinationPolicy>

        <!-- Use the following to configure how ActiveMQ is exposed in JMX
-->
        <managementContext>
            <managementContext createConnector=3D"true"/>
        </managementContext>

        <!--
            The store and forward broker networks ActiveMQ will listen to.
            We'll leave it empty as duplex network will be configured by
another broker
            Take a look at activemq-static_network-broker2.xml for example
        -->
        <networkConnectors>
            <networkConnector uri=3D"static:(tcp://daamq300.ie.i.net:61616
,tcp://daamq304.ie.i.net:61616,tcp://daamq306.ie.i.net:61616)"
prefetchSize=3D"1" conduitSubscriptions=3D"true" networkTTL=3D"3"/>
        </networkConnectors>

        <persistenceAdapter>
            <kahaDB directory=3D"${activemq.data}/daamq305.ie.i.net/kahadb"
enableJournalDiskSyncs=3D"false" indexWriteBatchSize=3D"10000"
indexCacheSize=3D"1000" journalMaxFileLength=3D"200 gb"/>
        </persistenceAdapter>

        <!--  The maximum amount of space the broker will use before
slowing down producers -->
        <systemUsage>
            <systemUsage>
                <memoryUsage>
                    <memoryUsage limit=3D"600 mb"/>
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit=3D"240 gb" name=3D"foo"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit=3D"1000 mb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

        <!-- The transport connectors ActiveMQ will listen to -->
        <transportConnectors>
            <transportConnector name=3D"openwire" uri=3D"nio://0.0.0.0:6161=
6"
               enableStatusMonitor=3D"true"/>
        </transportConnectors>

    </broker>

    <!--
        Enable web consoles, REST and Ajax APIs and demos

        Take a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details
    -->
    <import resource=3D"jetty.xml"/>

</beans>


On Wed, Jan 30, 2013 at 4:15 PM, Christian Posta
<christian.posta@gmail.com>wrote:

> Please post your broker config and what URL you're using on the client
> side. EOFException in the broker logs usually means the client didn't
> disconnect properly
>
>
> On Wed, Jan 30, 2013 at 5:11 PM, Mohit Anchlia <mohitanchlia@gmail.com
> >wrote:
>
> > With nio we often see this error even though all MQ servers are up and
> > running. We are using 5.7.0. Client then hangs and failover never
> > reconnects.
> >
> > WARN  transport.failover.FailoverTransport [ActiveMQ Transport:
>  Transport
> > (tcp://100.145.3.166:61616) failed, reason:  java.io.EOFException,
> > attempting to automatically reconnect
> >
> > Right after this error I check on netstat and I see TIMED_WAIT as if th=
e
> > connection was killed. And after that mq client never reconnects. Is th=
is
> > some issue that has been experienced before and the second problem is
> that
> > failover doesn't seem to be working
> >
>
>
>
> --
> *Christian Posta*
> http://www.christianposta.com/blog
> twitter: @christianposta
>

--bcaec517c69050780c04d48bf50b--