@Test void testCanResolveReturnsFalseNonAggregateScopeDescriptorImplementation() { assertFalse(testSubject.canResolve(new SagaScopeDescriptor("some-saga-type", AGGREGATE_ID))); }
@Override public boolean canResolve(ScopeDescriptor scopeDescription) { return scopeDescription instanceof AggregateScopeDescriptor && Objects.equals(aggregateModel.type(), ((AggregateScopeDescriptor) scopeDescription).getType()); }
AbstractRepository implements Repository<T> { @Override public boolean canResolve(ScopeDescriptor scopeDescription) { return scopeDescription instanceof AggregateScopeDescriptor && Objects.equals(aggregateModel.type(), ((AggregateScopeDescriptor) scopeDescription).getType()); } }
AbstractRepository implements Repository<T> { @Override public boolean canResolve(ScopeDescriptor scopeDescription) { return scopeDescription instanceof AggregateScopeDescriptor && Objects.equals(aggregateModel.type(), ((AggregateScopeDescriptor) scopeDescription).getType()); } protected  AbstractRepository(Builder<T> builder); }
AbstractRepository implements Repository<T> { @Override public boolean canResolve(ScopeDescriptor scopeDescription) { return scopeDescription instanceof AggregateScopeDescriptor && Objects.equals(aggregateModel.type(), ((AggregateScopeDescriptor) scopeDescription).getType()); } protected  AbstractRepository(Builder<T> builder); @Override A newInstance(Callable<T> factoryMethod); @Override A load(String aggregateIdentifier, Long expectedVersion); @Override Aggregate<T> loadOrCreate(String aggregateIdentifier, Callable<T> factoryMethod); @Override A load(String aggregateIdentifier); @Override void send(Message<?> message, ScopeDescriptor scopeDescription); @Override boolean canResolve(ScopeDescriptor scopeDescription); }
AbstractRepository implements Repository<T> { @Override public boolean canResolve(ScopeDescriptor scopeDescription) { return scopeDescription instanceof AggregateScopeDescriptor && Objects.equals(aggregateModel.type(), ((AggregateScopeDescriptor) scopeDescription).getType()); } protected  AbstractRepository(Builder<T> builder); @Override A newInstance(Callable<T> factoryMethod); @Override A load(String aggregateIdentifier, Long expectedVersion); @Override Aggregate<T> loadOrCreate(String aggregateIdentifier, Callable<T> factoryMethod); @Override A load(String aggregateIdentifier); @Override void send(Message<?> message, ScopeDescriptor scopeDescription); @Override boolean canResolve(ScopeDescriptor scopeDescription);  }