Class SubscribeByGroupOperationTest<O extends SubscribeByGroupOperation>
- java.lang.Object
-
- com.azure.spring.integration.test.support.SubscribeByGroupOperationTest<O>
-
public abstract class SubscribeByGroupOperationTest<O extends SubscribeByGroupOperation> extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected String
anotherConsumerGroup
protected String
consumerGroup
protected String
destination
protected O
subscribeByGroupOperation
-
Constructor Summary
Constructors Constructor Description SubscribeByGroupOperationTest()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description O
getSubscribeByGroupOperation()
void
setSubscribeByGroupOperation(O subscribeByGroupOperation)
void
testSubscribeAndUnsubscribe()
void
testSubscribeTwice()
void
testSubscribeWithAnotherGroup()
void
testUnsubscribeNotSubscribed()
protected abstract void
verifySubscriberCreatorCalled()
protected abstract void
verifySubscriberCreatorNotCalled()
protected abstract void
verifySubscriberRegistered(int times)
protected abstract void
verifySubscriberUnregistered(int times)
-
-
-
Field Detail
-
subscribeByGroupOperation
protected O extends SubscribeByGroupOperation subscribeByGroupOperation
-
consumerGroup
protected String consumerGroup
-
anotherConsumerGroup
protected String anotherConsumerGroup
-
destination
protected String destination
-
-
Method Detail
-
testSubscribeAndUnsubscribe
@Test public void testSubscribeAndUnsubscribe()
-
testSubscribeTwice
@Test public void testSubscribeTwice()
-
testSubscribeWithAnotherGroup
@Test public void testSubscribeWithAnotherGroup()
-
testUnsubscribeNotSubscribed
@Test public void testUnsubscribeNotSubscribed()
-
verifySubscriberCreatorCalled
protected abstract void verifySubscriberCreatorCalled()
-
verifySubscriberCreatorNotCalled
protected abstract void verifySubscriberCreatorNotCalled()
-
verifySubscriberRegistered
protected abstract void verifySubscriberRegistered(int times)
-
verifySubscriberUnregistered
protected abstract void verifySubscriberUnregistered(int times)
-
getSubscribeByGroupOperation
public O getSubscribeByGroupOperation()
-
setSubscribeByGroupOperation
public void setSubscribeByGroupOperation(O subscribeByGroupOperation)
-
-