A lightweight wrapper around SQLiteOpenHelper and ContentResolver which introduces reactive stream semantics to queries. SQL Brite's only responsibility is to be a mechanism for coordinating and composing the notification of updates to tables such that you can update queries as soon as data changes. This library is not an ORM. It is not a type-safe query mechanism. It won't serialize the same POJOs you use for Gson. It's not going to perform database migrations for you.

Sqlbrite - A lightweight wrapper around SQLiteOpenHelper which introduces reactive stream semantics to SQL operations

Scribe is a server for aggregating log data that's streamed in real time from clients. It is designed to be scalable and reliable. It is developed and maintained by Facebook. It is designed to scale to a very large number of nodes and be robust to network and node failures. There is a scribe server running on every node in the system, configured to aggregate messages and send them to a central scribe server (or servers) in larger groups.

Scribe - Real time log aggregation used in Facebook

EventBus is a publish/subscribe event bus for Android and Java. EventBus simplifies the communication between components, Decouples event senders and receivers.

EventBus - Event bus for Android and Java that simplifies communication between Activities, Fragments, Threads, Services, etc

Kafka provides a publish-subscribe solution that can handle all activity stream data and processing on a consumer-scale web site. This kind of activity (page views, searches, and other user actions) are a key ingredient in many of the social feature on the modern web. This data is typically handled by "logging" and ad hoc log aggregation solutions due to the throughput requirements. This kind of ad hoc solution is a viable solution to providing logging data to Hadoop.

Kafka - A high-throughput distributed messaging system

ActiveMQ Apollo is a faster, more reliable, easier to maintain messaging broker built from the foundations of the original ActiveMQ. It accomplishes this using a radically different threading and message dispatching architecture. Like ActiveMQ, Apollo is a multi-protocol broker and supports STOMP, AMQP, MQTT, Openwire, SSL, and WebSockets.

Apache Apollo - ActiveMQ's next generation of messaging 

Jafka mq is a distributed publish-subscribe messaging system cloned from Apache Kafka.
 
Its features include: 
<ul>
<li>Persistent messaging with O(1) disk structures that provide constant time performance even with many TB of stored messages.</li>
<li>High-throughput: even with very modest hardware single broker can support hundreds of thousands of messages per second.</li>
<li>Explicit support for partitioning messages over broker servers and distributing consumption over a cluster of consumer machines while maintaining per-partition ordering semantics.</li>
<li>Simple message format for many language clients.</li>
<li>Pure Java work</li>
</ul>

Jafka mq is a distributed publish-subscribe messaging system cloned from Apache Kafka.

Jafka - A fast and simple distributed publish-subscribe messaging system (mq)

Aeron is an efficient reliable unicast and multicast transport protocol. The Aeron protocol is designed to be run directly over many different types of transmission media, including shared memory/IPC, InfiniBand/RDMA, UDP, TCP, Raw IP, HTTP, WebSocket, BLE, etc.

Aeron - Efficient reliable unicast and multicast transport protocol

A high-throughput, persistent, distributed, publish-subscribe messaging system based on memory mapped file and Thrift RPC. 
Its design objectives are: 
<ol>
<li>Fast: close to the speed of direct memory access, both produding and consuming are close to O(1) memory access.</li>
<li>Persistent : all data in the system is persisted on disk and is crash resistant.</li>
<li>High-throughput: even with modest hardware Luxun can support handreds of thousands of messages per second.</li>
<li>Realtime : messages produced by producer threads should be immediately visible to consumer threads.</li>
<li>Distributed : explicit support for partitioning messages over Luxun servers and distributing consumption over a cluster of consumer machines while maintaining per-partition ordering semantics.</li>
<li>Multiple clients support : use <a href="http://thrift.apache.org/">Thrift RPC</a> as communication infrastructure, easy to generate different clients for different platforms.</li>
<li>Flexible consuming semantics : supports typical consume once queue, fan out queue, even supports consume by index when needed.</li>
</ol>

A high-throughput, persistent, distributed, publish-subscribe messaging system based on memory mapped file and Thrift RPC.

Luxun - A high-throughput, persistent, distributed, publish-subscribe messaging system based on memo

Discover open source projects across all platforms

Projects