public SubscriptionState getSubscriptionState ( String subscriptionName , String database ) { if ( StringUtils . isEmpty ( subscriptionName ) ) { throw new IllegalArgumentException ( "SubscriptionName cannot be null" ) ; } RequestExecutor requestExecutor = _store . getRequestExecutor ( ObjectUtils . firstNonNull ( database , _store . getDatabase ( ) ) ) ; GetSubscriptionStateCommand command = new GetSubscriptionStateCommand ( subscriptionName ) ; requestExecutor . execute ( command ) ; return command . getResult ( ) ; }
Returns subscription definition and it s current state