This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a change to branch pjfanning-patch-4
in repository https://gitbox.apache.org/repos/asf/pekko-connectors.git
omit 2de468a91 Merge remote-tracking branch 'upstream/main' into
pjfanning-patch-4
omit 918278d77 Revert "temp test with staged M5 build"
omit 47586cf3c temp test with staged M5 build
omit 209438f53 test issue
omit 26fe1765a Update MqttFlowSpec.scala
omit a12588e65 more warning suppression
omit 5e34962d1 upgrade mqtt tests
omit 940c2a852 issues with Source.queue deprecation
omit 990bd5e2e Update pekkoVersion to 2.0.0-M4
add e718de0f9 Update protobuf-java to 4.36.1 (#1892)
add b2f755275 Update auth, dynamodb, eventbridge, firehose, ... to 2.54.10
(#1894)
add dadfd167e Update orientdb-graphdb, orientdb-object to 3.2.56 (#1893)
add 00beb52e0 Update scalacheck to 1.20.0 (#1868)
add 293db00f0 Replace LocalStack with DynamoDB local and GoAws in aws-spi
tests (#1901)
add 017eb23d1 DynamoDB: use official amazon/dynamodb-local test image
(#1897)
add f34b00a63 AWS S3: update minio docker test image to
RELEASE.2025-09-07T16-13-09Z (#1890)
add 9653a7a0a AWS EventBridge: replace last localstack usage with
motoserver/moto (#1902)
add e3d4f2645 JMS: update IBM MQ test image to icr.io/ibm-messaging/mq
(#1899)
add 9a38c5aad AMQP: update rabbitmq docker test image to v4 (#1885)
add 188afd20b HBase: re-enable integration tests in CI (#1895)
add 9642b54a0 SNS: switch goaws test image to maintained admiralpiett fork
(#1896)
add cfa1c60c2 Google Cloud Pub/Sub: drop unmaintained prep image,
provision emulator via REST (#1900)
add 50bd1bc3b HDFS: remove obsolete cats-kernel cache probe from CI (#1903)
add adacf5aa8 Update auth, dynamodb, eventbridge, firehose, ... to 2.54.12
(#1916)
add ec32880af Update jcl-over-slf4j, log4j-over-slf4j, ... to 2.0.19
(#1915)
add 25841ef39 Update h2 to 2.5.250 (#1911)
add e04f06d6c Update scala-library to 3.9.0 (#1914)
add 14155198d Update parquet-avro to 1.18.1 (#1913)
add cc96893a0 Pin hbase to 2.x in scala-steward config (#1918)
add a270eecaa Run the hbase tests against an in-JVM mini cluster (#1919)
add 8dd43230d Cassandra: update cassandra docker test image to 5.0 (#1889)
add d493adda4 Kudu: update kudu docker test image to 1.18.1-ubuntu (#1891)
add c1a98b84f Update google-cloud-pubsub to 1.155.0 (#1922)
add 3b98d4c3a Update google-auth-library-credentials, ... to 1.52.0 (#1921)
add e025a7e7a Update proto-google-cloud-bigquerystorage-v1 to 3.33.0
(#1920)
add 4450bfd63 Update amazon-kinesis-client to 3.5.2 (#1924)
add f1dc6cb31 Update auth, dynamodb, eventbridge, firehose, ... to 2.54.13
(#1923)
add 0e716236d Google Cloud Pub/Sub: update google/cloud-sdk docker test
image to 583.0.0 (#1886)
add 9dfe80a06 Couchbase3: test against couchbase community-8.0.2 (#1888)
add 7614f1612 OrientDB: update orientdb docker test image to 3.2.55 (#1887)
add caa980a01 Google: add top-level project-id setting with environment
fallback (#1926)
add ae7c53315 Google: close the credentials file when parsing it fails
(#1928)
add 40741ebc3 Kinesis: resolve mbknor-jackson-jsonschema for the build's
Scala version (#1925)
add 063773f16 File: open zip archives in preStart rather than the stage
constructor (#1929)
add 24f190e56 Google: allow OAuth2 credentials to be closed (#1927)
add 857a07eaa Update activemq-broker, activemq-client to 5.19.11 (#1932)
add b6d96ae5d Update sbt-mima-plugin to 1.2.0 (#1931)
add 920cf5184 Update netty-handler to 4.2.18.Final (#1936)
add 578997ed7 Update auth, dynamodb, eventbridge, firehose, ... to 2.54.15
(#1939)
add 531541e35 Update mongo-scala-driver to 5.11.1 (#1938)
add f51db2b12 Update artemis-jakarta-client, ... to 2.57.0 (#1937)
add 6431bdac5 AWS SPI Pekko HTTP, Testkit: use parameterized slf4j logging
(#1940)
add 28783ec2c AWS S3: replace removed minio/minio test image with
pgsty/silo (#1943)
add 1db364094 Update auth, dynamodb, eventbridge, firehose, ... to 2.54.17
(#1942)
add 2c2837b4b Chore: remove leftover Scala 2.12 immutable.Seq idioms
(#1941)
add d69454094 Bump actions/setup-java from 6.0.0 to 6.0.1 (#1944)
add d7c2df39a Elasticsearch: test Opensearch against 2.x and 3.x (#1933)
add 18033ce10 HDFS: close the writer when the stream does not complete
normally (#1878)
add 0ab554702 Solr: fix broken links to the Solr 9.10 reference guide and
javadoc (#1946)
add 440a7143a Bump coursier/setup-action from 3.0.2 to 3.0.3 (#1947)
add 00a8f6d19 Elasticsearch: fix insecure-credentials check message and
failure mode (#1871)
add 8d6ef47de File: use int for the Java API zip compression level (#1873)
add fd74c9506 Unix Domain Socket: fix large-transfer stall from lost
readiness events (#1880)
add ad59442ea Update auth, dynamodb, eventbridge, firehose, ... to 2.54.20
(#1959)
add 7a5b0ee38 Update mongo-scala-driver to 5.12.0 (#1958)
add 6ffa496b7 Update geode-core, geode-cq to 2.0.3 (#1957)
add 22ca6c4a7 Update amqp-client to 5.36.0 (#1954)
add 50c588781 Update com.ibm.mq.allclient, ... to 10.0.0.5 (#1953)
add 3f6ec4f10 Update sshj to 0.41.1 (#1952)
add 8364182f2 Update jnr-unixsocket to 0.39.5 (#1950)
add 0c0c0c7c5 Update jackson-module-scala to 2.22.3 (#1948)
add fe7fb3fe0 Update jffi to 1.4.3 (#1949)
add 8d508697f googleCloudPubSubGrpc: filter out deprecated grpc classes
that are not needed (#1855)
add b10237e6e HBase: close the scanner and connection in the source stage
(#1876)
add 3d35ab3be Update protobuf-java to 4.36.2 (#1951)
add 6db1818c0 Update sbt-api-mappings to 3.1.0 (#1955)
add 1d41f7458 Update sbt-mima-plugin to 1.2.1 (#1956)
add 647a5886c Update auth, dynamodb, eventbridge, firehose, ... to 2.55.4
(#1966)
add 1ec6f0e79 Update jcl-over-slf4j, log4j-over-slf4j, ... to 2.0.20
(#1965)
add c0d9e3761 Update mockito-core to 5.24.0 (#1964)
add 86642aa53 Update proto-google-cloud-bigquerystorage-v1 to 3.34.0
(#1961)
add 9d79c9e88 Update google-auth-library-credentials, ... to 1.53.0 (#1962)
add 3965f155f Update google-cloud-pubsub to 1.156.0 (#1963)
add 7dd650376 Update auth, dynamodb, eventbridge, firehose, ... to 2.55.6
(#1969)
add f4bbad5f0 Update amazon-kinesis-client to 3.5.3 (#1970)
add c9255ad51 Update mongo-scala-driver to 5.13.0 (#1968)
add da1438356 Update logback-classic to 1.6.4 (#1967)
add c8336c0f9 Update h2 to 2.5.252 (#1972)
add 79dd2fddc Update jackson-module-scala to 2.22.3.1 (#1960)
add 12b7e8267 Elasticsearch: support Elasticsearch 8 and 9 (#1934)
add 817f614e3 S3: release disk-buffered chunks when the upload is done
with them (#1930)
add 04678214a FTP: stop pure-ftpd DNS lookups and relax FtpWritingTest
timeouts (#1974)
add 1c1d0b950 Update commons-lang3 to 3.21.0 (#1975)
add 1be54e751 Update auth, dynamodb, eventbridge, firehose, ... to 2.55.8
(#1976)
add 817d8f433 MQTT Streaming: fix BroadcastHub race in server flow tests
(#1977)
add dd540083a OrientDB: only validate className when it is used in a query
(#1874)
add 26d689382 AWS SPI: preserve content-type parameters and drop
unreachable map entry (#1905)
add c20bff707 Slick: keep H2 test database open and relax test patience
(#1978)
add 7b0b71cc9 Update sbt-java-formatter to 0.14.0 (#1980)
add 1a36f54b6 Update sbt-paradox, sbt-paradox-theme to 0.11.1 (#1984)
add b170c584d Update amqp-client to 5.37.0 (#1985)
add 718a48d05 Update auth, dynamodb, eventbridge, firehose, ... to 2.55.10
(#1987)
add 08ec4ebd0 Update google-cloud-pubsub to 1.157.0 (#1983)
add b13f57a6c Update google-auth-library-credentials, ... to 1.54.0 (#1982)
add 11c198b73 Update proto-google-cloud-bigquerystorage-v1 to 3.35.0
(#1981)
add 16d050aa6 Update logback-classic to 1.6.5 (#1979)
add a9ba6141a Update hbase-common, hbase-shaded-client, ... to 2.6.7
(#1986)
add 92ac9df24 Update pekkoVersion to 2.0.0-M4
add 7a1c0ad2b issues with Source.queue deprecation
add fa90b4602 upgrade mqtt tests
add a391896a1 more warning suppression
add ab64f9455 Update MqttFlowSpec.scala
add 8ff8fe180 test issue
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2de468a91)
\
N -- N -- N refs/heads/pjfanning-patch-4 (8ff8fe180)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/check-build-test.yml | 19 ++-
.github/workflows/headers.yml | 2 +-
.github/workflows/link-validator.yml | 4 +-
.github/workflows/nightly-builds.yaml | 4 +-
.github/workflows/nightly-pekko-1.0-builds.yaml | 2 +-
.github/workflows/nightly-pekko-1.x-builds.yaml | 2 +-
.github/workflows/publish-1.0-docs.yml | 2 +-
.github/workflows/publish-1.1-docs.yml | 2 +-
.github/workflows/publish-1.2-docs.yml | 2 +-
.github/workflows/publish-1.3-docs.yml | 2 +-
.github/workflows/publish-2.0-docs.yml | 2 +-
.github/workflows/publish-nightly-1.4.yml | 2 +-
.github/workflows/publish-nightly.yml | 4 +-
.github/workflows/publish-on-demand.yml | 2 +-
.github/workflows/stage-release-candidate.yml | 2 +-
.scala-steward.conf | 6 +-
.../connectors/amqp/AmqpConnectionProvider.scala | 25 ++--
.../connectors/amqp/AmqpConnectorSettings.scala | 27 ++--
.../test/scala/docs/scaladsl/AmqpDocsSpec.scala | 9 +-
.../amqp/scaladsl/AmqpConnectorsSpec.scala | 7 +-
amqp/src/test/travis/rabbitmq.conf | 4 +
.../stream/connectors/awsspi/PekkoHttpClient.scala | 22 +--
.../connectors/awsspi/BaseAwsClientTest.scala | 24 +++-
.../connectors/awsspi/PekkoHttpClientSpec.scala | 49 ++++++-
.../connectors/awsspi/dynamodb/TestDynamoDB.scala | 6 +-
.../stream/connectors/awsspi/sns/TestSNS.scala | 6 +-
.../LocalStackReadyLogWaitStrategy.scala | 48 -------
build.sbt | 18 ++-
.../connectors/cassandra/CqlSessionProvider.scala | 3 +-
.../cassandra/PekkoDiscoverySessionProvider.scala | 5 +-
.../cassandra/scaladsl/CassandraSession.scala | 5 +-
.../scala/docs/scaladsl/CassandraFlowSpec.scala | 9 +-
.../scala/docs/scaladsl/CassandraSourceSpec.scala | 5 +-
.../cassandra/javadsl/CassandraSessionSpec.scala | 3 +-
.../cassandra/scaladsl/CassandraLifecycle.scala | 9 +-
.../pekko/stream/connectors/couchbase/model.scala | 7 +-
.../couchbase/scaladsl/DiscoverySupport.scala | 5 +-
.../scala/docs/scaladsl/CouchbaseFlowSpec.scala | 34 +++--
.../scala/docs/scaladsl/CouchbaseSourceSpec.scala | 1 -
.../couchbase/testing/CouchbaseSupport.scala | 1 -
.../docs/scaladsl/CouchbaseTestFlowSpec.scala | 1 -
.../docs/scaladsl/CouchbaseTestSourceSpec.scala | 3 +-
.../stream/connectors/csv/impl/CsvToMapStage.scala | 22 ++-
.../scala/docs/scaladsl/CsvFormattingSpec.scala | 4 +-
.../test/scala/docs/scaladsl/CsvParsingSpec.scala | 1 -
docker-compose.yml | 154 +++++++++++++++------
docs/src/main/paradox/data-transformations/csv.md | 2 +-
docs/src/main/paradox/elasticsearch.md | 8 +-
docs/src/main/paradox/google-common.md | 26 ++++
docs/src/main/paradox/jms/ibm-mq.md | 6 +-
docs/src/main/paradox/opensearch.md | 32 ++---
docs/src/main/paradox/solr.md | 2 +-
.../connectors/elasticsearch/ApiVersion.java | 4 +-
.../ElasticsearchConnectionSettings.scala | 41 ++++--
.../elasticsearch/ElasticsearchParams.scala | 10 ++
.../elasticsearch/impl/ElasticsearchApi.scala | 47 +++++--
.../impl/ElasticsearchSimpleFlowStage.scala | 19 ++-
.../impl/ElasticsearchSourceStage.scala | 5 +-
.../elasticsearch/impl/RestBulkApi.scala | 8 +-
.../elasticsearch/impl/RestBulkApiV5.scala | 4 +-
.../elasticsearch/impl/RestBulkApiV7.scala | 4 +-
.../elasticsearch/scaladsl/ElasticsearchFlow.scala | 41 +++---
.../javadsl/ElasticsearchParameterizedTest.java | 8 +-
.../java/docs/javadsl/ElasticsearchTestBase.java | 49 ++++++-
...{OpensearchV1Test.java => Opensearch2Test.java} | 2 +-
.../docs/javadsl/OpensearchParameterizedTest.java | 5 +-
.../scaladsl/ElasticsearchConnectorBehaviour.scala | 70 +++++-----
.../scala/docs/scaladsl/ElasticsearchSpec.scala | 25 ++--
.../docs/scaladsl/ElasticsearchSpecUtils.scala | 47 ++++++-
.../scala/docs/scaladsl/ElasticsearchV5Spec.scala | 13 +-
.../scala/docs/scaladsl/ElasticsearchV7Spec.scala | 13 +-
.../scaladsl/OpensearchConnectorBehaviour.scala | 21 ++-
...OpensearchV1Spec.scala => OpensearchSpec.scala} | 25 ++--
.../elasticsearch/impl/ElasticsearchApiSpec.scala | 60 +++++++-
.../impl/ElasticsearchSimpleFlowStageTest.scala | 11 +-
.../file/impl/archive/ZipReaderSource.scala | 39 +++++-
.../stream/connectors/file/javadsl/Archive.scala | 22 +--
.../stream/connectors/file/scaladsl/Archive.scala | 19 ++-
.../connectors/file/scaladsl/Directory.scala | 4 +-
.../connectors/file/scaladsl/LogRotatorSink.scala | 3 +-
file/src/test/java/docs/javadsl/ArchiveTest.java | 50 +++++++
.../src/test/scala/docs/scaladsl/ArchiveSpec.scala | 30 +++-
.../test/scala/docs/scaladsl/DirectorySpec.scala | 9 +-
.../scala/docs/scaladsl/LogRotatorSinkSpec.scala | 9 +-
.../test/scala/docs/scaladsl/TarArchiveSpec.scala | 9 +-
.../connectors/ftp/impl/CommonFtpOperations.scala | 5 +-
.../pekko/stream/connectors/ftp/impl/FtpLike.scala | 5 +-
.../connectors/ftp/impl/SftpOperations.scala | 5 +-
ftp/src/test/java/docs/javadsl/FtpWritingTest.java | 4 +-
.../stream/connectors/ftp/CommonFtpStageSpec.scala | 7 +-
.../context-bounds.excludes | 2 +
.../bigquery/model/DatasetJsonProtocol.scala | 1 -
.../bigquery/model/JobJsonProtocol.scala | 1 -
.../bigquery/model/QueryJsonProtocol.scala | 1 -
.../bigquery/model/TableDataJsonProtocol.scala | 1 -
.../bigquery/model/TableJsonProtocol.scala | 1 -
.../bigquery/scaladsl/BigQueryTableData.scala | 1 -
.../bigquery/scaladsl/schema/ProductSchemas.scala | 1 -
.../src/test/scala/docs/scaladsl/BigQueryDoc.scala | 1 -
.../grpc-reflection-v1alpha.excludes | 7 +-
.../googlecloud/pubsub/impl/PubSubApi.scala | 8 +-
.../connectors/googlecloud/pubsub/model.scala | 14 +-
.../googlecloud/pubsub/scaladsl/GooglePubSub.scala | 17 ++-
.../test/scala/docs/scaladsl/ExampleUsage.scala | 1 -
.../test/scala/docs/scaladsl/IntegrationSpec.scala | 1 -
.../google/AuthorizationHeaderSpec.scala | 1 -
.../googlecloud/pubsub/GooglePubSubSpec.scala | 1 -
.../connectors/googlecloud/pubsub/ModelSpec.scala | 1 -
.../googlecloud/pubsub/impl/PubSubApiSpec.scala | 1 -
.../googlecloud/storage/FailedUpload.scala | 1 -
.../context-bounds.excludes | 6 +-
google-common/src/main/resources/reference.conf | 17 +++
.../stream/connectors/google/GoogleSettings.scala | 16 ++-
.../connectors/google/auth/Credentials.scala | 12 ++
.../connectors/google/auth/OAuth2Credentials.scala | 34 +++--
.../google/auth/ServiceAccountCredentials.scala | 5 +-
.../google/auth/UserAccessCredentials.scala | 5 +-
.../connectors/google/GoogleSettingsSpec.scala | 81 +++++++++++
.../connectors/google/auth/CredentialsSpec.scala | 75 ++++++++++
.../google/auth/OAuth2CredentialsSpec.scala | 32 +++++
.../src/test/scala/docs/scaladsl/FcmExamples.scala | 5 +-
.../stream/connectors/hbase/HTableSettings.scala | 17 ++-
.../connectors/hbase/impl/HBaseCapabilities.scala | 16 ++-
.../connectors/hbase/impl/HBaseSourceStage.scala | 45 ++++--
.../src/test/java/docs/javadsl/HBaseStageTest.java | 111 ++++++++++++++-
.../test/scala/docs/scaladsl/HBaseStageSpec.scala | 88 ++++++++++--
.../stream/connectors/hbase/HBaseMiniCluster.scala | 64 +++++++++
.../hbase/impl/HBaseSourceLogicSpec.scala | 71 ++++++++++
.../connectors/hdfs/impl/HdfsFlowStage.scala | 15 +-
.../hdfs/impl/writer/CompressedDataWriter.scala | 9 ++
.../connectors/hdfs/impl/writer/DataWriter.scala | 3 +
.../connectors/hdfs/impl/writer/HdfsWriter.scala | 22 ++-
.../hdfs/impl/writer/SequenceWriter.scala | 3 +
.../test/scala/docs/scaladsl/HdfsWriterSpec.scala | 49 ++++++-
.../huawei/pushkit/impl/PushKitSender.scala | 5 +-
.../test/scala/docs/scaladsl/PushKitExamples.scala | 3 +-
.../influxdb/impl/InfluxDbFlowStage.scala | 39 +++---
.../influxdb/scaladsl/InfluxDbFlow.scala | 12 +-
.../influxdb/scaladsl/InfluxDbSink.scala | 5 +-
.../connectors/ironmq/impl/IronMqClient.scala | 4 +-
.../test/scala/docs/scaladsl/IronMqDocsSpec.scala | 21 ++-
.../java/docs/javadsl/JmsIbmmqConnectorsTest.java | 6 +-
.../scaladsl/JmsBufferedAckConnectorsSpec.scala | 4 +-
.../scala/docs/scaladsl/JmsConnectorsSpec.scala | 22 +--
.../docs/scaladsl/JmsIbmmqConnectorsSpec.scala | 13 +-
.../scala/docs/scaladsl/JmsTxConnectorsSpec.scala | 4 +-
.../java/docs/javadsl/JmsIbmmqConnectorsTest.java | 6 +-
.../scaladsl/JmsBufferedAckConnectorsSpec.scala | 4 +-
.../scala/docs/scaladsl/JmsConnectorsSpec.scala | 21 ++-
.../docs/scaladsl/JmsIbmmqConnectorsSpec.scala | 13 +-
.../scala/docs/scaladsl/JmsTxConnectorsSpec.scala | 4 +-
.../kinesis/scaladsl/KinesisSchedulerSource.scala | 3 +-
.../test/scala/docs/scaladsl/MongoSourceSpec.scala | 1 -
.../mqtt/streaming/impl/BehaviorRunner.scala | 2 -
.../mqtt/streaming/impl/ClientState.scala | 1 -
.../mqtt/streaming/impl/QueueOfferState.scala | 1 -
.../mqtt/streaming/impl/ServerState.scala | 1 -
.../src/test/java/docs/javadsl/MqttFlowTest.java | 6 +-
.../test/scala/docs/scaladsl/MqttFlowSpec.scala | 4 +-
.../pekko/stream/connectors/mqtt/settings.scala | 11 +-
.../test/scala/docs/scaladsl/MqttSourceSpec.scala | 1 -
.../pekko/stream/connectors/mqttv5/model.scala | 3 +-
.../pekko/stream/connectors/mqttv5/settings.scala | 3 +-
.../orientdb/impl/OrientDbFlowStage.scala | 15 +-
.../orientdb/impl/OrientDbSourceStage.scala | 5 +-
.../orientdb/scaladsl/OrientDbFlow.scala | 15 +-
.../orientdb/scaladsl/OrientDbSink.scala | 5 +-
.../test/scala/docs/scaladsl/OrientDbSpec.scala | 3 +-
.../orientdb/impl/OrientDbSourceStageSpec.scala | 36 +++++
project/Dependencies.scala | 90 +++++++-----
project/plugins.sbt | 10 +-
.../reference/impl/ReferenceSourceStage.scala | 3 +-
.../pekko/stream/connectors/reference/model.scala | 9 +-
.../reference/testkit/MessageFactory.scala | 3 +-
.../test/scala/docs/scaladsl/ReferenceSpec.scala | 13 +-
.../pekko/stream/connectors/s3/S3Headers.scala | 2 -
.../s3/headers/ServerSideEncryption.scala | 18 ++-
.../pekko/stream/connectors/s3/impl/Chunk.scala | 28 +++-
.../stream/connectors/s3/impl/DiskBuffer.scala | 50 ++++++-
.../stream/connectors/s3/impl/HttpRequests.scala | 1 -
.../stream/connectors/s3/impl/MemoryBuffer.scala | 2 +-
.../pekko/stream/connectors/s3/impl/S3Stream.scala | 80 ++++++-----
.../apache/pekko/stream/connectors/s3/model.scala | 4 +-
.../stream/connectors/s3/MinioContainer.scala | 6 +-
.../stream/connectors/s3/impl/DiskBufferSpec.scala | 48 +++++++
.../connectors/s3/impl/MarshallingSpec.scala | 1 -
.../connectors/s3/scaladsl/S3IntegrationSpec.scala | 2 +-
scripts/create-slow-minio.sh | 4 +-
.../scala/docs/scaladsl/RecordIOFramingSpec.scala | 1 -
slick/src/test/resources/application.conf | 6 +
slick/src/test/scala/docs/scaladsl/SlickSpec.scala | 2 +-
.../docs/scaladsl/SlickWithTryResultSpec.scala | 6 +-
.../connectors/solr/impl/SolrFlowStage.scala | 25 ++--
.../stream/connectors/solr/javadsl/SolrFlow.scala | 13 +-
.../stream/connectors/solr/scaladsl/SolrFlow.scala | 18 ++-
.../stream/connectors/solr/scaladsl/SolrSink.scala | 7 +-
solr/src/test/scala/docs/scaladsl/SolrSpec.scala | 5 +-
.../stream/connectors/sqs/SqsSourceSettings.scala | 21 ++-
.../connectors/sqs/scaladsl/SqsAckFlow.scala | 3 +-
.../test/scala/docs/scaladsl/SqsSourceSpec.scala | 5 +-
.../test/scala/docs/scaladsl/EventSourceSpec.scala | 3 +-
.../testkit/javadsl/LogCapturingJunit4.scala | 6 +-
.../connectors/testkit/scaladsl/LogCapturing.scala | 4 +-
.../docs/scaladsl/CharsetCodingFlowsDoc.scala | 3 +-
.../text/scaladsl/CharsetCodingFlowsSpec.scala | 3 +-
.../impl/UnixDomainSocketImpl.scala | 29 +++-
.../scala/docs/scaladsl/UnixDomainSocketSpec.scala | 2 +-
.../stream/connectors/xml/impl/Subslice.scala | 4 +-
.../pekko/stream/connectors/xml/impl/Subtree.scala | 4 +-
.../connectors/xml/scaladsl/XmlParsing.scala | 6 +-
.../scala/docs/scaladsl/XmlProcessingSpec.scala | 2 +-
211 files changed, 2190 insertions(+), 932 deletions(-)
create mode 100644 amqp/src/test/travis/rabbitmq.conf
delete mode 100644
aws-spi-pekko-http/src/test/scala/org/apache/pekko/stream/connectors/awsspi/testcontainers/LocalStackReadyLogWaitStrategy.scala
rename elasticsearch/src/test/java/docs/javadsl/{OpensearchV1Test.java =>
Opensearch2Test.java} (99%)
rename elasticsearch/src/test/scala/docs/scaladsl/{OpensearchV1Spec.scala =>
OpensearchSpec.scala} (96%)
copy
aws-spi-pekko-http/src/main/mima-filters/1.4.x.backward.excludes/modify-convert-headers.backwards.excludes
=>
google-cloud-pub-sub-grpc/src/main/mima-filters/2.0.x.backwards.excludes/grpc-reflection-v1alpha.excludes
(67%)
copy {google-cloud-bigquery/src/main/mima-filters/2.0.x.backward.excludes =>
google-common/src/main/mima-filters/2.0.x.backwards.excludes}/context-bounds.excludes
(75%)
create mode 100644
hbase/src/test/scala/org/apache/pekko/stream/connectors/hbase/HBaseMiniCluster.scala
create mode 100644
hbase/src/test/scala/org/apache/pekko/stream/connectors/hbase/impl/HBaseSourceLogicSpec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
