chronicle-queue-stream

Akka Stream backed by Chronicle queue

License

License

GroupId

GroupId

com.codacy
ArtifactId

ArtifactId

chronicle-queue-stream_2.12
Last Version

Last Version

0.0.3
Release Date

Release Date

Type

Type

jar
Description

Description

chronicle-queue-stream
Akka Stream backed by Chronicle queue
Project URL

Project URL

https://www.codacy.com
Project Organization

Project Organization

Codacy
Source Code Management

Source Code Management

https://github.com/codacy/chronicle-queue-stream

Download chronicle-queue-stream_2.12

How to add to project

<!-- https://jarcasting.com/artifacts/com.codacy/chronicle-queue-stream_2.12/ -->
<dependency>
    <groupId>com.codacy</groupId>
    <artifactId>chronicle-queue-stream_2.12</artifactId>
    <version>0.0.3</version>
</dependency>
// https://jarcasting.com/artifacts/com.codacy/chronicle-queue-stream_2.12/
implementation 'com.codacy:chronicle-queue-stream_2.12:0.0.3'
// https://jarcasting.com/artifacts/com.codacy/chronicle-queue-stream_2.12/
implementation ("com.codacy:chronicle-queue-stream_2.12:0.0.3")
'com.codacy:chronicle-queue-stream_2.12:jar:0.0.3'
<dependency org="com.codacy" name="chronicle-queue-stream_2.12" rev="0.0.3">
  <artifact name="chronicle-queue-stream_2.12" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.codacy', module='chronicle-queue-stream_2.12', version='0.0.3')
)
libraryDependencies += "com.codacy" % "chronicle-queue-stream_2.12" % "0.0.3"
[com.codacy/chronicle-queue-stream_2.12 "0.0.3"]

Dependencies

compile (4)

Group / Artifact Type Version
org.scala-lang : scala-library jar 2.12.8
net.openhft : chronicle-queue jar 5.17.8
ch.qos.logback : logback-classic jar 1.2.3
com.typesafe.scala-logging : scala-logging_2.12 jar 3.9.0

provided (2)

Group / Artifact Type Version
com.typesafe.akka : akka-actor_2.12 jar 2.5.20
com.typesafe.akka : akka-stream_2.12 jar 2.5.20

test (2)

Group / Artifact Type Version
com.typesafe.akka : akka-testkit_2.12 jar 2.5.20
org.scalatest : scalatest_2.12 jar 3.0.5

Project Modules

There are no modules declared in this project.

Chronicle Queue Stream

This repo contains utilities to use a Chronicle Queue to back your Akka Source/Sink and Flow.

Credits

This repo elaborate a little further over the awesome work done in squbs-pattern. Because of very business related motivations (i.e. publishing this library with checked compatibility for Akka 2.4 and 2.5) we felt the need to fork instead of contributing upstream.

Usage

Most of the usage is extensively described here, where instead of PersistentBuffer you will use com.codacy.stream.ChronicleQueue.

We have to add that for inter-process communication we provide additional Source and Sink.

What is Codacy

Codacy is an Automated Code Review Tool that monitors your technical debt, helps you improve your code quality, teaches best practices to your developers, and helps you save time in Code Reviews.

Among Codacy’s features

  • Identify new Static Analysis issues
  • Commit and Pull Request Analysis with GitHub, BitBucket/Stash, GitLab (and also direct git repositories)
  • Auto-comments on Commits and Pull Requests
  • Integrations with Slack, HipChat, Jira, YouTrack
  • Track issues in Code Style, Security, Error Proneness, Performance, Unused Code and other categories

Codacy also helps keep track of Code Coverage, Code Duplication, and Code Complexity.

Codacy supports PHP, Python, Ruby, Java, JavaScript, and Scala, among others.

Free for Open Source

Codacy is free for Open Source projects.

License

chronicle-queue-stream is available under the Apache2 license. See the LICENSE file for more info.

com.codacy

Codacy

Versions

Version
0.0.3
0.0.2
0.0.1