[ 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)