public class Naming extends Object
Modifier and Type | Field and Description |
---|---|
private static ConcurrentHashMap<String,IExchange> |
exchanges |
static org.objectweb.util.monolog.api.Logger |
logger |
private static ConcurrentHashMap<ProxyName,Proxy> |
proxies |
private static long |
queueCounter |
private static ConcurrentHashMap<String,Queue> |
queues |
Constructor and Description |
---|
Naming() |
Modifier and Type | Method and Description |
---|---|
static void |
bindExchange(String name,
IExchange ref) |
static void |
bindProxy(ProxyName proxyName,
Proxy ref) |
static void |
bindQueue(String name,
Queue ref) |
static void |
clearAll() |
static void |
createDefaults() |
static String |
getGlobalName(String name) |
static String |
getLocalName(String name)
name:
serverName/QueueName (serverName see a3servers.xml)
serverName/ExchangeName
QueueName
ExchangeName ...
|
static Collection<Proxy> |
getProxies() |
static Collection<Queue> |
getQueues() |
private static String |
getServerName(String name)
name:
- serverName/QueueName (serverName see a3servers.xml)
- serverName/ExchangeName
- QueueName
- ExchangeName ...
|
static boolean |
isLocal(String name)
name:
- serverName/QueueName (serverName see a3servers.xml)
- serverName/ExchangeName
- QueueName
- ExchangeName ...
|
static IExchange |
lookupExchange(String name) |
static Proxy |
lookupProxy(ProxyName proxyName) |
static Queue |
lookupQueue(String name) |
static String |
nextQueueName() |
static short |
resolveServerId(String name) |
static void |
unbindExchange(String name) |
static void |
unbindProxy(ProxyName proxyName) |
static void |
unbindQueue(String name) |
public static org.objectweb.util.monolog.api.Logger logger
private static long queueCounter
private static ConcurrentHashMap<String,IExchange> exchanges
private static ConcurrentHashMap<String,Queue> queues
private static ConcurrentHashMap<ProxyName,Proxy> proxies
public static void bindExchange(String name, IExchange ref) throws AlreadyBoundException
name
- ref
- AlreadyBoundException
public static void bindQueue(String name, Queue ref) throws AlreadyBoundException
name
- ref
- Exception
AlreadyBoundException
public static Collection<Queue> getQueues()
public static void unbindQueue(String name)
name
- public static void unbindExchange(String name)
name
- private static String getServerName(String name)
name
- public static String getLocalName(String name)
name
- public static boolean isLocal(String name)
name
- public static short resolveServerId(String name)
name
- Exception
public static void bindProxy(ProxyName proxyName, Proxy ref) throws AlreadyBoundException
name
- ref
- AlreadyBoundException
public static void unbindProxy(ProxyName proxyName)
name
- public static Collection<Proxy> getProxies()
public static void clearAll()
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.