diff options
| author | Keith Wall <kwall@apache.org> | 2015-02-12 15:18:16 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2015-02-12 15:18:16 +0000 |
| commit | e243745d439671418016a2be1570209269b45070 (patch) | |
| tree | 7f17111b385b7759869e2e5594e591979097cc6f /qpid/java/broker-core/src | |
| parent | 825aceb7e885c793309557a3a886f10c475c4c1c (diff) | |
| download | qpid-python-e243745d439671418016a2be1570209269b45070.tar.gz | |
0-10 queue browser fix.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659288 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-core/src')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java | 1 | ||||
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java | 11 |
2 files changed, 11 insertions, 1 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java index 4fb89575aa..450d4d98d5 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueConsumerImpl.java @@ -316,6 +316,7 @@ class QueueConsumerImpl public final void flush() { _queue.flushConsumer(this); + _target.processPending(); } public boolean resend(final QueueEntry entry) diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java index 786f1915a7..cc5ee71cf5 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/SelectorThread.java @@ -286,7 +286,16 @@ public class SelectorThread extends Thread @Override public void run() { - processConnection(connection); + String currentName = Thread.currentThread().getName(); + try + { + Thread.currentThread().setName("NCS-"+connection.getRemoteAddress().toString()); + processConnection(connection); + } + finally + { + Thread.currentThread().setName(currentName); + } } }); } |