GatewaySenderMBean extends NotificationBroadcasterSupport implements GatewaySenderMXBean { @Override public void startWithCleanQueue() { bridge.startWithCleanQueue(); } GatewaySenderMBean(GatewaySenderMBeanBridge bridge); @Override int getAlertThreshold(); @Override long getAverageDistributionTimePerBatch(); @Override int getBatchSize(); @Override long getBatchTimeInterval(); @Override float getBatchesDispatchedRate(); @Override String getOverflowDiskStoreName(); @Override int getEventQueueSize(); @Override float getEventsQueuedRate(); @Override float getEventsReceivedRate(); @Override float getLRUEvictionsRate(); @Override long getEntriesOverflowedToDisk(); @Override long getBytesOverflowedToDisk(); @Override String[] getGatewayEventFilters(); @Override String[] getGatewayTransportFilters(); @Override int getMaximumQueueMemory(); @Override int getRemoteDSId(); @Override String getSenderId(); @Override int getSocketBufferSize(); @Override long getSocketReadTimeout(); @Override int getTotalBatchesRedistributed(); @Override int getTotalEventsConflated(); @Override boolean isBatchConflationEnabled(); @Override boolean isManualStart(); @Override boolean isPaused(); @Override boolean isPersistenceEnabled(); @Override boolean isRunning(); @Override void pause(); @Override void resume(); @Override void start(); @Override void startWithCleanQueue(); @Override void stop(); @Override void rebalance(); @Override boolean isPrimary(); @Override int getDispatcherThreads(); @Override String getOrderPolicy(); @Override boolean isDiskSynchronous(); @Override boolean isParallel(); @Override boolean mustGroupTransactionEvents(); @Override String getGatewayReceiver(); GatewaySenderMBeanBridge getBridge(); void stopMonitor(); @Override boolean isConnected(); @Override int getEventsExceedingAlertThreshold();  }
@Test public void testStartWithCleanQueue() { bean.startWithCleanQueue(); verify(bridge).startWithCleanQueue(); }