[jira] [Updated] (PROTON-520) Unable to send messages to more than 256 queues

["Marcin Salata (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/PROTON-520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Marcin Salata updated PROTON-520:
---------------------------------

    Description: 
It is unable to send messages to more than 256 queues from one messenger.

Example code:

Messenger mng = new MessengerImpl();
mng.start();

for (int i = 0; i < 300; i++) {
    Message message = new MessageImpl();
    String address = "amqp://localhost:5672/queue://receiver";
    message.setAddress(address+i);
    message.setBody(new AmqpValue("test message"));                   
    mng.put(message);
}        

mng.send();
mng.stop();

Proton will send messages to 256 queues and hangs.
When sending messages to less than 256 queues eveyrhing is ok.
The same situation occurs using Proton non blocking mode.

  was:
It is unable to send messages to more then 256 queues from one messenger.

Example code:

Messenger mng = new MessengerImpl();
mng.start();

for (int i = 0; i < 300; i++) {
    Message message = new MessageImpl();
    String address = "amqp://localhost:5672/queue://receiver";
    message.setAddress(address+i);
    message.setBody(new AmqpValue("test message"));                   
    mng.put(message);
}        

mng.send();
mng.stop();

Proton will send messages to 256 queues and hangs.
When sending messages to less than 256 queues eveyrhing is ok.
The same situation occurs using Proton non blocking mode.


> Unable to send messages to more than 256 queues
> -----------------------------------------------
>
>                 Key: PROTON-520
>                 URL: https://issues.apache.org/jira/browse/PROTON-520
>             Project: Qpid Proton
>          Issue Type: Bug
>          Components: proton-j
>    Affects Versions: 0.6
>         Environment: Tested with:
> Qpid Proton 0.6
> ActiveMQ 5.9.0 and ActiveMQ 5.1.0 leatest snapshot
>            Reporter: Marcin Salata
>              Labels: proton-j
>
> It is unable to send messages to more than 256 queues from one messenger.
> Example code:
> Messenger mng = new MessengerImpl();
> mng.start();
> for (int i = 0; i < 300; i++) {
>     Message message = new MessageImpl();
>     String address = "amqp://localhost:5672/queue://receiver";
>     message.setAddress(address+i);
>     message.setBody(new AmqpValue("test message"));                   
>     mng.put(message);
> }        
> mng.send();
> mng.stop();
> Proton will send messages to 256 queues and hangs.
> When sending messages to less than 256 queues eveyrhing is ok.
> The same situation occurs using Proton non blocking mode.



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)