apache / pekko-connectors
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 715 files with 49,713 lines of code in files.
    • 654 files that are 366+ days old (45,202 lines of code)
    • 48 files that are 181-365 days old (3,400 lines of code)
    • 1 files that are 91-180 days old (34 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 12 files that are 1-30 days old (1,077 lines of code)
90% | 6% | <1% | 0% | 2%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 715 files with 49,713 lines of code in files.
    • 618 files have been last changed 366+ days ago (39,963 lines of code)
    • 76 files have been last changed 181-365 days ago (6,837 lines of code)
    • 3 files have been last changed 91-180 days ago (59 lines of code)
    • 3 files have been last changed 31-90 days ago (616 lines of code)
    • 15 files have been last changed 1-30 days ago (2,238 lines of code)
80% | 13% | <1% | 1% | 4%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
scala, java, md, xml, yaml, txt, sh, pub, sbt, json, svg, properties, gitattributes, gitignore
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
scala90% | 6% | <1% | 0% | 2%
java83% | 16% | 0% | 0% | 0%
sbt100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
scala81% | 13% | <1% | 1% | 3%
java83% | 16% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
sbt0% | 0% | 4% | 0% | 95%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
s3100% | 0% | 0% | 0% | 0%
mqtt-streaming100% | 0% | 0% | 0% | 0%
jms99% | <1% | 0% | 0% | 0%
google-cloud-bigquery100% | 0% | 0% | 0% | 0%
ftp93% | 6% | 0% | 0% | 0%
google-cloud-storage100% | 0% | 0% | 0% | 0%
amqp100% | 0% | 0% | 0% | 0%
elasticsearch100% | 0% | 0% | 0% | 0%
google-common100% | 0% | 0% | 0% | 0%
file100% | 0% | 0% | 0% | 0%
pravega100% | 0% | 0% | 0% | 0%
sqs100% | 0% | 0% | 0% | 0%
google-fcm100% | 0% | 0% | 0% | 0%
couchbase100% | 0% | 0% | 0% | 0%
google-cloud-bigquery-storage100% | 0% | 0% | 0% | 0%
csv100% | 0% | 0% | 0% | 0%
kinesis100% | 0% | 0% | 0% | 0%
geode100% | 0% | 0% | 0% | 0%
huawei-push-kit100% | 0% | 0% | 0% | 0%
hdfs100% | 0% | 0% | 0% | 0%
mqtt100% | 0% | 0% | 0% | 0%
project100% | 0% | 0% | 0% | 0%
ironmq100% | 0% | 0% | 0% | 0%
influxdb100% | 0% | 0% | 0% | 0%
cassandra100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
solr100% | 0% | 0% | 0% | 0%
google-cloud-pub-sub100% | 0% | 0% | 0% | 0%
unix-domain-socket100% | 0% | 0% | 0% | 0%
couchbase3100% | 0% | 0% | 0% | 0%
google-cloud-pub-sub-grpc100% | 0% | 0% | 0% | 0%
orientdb100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
reference100% | 0% | 0% | 0% | 0%
mongodb100% | 0% | 0% | 0% | 0%
udp100% | 0% | 0% | 0% | 0%
hbase100% | 0% | 0% | 0% | 0%
slick87% | 0% | 12% | 0% | 0%
azure-storage-queue100% | 0% | 0% | 0% | 0%
mqtt-streaming-bench100% | 0% | 0% | 0% | 0%
text100% | 0% | 0% | 0% | 0%
kudu100% | 0% | 0% | 0% | 0%
testkit100% | 0% | 0% | 0% | 0%
avroparquet100% | 0% | 0% | 0% | 0%
dynamodb100% | 0% | 0% | 0% | 0%
sse100% | 0% | 0% | 0% | 0%
simple-codecs100% | 0% | 0% | 0% | 0%
sns100% | 0% | 0% | 0% | 0%
aws-event-bridge100% | 0% | 0% | 0% | 0%
spring-web100% | 0% | 0% | 0% | 0%
json-streaming100% | 0% | 0% | 0% | 0%
csv-bench100% | 0% | 0% | 0% | 0%
awslambda100% | 0% | 0% | 0% | 0%
jakartams0% | 100% | 0% | 0% | 0%
aws-spi-pekko-http0% | 100% | 0% | 0% | 0%
mqttv50% | 0% | 0% | 0% | 100%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
s396% | 3% | 0% | 0% | 0%
mqtt-streaming100% | 0% | 0% | 0% | 0%
jms99% | <1% | 0% | 0% | 0%
google-cloud-bigquery100% | 0% | 0% | 0% | 0%
elasticsearch100% | 0% | 0% | 0% | 0%
file95% | 4% | 0% | 0% | 0%
google-common81% | 10% | 0% | 7% | 0%
pravega100% | 0% | 0% | 0% | 0%
google-fcm100% | 0% | 0% | 0% | 0%
couchbase100% | 0% | 0% | 0% | 0%
google-cloud-storage58% | 0% | 0% | 24% | 17%
kinesis100% | 0% | 0% | 0% | 0%
sqs80% | 19% | 0% | 0% | 0%
huawei-push-kit100% | 0% | 0% | 0% | 0%
google-cloud-bigquery-storage91% | 8% | 0% | 0% | 0%
geode96% | 3% | 0% | 0% | 0%
hdfs100% | 0% | 0% | 0% | 0%
amqp48% | 51% | 0% | 0% | 0%
mqtt100% | 0% | 0% | 0% | 0%
csv78% | 21% | 0% | 0% | 0%
ftp38% | 61% | 0% | 0% | 0%
ironmq100% | 0% | 0% | 0% | 0%
influxdb100% | 0% | 0% | 0% | 0%
cassandra100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
solr100% | 0% | 0% | 0% | 0%
google-cloud-pub-sub100% | 0% | 0% | 0% | 0%
couchbase3100% | 0% | 0% | 0% | 0%
google-cloud-pub-sub-grpc100% | 0% | 0% | 0% | 0%
orientdb100% | 0% | 0% | 0% | 0%
reference100% | 0% | 0% | 0% | 0%
project38% | 3% | 3% | 0% | 54%
mongodb100% | 0% | 0% | 0% | 0%
hbase100% | 0% | 0% | 0% | 0%
slick87% | 0% | 12% | 0% | 0%
azure-storage-queue100% | 0% | 0% | 0% | 0%
mqtt-streaming-bench100% | 0% | 0% | 0% | 0%
kudu100% | 0% | 0% | 0% | 0%
testkit100% | 0% | 0% | 0% | 0%
text84% | 15% | 0% | 0% | 0%
udp68% | 0% | 0% | 31% | 0%
avroparquet100% | 0% | 0% | 0% | 0%
dynamodb100% | 0% | 0% | 0% | 0%
unix-domain-socket23% | 76% | 0% | 0% | 0%
sse100% | 0% | 0% | 0% | 0%
simple-codecs100% | 0% | 0% | 0% | 0%
sns100% | 0% | 0% | 0% | 0%
aws-event-bridge100% | 0% | 0% | 0% | 0%
spring-web100% | 0% | 0% | 0% | 0%
json-streaming100% | 0% | 0% | 0% | 0%
csv-bench100% | 0% | 0% | 0% | 0%
awslambda100% | 0% | 0% | 0% | 0%
jakartams0% | 100% | 0% | 0% | 0%
aws-spi-pekko-http0% | 100% | 0% | 0% | 0%
mqttv50% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
build.sbt
in root
 426 2 2016-05-10 2025-04-23 323 69 patrik.nordwall@gmail.com sndnv@users.noreply.github.com
plugins.sbt
in project
 19 - 2016-05-10 2024-11-14 157 25 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
Common.scala
in project
 101 1 2016-08-11 2024-03-22 80 18 mmartynas@gmail.com pjfanning@users.noreply.git...
437 1 2016-10-26 2025-05-07 422 112 mmartynas@gmail.com pjfanning@users.noreply.git...
cache.xml
in geode/scripts
 23 - 2017-02-23 2017-06-04 2 2 olivier.nouguier@gmail.com mmartynas@gmail.com
40 1 2017-09-18 2024-02-25 14 10 github@bzzt.net 35491928+laglangyue@users.n...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
22 - 2023-01-10 2024-06-02 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
100 3 2023-02-20 2023-08-06 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
17 - 2023-02-20 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3Stream.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 1288 52 2023-03-14 2024-02-09 12 3 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
model.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 936 61 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ServerState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 808 10 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming
 712 48 2023-03-14 2023-06-23 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/javadsl
 659 19 2023-03-14 2023-11-12 11 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
ClientState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 608 8 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MqttSession.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/scaladsl
 572 13 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms
 501 21 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3
 499 19 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
RequestState.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 466 11 2023-03-14 2023-11-01 5 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 439 6 2023-03-14 2024-07-07 6 3 pjfanning@users.noreply.git... arnout@bzzt.net
PravegaSettings.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 436 13 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2025-04-07 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
S3.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/scaladsl
 417 5 2023-03-14 2023-11-12 5 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
JmsConnector.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 332 22 2023-03-14 2024-02-22 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp
 327 9 2023-03-14 2024-06-03 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectionProvider.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 315 15 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpApi.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/javadsl
 313 20 2023-03-14 2024-06-03 9 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
HttpRequests.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 305 15 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16 2023-03-14 2025-04-23 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
MqttFlowStage.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt/impl
 297 17 2023-03-14 2024-02-17 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpIOGraphStage.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 292 4 2023-03-14 2024-01-28 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AmqpConnectorSettings.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp
 289 13 2023-03-14 2024-06-24 7 3 pjfanning@users.noreply.git... diogomoura13@gmail.com
ElasticsearchSourceStage.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 265 11 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Marshalling.scala
in s3/src/main/scala/org/apache/pekko/stream/connectors/s3/impl
 259 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PubSubApi.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub/impl
 233 14 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
QueryJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 225 4 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Formats.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 224 8 2023-03-14 2023-06-23 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TarReaderStage.scala
in file/src/main/scala/org/apache/pekko/stream/connectors/file/impl/archive
 224 1 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in google-cloud-pub-sub/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/pubsub
 222 21 2023-03-14 2024-01-14 8 2 pjfanning@users.noreply.git... matthew.dedetrich@aiven.io
FcmJsonSupport.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm/v1/impl
 218 17 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FcmSettings.scala
in google-fcm/src/main/scala/org/apache/pekko/stream/connectors/google/firebase/fcm
 213 12 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
settings.scala
in mqtt/src/main/scala/org/apache/pekko/stream/connectors/mqtt
 211 3 2023-03-14 2024-02-17 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
GoogleSettings.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 205 12 2023-03-14 2023-06-23 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 203 11 2023-03-14 2023-06-23 8 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
SqsModel.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 203 21 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStage.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 202 4 2023-03-14 2023-06-26 5 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JobJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/model
 200 15 2023-03-14 2023-06-23 7 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
FtpSourceFactory.scala
in ftp/src/main/scala/org/apache/pekko/stream/connectors/ftp/impl
 196 10 2023-03-14 2024-06-03 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PushKitJsonSupport.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/impl
 193 10 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
cache.xml
in geode/scripts
 23 - 2017-02-23 2017-06-04 2 2 olivier.nouguier@gmail.com mmartynas@gmail.com
ObjectEncoder.scala
in geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx
 23 - 2023-06-10 2023-06-10 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
ObjectEncoder.scala
in geode/src/main/scala-2/org/apache/pekko/stream/connectors/geode/impl/pdx
 26 2 2023-06-10 2023-06-10 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
ObjectDecoder.scala
in geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx
 26 - 2023-06-10 2023-06-10 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
ObjectDecoder.scala
in geode/src/main/scala-2/org/apache/pekko/stream/connectors/geode/impl/pdx
 28 2 2023-06-10 2023-06-10 1 1 matthew.dedetrich@aiven.io matthew.dedetrich@aiven.io
ApiVersionBase.java
in elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch
 2 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ObjectNotFoundException.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 2 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PravegaEvent.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 3 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
TableEntry.scala
in pravega/src/main/scala/org/apache/pekko/stream/connectors/pravega
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchApiVersion.java
in elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchParams.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Paginated.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/scaladsl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BucketInfo.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MultiPartUpload.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 4 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisSchedulerErrors.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesis
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
PekkoPdxSerializer.scala
in geode/src/main/scala/org/apache/pekko/stream/connectors/geode
 5 - 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ApiVersion.java
in elasticsearch/src/main/java/org/apache/pekko/stream/connectors/elasticsearch
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CsvQuotingStyle.java
in csv/src/main/java/org/apache/pekko/stream/connectors/csv/javadsl
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
model.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv
 5 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CassandraServerMetaData.scala
in cassandra/src/main/scala/org/apache/pekko/stream/connectors/cassandra
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
DirectoryChange.java
in file/src/main/java/org/apache/pekko/stream/connectors/file
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Schema.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryNumber.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryStandardFormats.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 6 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
NDJsonProtocol.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/impl
 7 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
OpensearchConnectionSettings.scala
in elasticsearch/src/main/scala/org/apache/pekko/stream/connectors/elasticsearch
 7 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
7 - 2018-03-02 2023-06-23 7 5 458526+ennru@users.noreply.... pjfanning@users.noreply.git...
BigQuerySchemas.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema
 8 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
StandardSchemas.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/schema
 8 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryBytes.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 8 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
attributes.scala
in reference/src/main/scala/org/apache/pekko/stream/connectors/reference
 9 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Strategy.scala
in hdfs/src/main/scala/org/apache/pekko/stream/connectors/hdfs/impl/strategy
 9 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MongoSource.scala
in mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/javadsl
 9 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
MongoSource.scala
in mongodb/src/main/scala/org/apache/pekko/stream/connectors/mongodb/scaladsl
 9 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryRestJsonProtocol.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl/spray
 9 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
XUploadContentType.java
in google-common/src/main/java/org/apache/pekko/stream/connectors/google/javadsl
 9 1 2023-03-14 2023-06-23 3 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
package.scala
in slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl
 9 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KinesisFirehoseErrors.scala
in kinesis/src/main/scala/org/apache/pekko/stream/connectors/kinesisfirehose
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AwsLambdaFlow.scala
in awslambda/src/main/scala/org/apache/pekko/stream/connectors/awslambda/javadsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
KuduAttributes.scala
in kudu/src/main/scala/org/apache/pekko/stream/connectors/kudu
 10 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsInternalMatValues.scala
in jms/src/main/scala/org/apache/pekko/stream/connectors/jms/impl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
RecordIOFraming.scala
in simple-codecs/src/main/scala/org/apache/pekko/stream/connectors/recordio/scaladsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQuery.scala
in google-cloud-bigquery/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/scaladsl
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
CommittableReadResult.scala
in amqp/src/main/scala/org/apache/pekko/stream/connectors/amqp/scaladsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BigQueryStorageAttributes.scala
in google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/scaladsl
 10 - 2023-03-14 2023-06-23 4 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ActorName.scala
in mqtt-streaming/src/main/scala/org/apache/pekko/stream/connectors/mqtt/streaming/impl
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
ByteOrderMark.scala
in csv/src/main/scala/org/apache/pekko/stream/connectors/csv/scaladsl
 10 - 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
BasicNotification.scala
in huawei-push-kit/src/main/scala/org/apache/pekko/stream/connectors/huawei/pushkit/models
 10 1 2023-03-14 2023-06-23 2 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AvroParquetFlow.scala
in avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
AvroParquetSource.scala
in avroparquet/src/main/scala/org/apache/pekko/stream/connectors/avroparquet/javadsl
 10 - 2023-03-14 2023-06-23 3 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MqttFlowStage.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 429 18 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
settings.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 330 5 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttFlowStageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 72 3 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
model.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 47 2 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttFlow.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 46 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttFlow.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 36 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSource.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 26 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSource.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 22 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttMessageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 19 2 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttMessageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 19 1 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSink.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 16 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSink.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 15 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
SlickWithTryResult.scala
in slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl
 34 1 2025-01-25 2025-01-25 1 1 34303486+minjibir@users.nor... 34303486+minjibir@users.nor...
JmsConnectorState.java
in jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl
 10 - 2024-07-03 2024-07-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConnectorState.java
in jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl
 10 - 2024-07-03 2024-07-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConsumerControl.java
in jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl
 7 - 2024-07-03 2024-07-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsConsumerControl.java
in jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl
 7 - 2024-07-03 2024-07-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStatus.java
in jms/src/main/java/org/apache/pekko/stream/connectors/jms/javadsl
 6 - 2024-07-03 2024-07-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsProducerStatus.java
in jakartams/src/main/java/org/apache/pekko/stream/connectors/jakartams/javadsl
 6 - 2024-07-03 2024-07-03 1 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
JmsMessages.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 501 21 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConnector.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 332 22 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsProducerStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 203 4 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumerSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 142 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
SourceStageLogic.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 115 6 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
JmsMessageProducer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 103 6 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsProducerSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 97 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
Sessions.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 88 5 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsBrowseSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 77 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
ConnectionRetrySettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 70 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
Headers.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 68 9 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
JmsProducer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl
 66 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsTxSourceStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 66 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 63 7 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsAckSourceStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 62 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsMessageReader.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 60 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
SendRetrySettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 58 2 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
JmsBrowseStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 52 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsProducer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 49 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumerStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 47 4 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl
 45 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
Credentials.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 45 3 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
JmsExceptions.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 38 - 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
AcknowledgeMode.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 38 3 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
JmsConnectorState.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 33 - 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
Destinations.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 30 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
SoftReferenceCache.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 26 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
package.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 22 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
InternalConnectionState.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 21 - 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
Envelopes.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 16 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
GraphStageCompanion.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 14 - 2024-07-02 2024-07-02 1 1 samuele.resca@gmail.com samuele.resca@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
437 1 2016-10-26 2025-05-07 422 112 mmartynas@gmail.com pjfanning@users.noreply.git...
MqttFlowStage.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 429 18 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
build.sbt
in root
 426 2 2016-05-10 2025-04-23 323 69 patrik.nordwall@gmail.com sndnv@users.noreply.github.com
settings.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 330 5 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
GCStorageStream.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage/impl
 298 16 2023-03-14 2025-04-23 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
MqttFlowStageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/impl
 72 3 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
model.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5
 47 2 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttFlow.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 46 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttFlow.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 36 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSource.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 26 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSource.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 22 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttMessageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 19 2 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttMessageWithAck.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 19 1 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSink.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/javadsl
 16 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
MqttSink.scala
in mqttv5/src/main/scala/org/apache/pekko/stream/connectors/mqttv5/scaladsl
 15 - 2025-04-23 2025-04-23 1 1 sndnv@users.noreply.github.com sndnv@users.noreply.github.com
StorageObject.scala
in google-cloud-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/storage
 419 2 2023-03-14 2025-04-07 8 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
UdpBind.scala
in udp/src/main/scala/org/apache/pekko/stream/connectors/udp/impl
 78 5 2023-03-14 2025-03-31 4 3 pjfanning@users.noreply.git... 46769049+sdeigm@users.norep...
GoogleHttp.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google/http
 119 6 2023-03-14 2025-03-30 6 3 pjfanning@users.noreply.git... mdedetrich@gmail.com
SlickWithTryResult.scala
in slick/src/main/scala/org/apache/pekko/stream/connectors/slick/scaladsl
 34 1 2025-01-25 2025-01-25 1 1 34303486+minjibir@users.nor... 34303486+minjibir@users.nor...
6 - 2024-01-15 2025-01-09 6 1 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
plugins.sbt
in project
 19 - 2016-05-10 2024-11-14 157 25 patrik.nordwall@gmail.com pjfanning@users.noreply.git...
6 - 2024-01-16 2024-10-01 4 2 matthew.dedetrich@aiven.io pjfanning@users.noreply.git...
PekkoHttpClient.scala
in aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi
 202 10 2024-06-12 2024-09-27 3 2 pjfanning@users.noreply.git... jtjeferreira@gmail.com
RequestRunner.scala
in aws-spi-pekko-http/src/main/scala/org/apache/pekko/stream/connectors/awsspi
 52 2 2024-06-12 2024-09-27 3 2 pjfanning@users.noreply.git... jtjeferreira@gmail.com
ResumableUpload.scala
in google-common/src/main/scala/org/apache/pekko/stream/connectors/google
 163 5 2023-03-14 2024-09-14 10 4 pjfanning@users.noreply.git... mdedetrich@gmail.com
SqsPublishFlow.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs/scaladsl
 96 2 2023-03-14 2024-08-06 9 3 pjfanning@users.noreply.git... llazanja96@gmail.com
SqsSourceSettings.scala
in sqs/src/main/scala/org/apache/pekko/stream/connectors/sqs
 128 3 2023-03-14 2024-08-03 6 2 pjfanning@users.noreply.git... pjfanning@users.noreply.git...
LabelledGenericGeneric.scala
in geode/src/main/scala-3/org/apache/pekko/stream/connectors/geode/impl/pdx
 37 3 2023-06-10 2024-07-19 2 2 matthew.dedetrich@aiven.io wojciech.mazur95@gmail.com
UnixDomainSocketImpl.scala
in unix-domain-socket/src/main/scala/org/apache/pekko/stream/connectors/unixdomainsocket/impl
 439 6 2023-03-14 2024-07-07 6 3 pjfanning@users.noreply.git... arnout@bzzt.net
JmsMessages.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 501 21 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConnector.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 332 22 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsProducerStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 203 4 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsMessageProducer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 103 6 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
Sessions.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 88 5 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
ConnectionRetrySettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 70 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsProducer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl
 66 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsTxSourceStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 66 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 63 7 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsAckSourceStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 62 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsMessageReader.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 60 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsBrowseStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 52 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsProducer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 49 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumerStage.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 47 4 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConsumer.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/javadsl
 45 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsConnectorState.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 33 - 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
Destinations.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 30 2 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
SoftReferenceCache.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/impl
 26 3 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
package.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams/scaladsl
 22 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
Envelopes.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 16 1 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...
JmsSettings.scala
in jakartams/src/main/scala/org/apache/pekko/stream/connectors/jakartams
 13 - 2024-07-02 2024-07-03 2 2 samuele.resca@gmail.com pjfanning@users.noreply.git...