mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550473 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
2256ec03b4
commit
702b13be27
|
@ -402,7 +402,7 @@ public class MessageServlet extends MessageServletSupport {
|
|||
/*
|
||||
* Listen for available messages and wakeup any continuations.
|
||||
*/
|
||||
private class Listener implements MessageAvailableListener {
|
||||
private static class Listener implements MessageAvailableListener {
|
||||
MessageConsumer consumer;
|
||||
Continuation continuation;
|
||||
List queue = new LinkedList();
|
||||
|
|
|
@ -56,11 +56,11 @@ public class PortfolioPublishServlet extends MessageServletSupport {
|
|||
else {
|
||||
Integer total=(Integer)request.getSession(true).getAttribute("total");
|
||||
if (total==null)
|
||||
total=new Integer(0);
|
||||
total=Integer.valueOf(0);
|
||||
|
||||
|
||||
int count = getNumberOfMessages(request);
|
||||
total=new Integer(total.intValue()+count);
|
||||
total=Integer.valueOf(total.intValue()+count);
|
||||
request.getSession().setAttribute("total",total);
|
||||
|
||||
try {
|
||||
|
|
Loading…
Reference in New Issue