@Test public void processChannelChanges_update_forNonDYNAMICChannel() { final ChannelSchema channelSchema = new ChannelSchema( 0, ValueUtil.randomString(), null, ChannelSchema.FilterType.NONE, null, true, true, Collections.emptyList() ); final SystemSchema schema = new SystemSchema( 1, ValueUtil.randomString(), new ChannelSchema[]{ channelSchema }, new EntitySchema[ 0 ] ); final Connector connector = createConnector( schema ); final Connection connection = newConnection( connector ); final String oldFilter = ValueUtil.randomString(); final String newFilter = ValueUtil.randomString(); final ChannelChange[] channelChanges = new ChannelChange[]{ ChannelChange.create( "=0.2223", newFilter ) }; final MessageResponse response = setCurrentMessageResponse( connection, ChangeSetMessage.create( null, null, null, channelChanges, null ) ); response.setParsedChannelChanges( Collections.singletonList( ChannelChangeDescriptor.from( 1, channelChanges[ 0 ] ) ) ); createSubscription( new ChannelAddress( 1, 0, 2223 ), oldFilter, true ); final IllegalStateException exception = expectThrows( IllegalStateException.class, connector::processChannelChanges ); assertEquals( exception.getMessage(), "Replicant-0078: Received ChannelChange of type UPDATE for address 1.0.2223 but the channel does not have a DYNAMIC filter." ); }
@Nonnull static Connector create( @Nullable final ReplicantContext context, @Nonnull final SystemSchema schema, @Nonnull final Transport transport ) { return new Arez_Connector( context, schema, transport ); }
Connector extends ReplicantService { @Nonnull static Connector create( @Nullable final ReplicantContext context, @Nonnull final SystemSchema schema, @Nonnull final Transport transport ) { return new Arez_Connector( context, schema, transport ); } }
Connector extends ReplicantService { @Nonnull static Connector create( @Nullable final ReplicantContext context, @Nonnull final SystemSchema schema, @Nonnull final Transport transport ) { return new Arez_Connector( context, schema, transport ); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); }
Connector extends ReplicantService { @Nonnull static Connector create( @Nullable final ReplicantContext context, @Nonnull final SystemSchema schema, @Nonnull final Transport transport ) { return new Arez_Connector( context, schema, transport ); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString(); }
Connector extends ReplicantService { @Nonnull static Connector create( @Nullable final ReplicantContext context, @Nonnull final SystemSchema schema, @Nonnull final Transport transport ) { return new Arez_Connector( context, schema, transport ); } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString();  }