com.rabbitmq.perf

Class MulticastSet

java.lang.Object

com.rabbitmq.perf.MulticastSet

public class MulticastSet
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MulticastSet.CompletionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_CONSUMER_WORK_SERVICE_THREAD_POOL_SIZE

Constructor Summary

Constructors

Constructor and Description
MulticastSet(PerformanceMetrics performanceMetrics, com.rabbitmq.client.ConnectionFactory factory, MulticastParams params, java.util.List<java.lang.String> uris, MulticastSet.CompletionHandler completionHandler)
MulticastSet(PerformanceMetrics performanceMetrics, com.rabbitmq.client.ConnectionFactory factory, MulticastParams params, java.lang.String testID, java.util.List<java.lang.String> uris, MulticastSet.CompletionHandler completionHandler)
MulticastSet(PerformanceMetrics performanceMetrics, com.rabbitmq.client.ConnectionFactory factory, MulticastParams params, java.lang.String testID, java.util.List<java.lang.String> uris, MulticastSet.CompletionHandler completionHandler, ShutdownService shutdownService, com.rabbitmq.perf.ExpectedMetrics expectedMetrics)

Method Summary

Modifier and Type	Method and Description
protected static int	nbThreadsForConsumer(MulticastParams params)
protected static int	nbThreadsForProducerScheduledExecutorService(MulticastParams params)
void	run()
void	run(boolean announceStartup)
void	setThreadingHandler(com.rabbitmq.perf.MulticastSet.ThreadingHandler threadingHandler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_CONSUMER_WORK_SERVICE_THREAD_POOL_SIZE

public static final int DEFAULT_CONSUMER_WORK_SERVICE_THREAD_POOL_SIZE

Constructor Detail

MulticastSet

public MulticastSet(PerformanceMetrics performanceMetrics,
                    com.rabbitmq.client.ConnectionFactory factory,
                    MulticastParams params,
                    java.util.List<java.lang.String> uris,
                    MulticastSet.CompletionHandler completionHandler)

MulticastSet

public MulticastSet(PerformanceMetrics performanceMetrics,
                    com.rabbitmq.client.ConnectionFactory factory,
                    MulticastParams params,
                    java.lang.String testID,
                    java.util.List<java.lang.String> uris,
                    MulticastSet.CompletionHandler completionHandler)

MulticastSet

public MulticastSet(PerformanceMetrics performanceMetrics,
                    com.rabbitmq.client.ConnectionFactory factory,
                    MulticastParams params,
                    java.lang.String testID,
                    java.util.List<java.lang.String> uris,
                    MulticastSet.CompletionHandler completionHandler,
                    ShutdownService shutdownService,
                    com.rabbitmq.perf.ExpectedMetrics expectedMetrics)

Method Detail

nbThreadsForConsumer

protected static int nbThreadsForConsumer(MulticastParams params)

nbThreadsForProducerScheduledExecutorService

protected static int nbThreadsForProducerScheduledExecutorService(MulticastParams params)

run

public void run()
         throws java.io.IOException,
                java.lang.InterruptedException,
                java.util.concurrent.TimeoutException,
                java.security.NoSuchAlgorithmException,
                java.security.KeyManagementException,
                java.net.URISyntaxException,
                java.util.concurrent.ExecutionException

Throws:

java.io.IOException

java.lang.InterruptedException

java.util.concurrent.TimeoutException

java.security.NoSuchAlgorithmException

java.security.KeyManagementException

java.net.URISyntaxException

java.util.concurrent.ExecutionException

run

public void run(boolean announceStartup)
         throws java.io.IOException,
                java.lang.InterruptedException,
                java.util.concurrent.TimeoutException,
                java.security.NoSuchAlgorithmException,
                java.security.KeyManagementException,
                java.net.URISyntaxException

Throws:

java.io.IOException

java.lang.InterruptedException

java.util.concurrent.TimeoutException

java.security.NoSuchAlgorithmException

java.security.KeyManagementException

java.net.URISyntaxException

setThreadingHandler

public void setThreadingHandler(com.rabbitmq.perf.MulticastSet.ThreadingHandler threadingHandler)