subscriptions.remove(subscriptionId).cancel(); | subscriptions.get(context).remove(subscriptionId).cancel(); | subscriptions | subscriptions.get(context) | AxonFramework | 104f1262032b01bc7f5e22d5c4159e4673785920 | org.axonframework.axonserver.connector.query.subscription.SubscriptionQueryRequestTarget | | _1 | subscriptions |
---|
_2 | subscriptions |
---|
| | | | Uses | False |
subscriptions.get(subscriptionId).initialResult().subscribe(i -> publisher.publish(serializer.serialize(i,subscriptionId)),e -> logger.debug(STR0,subscriptionId)); | subscriptions.get(context).get(subscriptionId).initialResult().subscribe(i -> publisher.publish(serializer.serialize(i,subscriptionId)),e -> logger.debug(STR0,subscriptionId)); | subscriptions | subscriptions.get(context) | AxonFramework | 104f1262032b01bc7f5e22d5c4159e4673785920 | org.axonframework.axonserver.connector.query.subscription.SubscriptionQueryRequestTarget | | _1 | subscriptions |
---|
_2 | subscriptions |
---|
| | | | Uses | False |