activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eric-AWL <eric.vinc...@atosorigin.com>
Subject Re: "Embedded broker", "network of brokers" and "temporary queues"
Date Tue, 29 Jan 2008 16:49:12 GMT

Hi ttmdev

You will find in the other answer to your question the elements you ask me.
I know that all these messages can confuse you

I continued my tests by making a duplex networkConnector between the client
process and the two servers process.
In the activemq_clt.xml

    <!-- The store and forward broker networks ActiveMQ will listen to -->
    <networkConnectors>
      <networkConnector name="pool"
uri="static:(tcp://ytsvmx02s:61617,tcp://ytsvmx01s:61617)"
                conduitSubscriptions="false"
                dynamicOnly="true"
                networkTTL="3"
                duplex="true"/>
    </networkConnectors>

in the two activemq_srv.xml, I deleted this section.


Things seem to be better. My test doesn't go to the end, but I think I am
blocked by a "1000 limit".
When I put "DEBUG" in the log4j configuration, the last line in logfile
before blocking is

DEBUG ActiveMQMessageConsumer        -
ID:ytsvmx01s-34585-1201623607945-4:1:278:1 received message: MessageDispatch
{commandId = 7775, responseRequired = false, consumerId =
ID:ytsvmx01s-34585-1201623607945-4:1:278:1, destination =
temp-queue://ID:ytsvmx01s-34585-1201623607945-4:1:277, message =
ActiveMQTextMessage {commandId = 3187, responseRequired = false, messageId =
ID:ytsvmx02s-48347-1201622976927-2:1:2:1000:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:ytsvmx02s-48347-1201622976927-5:0:1:1, destination =
temp-queue://ID:ytsvmx01s-34585-1201623607945-4:1:277, transactionId = null,
expiration = 0, timestamp = 1201623084328, arrival = 0, brokerInTime =
1201623706101, brokerOutTime = 1201623706102, correlationId = null, replyTo
= null, persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = org.apache.activemq.util.ByteSequence@2c6f70,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 8223, properties = null, readOnlyProperties = true, readOnlyBody =
true, droppable = false, text = null}, redeliveryCounter = 0}

DEBUG ActiveMQMessageConsumer        -
ID:ytsvmx01s-34585-1201623607945-4:1:266:1 received message: MessageDispatch
{commandId = 7847, responseRequired = false, consumerId =
ID:ytsvmx01s-34585-1201623607945-4:1:266:1, destination =
temp-queue://ID:ytsvmx01s-34585-1201623607945-4:1:265, message =
ActiveMQTextMessage {commandId = 3198, responseRequired = false, messageId =
ID:ytsvmx01s-46060-1201623597671-2:1:2:1000:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:ytsvmx01s-46060-1201623597671-5:0:1:1, destination =
temp-queue://ID:ytsvmx01s-34585-1201623607945-4:1:265, transactionId = null,
expiration = 0, timestamp = 1201623706275, arrival = 0, brokerInTime =
1201623706280, brokerOutTime = 1201623706280, correlationId = null, replyTo
= null, persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false, userID =
null, content = org.apache.activemq.util.ByteSequence@7946a2,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 8222, properties = null, readOnlyProperties = true, readOnlyBody =
true, droppable = false, text = null}, redeliveryCounter = 0}


My test is blocked and I never received message with a messageId of 
ID:ytsvmx01s-46060-1201623597671-2:1:2:1001:1

I try to acknowledge messages. I tried to increase prefetch limit ...

Excuse-me if all these different tests confuse you. The other message is
with "half-duplex" configuration, and things are not the same with this
"full-duplex" configuration

Eric-AWL
-- 
View this message in context: http://www.nabble.com/%22Embedded-broker%22%2C-%22network-of-brokers%22-and-%22temporary-queues%22-tp15023996s2354p15163609.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message