[
https://issues.apache.org/jira/browse/QPIDJMS-273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15924045#comment-15924045
]
Rob Godfrey commented on QPIDJMS-273:
-------------------------------------
I think the number sent (to a 6.1.1 Java Broker) will always be of the form
2048 + N*1024, and the exact number will depend on how quickly the messages are
accepted by the broker vs. how quickly the client gets through the sending
loop. I was running my tests over loopback on my Mac... I guess the speed of
the SSD in my laptop vs. the speed of the CPU is such that it can stuff the
messages to disk fast enough that by the time the client application thread has
looped through 10000 messages, the broker has put >= 4096 messages to disk.
I think you may find that if you send a sufficient number of non-persistent
messages you may also run into this same problem.
BTW I have raised https://issues.apache.org/jira/browse/QPID-7708 to allow the
session credit limit in the Java Broker to be configurable, not that this would
actually solve the problem here.
> Unable to send more than 2048 messages (async + persistent)
> -----------------------------------------------------------
>
> Key: QPIDJMS-273
> URL: https://issues.apache.org/jira/browse/QPIDJMS-273
> Project: Qpid JMS
> Issue Type: Bug
> Components: qpid-jms-client
> Reporter: Antonin Vyborny
> Priority: Minor
>
> When I use jms.forceAsyncSend=True flag along with DeliveryMode.PERSISTENT I
> am unable to receive more than 2048 messages in the queue. I am not receiving
> any warning/error so from client it looks like all messages are sent, but
> only 2048 messages are actually found in the queue.
> There is unfortunately nothing in the log either.
> Steps to reproduce:
> 1) Use the Sender example (org.apache.qpid.jms.example.Sender)
> 2) Set the following in Sender class:
> private static final int DEFAULT_COUNT = 3000;
> private static final int DELIVERY_MODE = DeliveryMode.PERSISTENT;
> 3) Set async sending in jndi.properties:
> amqp://localhost:5672?jms.forceAsyncSend=True
> 4) run the example...
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
