Giter VIP home page Giter VIP logo

akka-customer's Introduction

Introduction

This is a sample Akka/Java application that has a Customer service that allows you, via REST, to:

  1. Add a customer
  2. Get a customer
  3. List customers (via read-side view)
  4. Disable a customer (acting as a soft delete)

This implementation uses Cassandra for both the write-side and read-side.

Features

  • Akka HTTP (with HttpApp bootstrap)
  • Bulkheading of blocking HTTP call with custom dispatcher
  • Akka Persistence (with Cassandra)
  • Akka Persistence Query (for CQRS using eventsByTag and a stored offset)
  • Akka Cluster
  • Akka Cluster Sharding for CustomerPersistentActor
  • Kryo Serializer
  • Lombok (for @Value immutable object)
  • Guava for ImmutableList (you can use PCollections too)
  • SBT Revolver for hot reloading of application after code changes (see SBT commands)
  • Docker image build and publish (see SBT commands)
  • Kubernetes deployment script (see other .md files)

Useful SBT Commands

Cassandra

You must be running Cassandra separately when executing on local machine; default port is 9042.

Example curl commands

  1. curl -H "Content-Type: application/json" -X POST -d '{"name": "Eric Murphy", "city": "San Francisco", "state": "CA", "zipCode": "94105"}' http://localhost:9000/customer
  2. curl http://localhost:9000/customer/51c25a39-39b8-4937-b56b-5cca7f79acc1
  3. curl http://localhost:9000/customer
  4. curl -X PUT http://localhost:9000/customer/disable/51c25a39-39b8-4937-b56b-5cca7f79acc1
  5. curl http://localhost:9000/customer/51c25a39-39b8-4937-b56b-5cca7f79acc1 (run again to check disabled)

akka-customer's People

Contributors

murphye avatar

Stargazers

 avatar  avatar

Watchers

 avatar

Forkers

aolmez yasir2000

akka-customer's Issues

Question on running unit tests with `CassandraLauncher`

I've been using your akka-customer sample project as one of my resources for grokking testing Akka Persistence Cassandra, and have a question about cassandra-env.sh issues when using CassandraLoader:
I'm seeing the following in my terminal window near the beginning of my test suite:
11/05 13:16:32 ERROR[main] o.a.c.s.StartupChecks - cassandra.jmx.local.port missing from cassandra-env.sh, unable to start local JMX service.

I may be off, but I can't help but think that the error above is responsible for the rest...

Further down, I'm seeing multiple connection errors:
13:17:14.830 [cluster2-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[/127.0.0.1:19042-1, inFlight=0, closed=false] connection error java.io.IOException: Connection reset by peer ...
And further multiple connection errors:
com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:19042] Cannot connect
...
Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: /127.0.0.1:19042

I did some research on the LOCAL_JMX issue, and that is something that would usually be dealt with in the cassandra-env.sh file, which we don't have for the embedded C*.
And I tried doing a fork in Test := true, followed by a envVars in Test := Map("LOCAL_JMX" -> "no") in my build.sbt, but to no avail.

Any thoughts?

cassandralauncher-unittests-stacktrace.txt

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    ๐Ÿ–– Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. ๐Ÿ“Š๐Ÿ“ˆ๐ŸŽ‰

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google โค๏ธ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.