Re: Socket Woes

[cronos]

Just ran another test with the following configuration (transport
connectors). The queue stats for
this test are as follows:

ConsumerCount > 1
DequeueCount > 15117
DispatchCount > 15118
EnqueueCount > 15118
QueueSize      > 1

--------------------------------------------------------------------------------


<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:amq="http://activemq.org/config/1.0";>

        <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"
/>

        <amq:broker brokerName="activemq" useJmx="true"
advisorySupport="false" persistent="false">
                <amq:destinationPolicy>
                        <amq:policyMap>
                                <amq:policyEntries>
                                        <amq:policyEntry queue=">">
                                                <amq:deadLetterStrategy>
                                                       
<amq:individualDeadLetterStrategy queuePrefix="DLQ."
useQueueForQueueMessages="true" />
                                                </amq:deadLetterStrategy>
                                        </amq:policyEntry>
                                </amq:policyEntries>
                        </amq:policyMap>
                </amq:destinationPolicy>

                <amq:managementContext>
                        <amq:managementContext rmiServerPort="8100" />
                </amq:managementContext>

                <amq:memoryManager>
                        <amq:usageManager limit="120 MB" />
                </amq:memoryManager>

                <amq:persistenceAdapter>
                        <amq:journaledJDBC>
                               
<dataDirectory>${java.io.tmpdir}/activemq</dataDirectory>
                                <journalLogFiles>2</journalLogFiles>
                        </amq:journaledJDBC>
                </amq:persistenceAdapter>

                <amq:transportConnectors>
                        <amq:transportConnector>
                               
<uri>tcp://localhost:61616?soTimeout=0;socketBufferSize=65536;trace=true;wireFormat.tcpNoDelayEnabled=true;wireFormat.maxInactivityDuration=0;</uri>
                        </amq:transportConnector>

                        <amq:transportConnector>
                               
<uri>stomp://localhost:51516?soTimeout=0;socketBufferSize=65536;trace=true;wireFormat.tcpNoDelayEnabled=true;wireFormat.maxInactivityDuration=0;</uri>
                        </amq:transportConnector>
                </amq:transportConnectors>
        </amq:broker>

</beans>


-- 
View this message in context: 
http://www.nabble.com/Socket-Woes-tf4214291s2354.html#a11993323
Sent from the ActiveMQ - User mailing list archive at Nabble.com.