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 java.util.logging.Logger |
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 java.util.logging.Logger 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.