Reactive Event Hub
Reactive Hub is a collection of multi-receiver and multi-producer Proxies connecting Publishers and Subscribers so that Subscribers can receive events without knowledge of which Publishers, if any, there are, while maintaining easily identifiable connection between them.
It is ideal for centralizing cross-cutting activities like UI updates, logging, alerting, monitoring, security, etc.
RxHub rxHub = new DefaultRxJava1Hub();
rxHub.getPub("src1").subscribe(System.out::println);
rxHub.addUpstream("src1", Observable.just(1));
rxHub.addUpstream("src1", Observable.just(5));
rxHub.getPub("src1").subscribe(System.err::println);
RHub allows Publish/Subscribe pattern implementation and thus helps decouple components. This can be compared to an EventBus where:
In RHub different set of events are separated into Proxies identified by a Tag(topic).
Check also the Gherkin Features
Find the latest JARs or grab via Maven:
<dependency>
<groupId>io.apptik.rhub</groupId>
<artifactId>XXX</artifactId>
<version>0.2.0-alpha1</version>
</dependency>
or Gradle:
compile 'io.apptik.rhub:XXX:0.2.0-alpha1'
Downloads of the released versions are available in Sonatype's releases
repository.
Snapshots of the development versions are available in Sonatype's snapshots
repository.
StackOverflow with tag 'rhub' or 'apptik'
Copyright (C) 2016 AppTik Project
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.