The current OrcaJSONStream(InputStream) is just a guess at the actual interface, but has the basics: listens on a ZeroMQ socket (PUB/SUB? REQ/REP?) for incoming JSON objects, parses them as necessary, and hands them off for storage.
This should be developed in parallel with the new, combined JSON-over-ZMQ dispatch in Orca.
The current
OrcaJSONStream(InputStream)is just a guess at the actual interface, but has the basics: listens on a ZeroMQ socket (PUB/SUB? REQ/REP?) for incoming JSON objects, parses them as necessary, and hands them off for storage.This should be developed in parallel with the new, combined JSON-over-ZMQ dispatch in Orca.