@Test public void validate_duplicateChannelActions_instanceChannel() { final ChannelChange[] channelChanges = new ChannelChange[]{ ChannelChange.create( "+2.50", "XX" ), ChannelChange.create( "=2.50", "XY" ) }; final ChangeSetMessage changeSet = ChangeSetMessage.create( null, null, new String[]{ "+1", "+4.23" }, channelChanges, null ); final IllegalStateException exception = expectThrows( IllegalStateException.class, changeSet::validate ); assertEquals( exception.getMessage(), "Replicant-0028: ChangeSet contains multiple ChannelChange messages for the channel 2.50." ); }
@GwtIncompatible public static ChangeSetMessage create( @Nullable final Integer requestId, @Nullable final String eTag, @Nullable final String[] channels, @Nullable final ChannelChange[] fchannels, @Nullable final EntityChange[] entityChanges ) { final ChangeSetMessage changeSet = new ChangeSetMessage(); changeSet.type = TYPE; changeSet.requestId = null == requestId ? null : requestId.doubleValue(); changeSet.etag = eTag; changeSet.channels = channels; changeSet.fchannels = fchannels; changeSet.changes = entityChanges; return changeSet; }
ChangeSetMessage extends ServerToClientMessage { @GwtIncompatible public static ChangeSetMessage create( @Nullable final Integer requestId, @Nullable final String eTag, @Nullable final String[] channels, @Nullable final ChannelChange[] fchannels, @Nullable final EntityChange[] entityChanges ) { final ChangeSetMessage changeSet = new ChangeSetMessage(); changeSet.type = TYPE; changeSet.requestId = null == requestId ? null : requestId.doubleValue(); changeSet.etag = eTag; changeSet.channels = channels; changeSet.fchannels = fchannels; changeSet.changes = entityChanges; return changeSet; } }
ChangeSetMessage extends ServerToClientMessage { @GwtIncompatible public static ChangeSetMessage create( @Nullable final Integer requestId, @Nullable final String eTag, @Nullable final String[] channels, @Nullable final ChannelChange[] fchannels, @Nullable final EntityChange[] entityChanges ) { final ChangeSetMessage changeSet = new ChangeSetMessage(); changeSet.type = TYPE; changeSet.requestId = null == requestId ? null : requestId.doubleValue(); changeSet.etag = eTag; changeSet.channels = channels; changeSet.fchannels = fchannels; changeSet.changes = entityChanges; return changeSet; }  }
ChangeSetMessage extends ServerToClientMessage { @GwtIncompatible public static ChangeSetMessage create( @Nullable final Integer requestId, @Nullable final String eTag, @Nullable final String[] channels, @Nullable final ChannelChange[] fchannels, @Nullable final EntityChange[] entityChanges ) { final ChangeSetMessage changeSet = new ChangeSetMessage(); changeSet.type = TYPE; changeSet.requestId = null == requestId ? null : requestId.doubleValue(); changeSet.etag = eTag; changeSet.channels = channels; changeSet.fchannels = fchannels; changeSet.changes = entityChanges; return changeSet; }  @GwtIncompatible static ChangeSetMessage create( @Nullable final Integer requestId,
                                         @Nullable final String eTag,
                                         @Nullable final String[] channels,
                                         @Nullable final ChannelChange[] fchannels,
                                         @Nullable final EntityChange[] entityChanges ); @Nullable @JsOverlay final String getETag(); @Nonnull @JsOverlay final String[] getChannels(); @JsOverlay final boolean hasChannels(); @Nonnull @JsOverlay final ChannelChange[] getFilteredChannels(); @JsOverlay final boolean hasFilteredChannels(); @Nonnull @JsOverlay final EntityChange[] getEntityChanges(); @JsOverlay final boolean hasEntityChanges(); @JsOverlay final void validate(); }
ChangeSetMessage extends ServerToClientMessage { @GwtIncompatible public static ChangeSetMessage create( @Nullable final Integer requestId, @Nullable final String eTag, @Nullable final String[] channels, @Nullable final ChannelChange[] fchannels, @Nullable final EntityChange[] entityChanges ) { final ChangeSetMessage changeSet = new ChangeSetMessage(); changeSet.type = TYPE; changeSet.requestId = null == requestId ? null : requestId.doubleValue(); changeSet.etag = eTag; changeSet.channels = channels; changeSet.fchannels = fchannels; changeSet.changes = entityChanges; return changeSet; }  @GwtIncompatible static ChangeSetMessage create( @Nullable final Integer requestId,
                                         @Nullable final String eTag,
                                         @Nullable final String[] channels,
                                         @Nullable final ChannelChange[] fchannels,
                                         @Nullable final EntityChange[] entityChanges ); @Nullable @JsOverlay final String getETag(); @Nonnull @JsOverlay final String[] getChannels(); @JsOverlay final boolean hasChannels(); @Nonnull @JsOverlay final ChannelChange[] getFilteredChannels(); @JsOverlay final boolean hasFilteredChannels(); @Nonnull @JsOverlay final EntityChange[] getEntityChanges(); @JsOverlay final boolean hasEntityChanges(); @JsOverlay final void validate(); @JsOverlay
  static final String TYPE; }