smaldini

import reactor.core.Environment
import reactor.rx.Streams
import reactor.rx.amqp.LapinStreams
import reactor.rx.amqp.signal.ExchangeSignal
import reactor.rx.amqp.spec.Queue
import spock.lang.Shared
import spock.lang.Specification

import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit