executor, null);
executor);
   public synchronized void startService() throws Exception   {      super.startService();            try      {         postOffice = serverPeer.getTopicPostOfficeInstance();                  destination.setPostOffice(postOffice);                    // We deploy any queues corresponding to pre-existing durable subscriptions         List bindings = postOffice.listBindingsForCondition(destination.getName());         Iterator iter = bindings.iterator();         while (iter.hasNext())         {            Binding binding = (Binding)iter.next();            if (binding.isActive())            {               //Do nothing - already active            }            else            {               QueuedExecutorPool pool = serverPeer.getQueuedExecutorPool();               QueuedExecutor executor = (QueuedExecutor)pool.get();               org.jboss.messaging.core.local.Queue q =                   new org.jboss.messaging.core.local.Queue(binding.getChannelId(), ms, pm, true, true,                           destination.getFullSize(), destination.getPageSize(), destination.getDownCacheSize(),                           executor, null);               q.load();               binding.setQueue(q);               binding.activate();            }         }         // push security update to the server         sm.setSecurityConfig(isQueue(), destination.getName(), destination.getSecurityConfig());                            dm.registerDestination(destination);                  log.debug(this + " security configuration: " + (destination.getSecurityConfig() == null ?            "null" : "\n" + XMLUtil.elementToString(destination.getSecurityConfig())));                  started = true;         log.info(this + " started, fullSize=" + destination.getFullSize() + ", pageSize=" + destination.getPageSize() + ", downCacheSize=" + destination.getDownCacheSize());      }      catch (Throwable t)      {         ExceptionUtil.handleJMXInvocation(t, this + " startService");      }   }