This closes #1016
This commit is contained in:
commit
cdc974e71e
|
@ -443,8 +443,10 @@ public class AMQPSessionCallback implements SessionCallback {
|
||||||
final Receiver receiver) {
|
final Receiver receiver) {
|
||||||
try {
|
try {
|
||||||
if (address == null) {
|
if (address == null) {
|
||||||
receiver.flow(credits);
|
synchronized (connection.getLock()) {
|
||||||
connection.flush();
|
receiver.flow(credits);
|
||||||
|
connection.flush();
|
||||||
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
final PagingStore store = manager.getServer().getPagingManager().getPageStore(new SimpleString(address));
|
final PagingStore store = manager.getServer().getPagingManager().getPageStore(new SimpleString(address));
|
||||||
|
|
Loading…
Reference in New Issue