public class Broker
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private java.util.List<java.lang.String> |
accounts
List of accounts for this broker
|
private java.util.Map<java.lang.String,BrokerParameters> |
instances
Remote broker instances registered for this broker
|
private static CentralLogger |
LOG
Logger.
|
| Constructor and Description |
|---|
Broker(java.util.List<java.lang.String> accounts)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addAccount(java.lang.String account)
Add an account for this broker.
|
void |
addBroker(BrokerParameters params)
Register a new remote broker instance.
|
boolean |
findBroker(java.lang.String uuid)
Find a broker based on UUID
|
BrokerParameters |
getBroker(java.lang.String uuid)
Get a broker instance based on UUID
|
java.util.Map<java.lang.String,BrokerParameters> |
getBrokers()
Get broker instances.
|
boolean |
hasAccount(java.lang.String account)
Check if a specific account is define for this broker.
|
boolean |
noAccounts()
Check if broker has no accounts.
|
boolean |
removeBroker(Session session)
Remove a broker instance based on session.
|
void |
shutdown()
Close brokers session on server shutdown.
|
private static final CentralLogger LOG
private java.util.List<java.lang.String> accounts
private java.util.Map<java.lang.String,BrokerParameters> instances
public Broker(java.util.List<java.lang.String> accounts)
accounts - Accounts list or null if no accounts are defined for this broker.public void addAccount(java.lang.String account)
account - P2J or OS account.public void addBroker(BrokerParameters params)
params - Remote broker parameters.public void shutdown()
public boolean removeBroker(Session session)
session - Broker session.true on successful remove.public boolean hasAccount(java.lang.String account)
account - P2J or OS account.true if account is defined.public boolean noAccounts()
true if no accounts are defined.public java.util.Map<java.lang.String,BrokerParameters> getBrokers()
public boolean findBroker(java.lang.String uuid)
uuid - Broker UUID.true when broker is found.public BrokerParameters getBroker(java.lang.String uuid)
uuid - Broker UUID.