ESHttpEventStore extends AbstractReadableEventStore implements IESHttpEventStore { static TenantStreamId streamId(final TenantId tenantId, final URI uri) { return new TenantStreamId(tenantId, new SimpleStreamId(streamName(uri))); } @Deprecated  ESHttpEventStore(@NotNull final ThreadFactory threadFactory, @NotNull final URL url, @NotNull final ESEnvelopeType envelopeType,
            @NotNull final SerializerRegistry serRegistry, @NotNull final DeserializerRegistry desRegistry); @Deprecated  ESHttpEventStore(@NotNull final ThreadFactory threadFactory, @NotNull final URL url, @NotNull final ESEnvelopeType envelopeType,
            @NotNull final SerializerRegistry serRegistry, @NotNull final DeserializerRegistry desRegistry,
            final CredentialsProvider credentialsProvider); private  ESHttpEventStore(@NotNull final ThreadFactory threadFactory, @NotNull final URL url, @NotNull final ESEnvelopeType envelopeType,
            @NotNull final SerializerRegistry serRegistry, @NotNull final DeserializerRegistry desRegistry,
            final CredentialsProvider credentialsProvider, final TenantId tenantId); @Override ESHttpEventStore open(); @Override void close(); @Override final boolean isSupportsCreateStream(); @Override final void createStream(final StreamId streamId); @Override final long appendToStream(final StreamId streamId, final CommonEvent... events); @Override final long appendToStream(final StreamId streamId, final long expectedVersion, final CommonEvent... events); @Override final long appendToStream(final StreamId streamId, final List<CommonEvent> events); @Override long appendToStream(final StreamId streamId, final long expectedVersion, final List<CommonEvent> commonEvents); @Override void deleteStream(final StreamId streamId, final long expectedVersion, final boolean hardDelete); @Override void deleteStream(final StreamId streamId, final boolean hardDelete); @Override StreamEventsSlice readEventsForward(final StreamId streamId, final long start, final int count); @Override StreamEventsSlice readEventsBackward(final StreamId streamId, final long start, final int count); @Override CommonEvent readEvent(final StreamId streamId, final long eventNumber); @Override final boolean streamExists(final StreamId streamId); @Override final StreamState streamState(final StreamId streamId); @Override boolean projectionExists(final StreamId projectionId); @Override final void enableProjection(final StreamId projectionId); @Override final void disableProjection(final StreamId projectionId); @Override final void createProjection(final StreamId projectionId, final boolean enable, final TypeName... eventType); @Override final void createProjection(final StreamId projectionId, final boolean enable, final List<TypeName> eventTypes); @Override final void deleteProjection(final StreamId projectionId);  }
@Test public void testStreamId() throws URISyntaxException { try { ESHttpEventStore.streamId(null, new URI("https: fail(); } catch (final IllegalStateException ex) { assertThat(ex.getMessage()).isEqualTo("Failed to extract '/streams/': https: } try { ESHttpEventStore.streamId(null, new URI("http: fail(); } catch (final IllegalStateException ex) { assertThat(ex.getMessage()).isEqualTo("Failed to extract '/streams/': http: } try { ESHttpEventStore.streamId(null, new URI("http: fail(); } catch (final IllegalStateException ex) { assertThat(ex.getMessage()).isEqualTo("Failed to extract last '/': http: } try { ESHttpEventStore.streamId(null, new URI("http: fail(); } catch (final IllegalStateException ex) { assertThat(ex.getMessage()).isEqualTo("Failed to extract last '/': http: } try { ESHttpEventStore.streamId(null, new URI("http: fail(); } catch (final IllegalStateException ex) { assertThat(ex.getMessage()).isEqualTo("Failed to extract name: http: } assertThat(ESHttpEventStore.streamId(null, new URI("http: .isEqualTo("append_diff_and_read_stream"); }