|
|
|
@ -30,6 +30,7 @@ import org.apache.commons.logging.LogFactory;
@@ -30,6 +30,7 @@ import org.apache.commons.logging.LogFactory;
|
|
|
|
|
import org.junit.After; |
|
|
|
|
import org.junit.Before; |
|
|
|
|
import org.junit.Test; |
|
|
|
|
|
|
|
|
|
import org.springframework.context.ApplicationEvent; |
|
|
|
|
import org.springframework.context.ApplicationEventPublisher; |
|
|
|
|
import org.springframework.messaging.Message; |
|
|
|
@ -38,13 +39,11 @@ import org.springframework.messaging.MessagingException;
@@ -38,13 +39,11 @@ import org.springframework.messaging.MessagingException;
|
|
|
|
|
import org.springframework.messaging.simp.BrokerAvailabilityEvent; |
|
|
|
|
import org.springframework.messaging.support.MessageBuilder; |
|
|
|
|
import org.springframework.messaging.support.channel.ExecutorSubscribableChannel; |
|
|
|
|
import org.springframework.util.Assert; |
|
|
|
|
import org.springframework.util.SocketUtils; |
|
|
|
|
|
|
|
|
|
import reactor.util.Assert; |
|
|
|
|
|
|
|
|
|
import static org.junit.Assert.*; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* @author Rossen Stoyanchev |
|
|
|
|
*/ |
|
|
|
|