public class InMemoryBroker extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
InMemoryBroker.Subscriber
Subscriber interface to be implemented to subscribe to in-memory broker.
|
Constructor and Description |
---|
InMemoryBroker() |
Modifier and Type | Method and Description |
---|---|
static void |
publish(String topic,
Object message) |
static void |
subscribe(InMemoryBroker.Subscriber subscriber) |
static void |
unsubscribe(InMemoryBroker.Subscriber subscriber) |
public static void subscribe(InMemoryBroker.Subscriber subscriber)
public static void unsubscribe(InMemoryBroker.Subscriber subscriber)
public static void publish(String topic, Object message) throws SubscriberUnAvailableException
SubscriberUnAvailableException
Copyright © 2021. All rights reserved.