com.rabbitmq.perf

Class TopologyRecording

java.lang.Object

com.rabbitmq.perf.TopologyRecording

public class TopologyRecording
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TopologyRecording(boolean polling, boolean cluster) Create a TopologyRecording with or without polling option.

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.perf.TopologyRecording.RecordedExchange	exchange(java.lang.String name)
com.rabbitmq.perf.TopologyRecording.RecordedQueue	queue(java.lang.String name)
com.rabbitmq.perf.TopologyRecording.RecordedBinding	recordBinding(java.lang.String queue, java.lang.String exchange, java.lang.String routingKey)
com.rabbitmq.perf.TopologyRecording.RecordedExchange	recordExchange(java.lang.String name, java.lang.String type)
com.rabbitmq.perf.TopologyRecording.RecordedQueue	recordQueue(java.lang.String name, boolean durable, boolean exclusive, boolean autoDelete, java.util.Map<java.lang.String,java.lang.Object> arguments, boolean serverNamed)
void	recover(com.rabbitmq.client.Connection connection)
TopologyRecording	subRecording(java.util.Collection<java.lang.String> queues) Create a subset of the topology of this recording for the passed-in queues.

Methods inherited from class java.lang.Object

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

Constructor Detail

TopologyRecording

public TopologyRecording(boolean polling,
                         boolean cluster)

Create a TopologyRecording with or without polling option.

The polling option is set to true when basic.get is used to consume messages. This way, auto-delete queues with server-generated names are cleaned on recovery (because they don't go away by themselves).

Parameters:

polling -

Method Detail

recordExchange

public com.rabbitmq.perf.TopologyRecording.RecordedExchange recordExchange(java.lang.String name,
                                                                           java.lang.String type)

recordQueue

public com.rabbitmq.perf.TopologyRecording.RecordedQueue recordQueue(java.lang.String name,
                                                                     boolean durable,
                                                                     boolean exclusive,
                                                                     boolean autoDelete,
                                                                     java.util.Map<java.lang.String,java.lang.Object> arguments,
                                                                     boolean serverNamed)

recordBinding

public com.rabbitmq.perf.TopologyRecording.RecordedBinding recordBinding(java.lang.String queue,
                                                                         java.lang.String exchange,
                                                                         java.lang.String routingKey)

queue

public com.rabbitmq.perf.TopologyRecording.RecordedQueue queue(java.lang.String name)

exchange

public com.rabbitmq.perf.TopologyRecording.RecordedExchange exchange(java.lang.String name)

subRecording

public TopologyRecording subRecording(java.util.Collection<java.lang.String> queues)

Create a subset of the topology of this recording for the passed-in queues.

Parameters:

queues -

Returns:

recover

public void recover(com.rabbitmq.client.Connection connection)