Package org.ow2.joram.mom.amqp

Class Naming

java.lang.Object

org.ow2.joram.mom.amqp.Naming

public class Naming
extends Object

Naming directory for all local exchanges, proxies and queues.

Field Summary

Fields

Modifier and Type	Field	Description
private static ConcurrentHashMap<String,IExchange>	exchanges
private static Logger	logger
private static ConcurrentHashMap<ProxyName,Proxy>	proxies
private static long	queueCounter
private static ConcurrentHashMap<String,Queue>	queues

Constructor Summary

Constructors

Constructor	Description
Naming()

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static final Logger logger

queueCounter

private static long queueCounter

exchanges

private static ConcurrentHashMap<String,IExchange> exchanges

queues

private static ConcurrentHashMap<String,Queue> queues

proxies

private static ConcurrentHashMap<ProxyName,Proxy> proxies

Constructor Detail

Naming

public Naming()

Method Detail

nextQueueName

public static String nextQueueName()

Parameters:

name -

ref -

Throws:

Exception

bindExchange

public static void bindExchange(String name,
                                IExchange ref)
                         throws AlreadyBoundException

Parameters:

name -

ref -

Throws:

AlreadyBoundException

bindQueue

public static void bindQueue(String name,
                             Queue ref)
                      throws AlreadyBoundException

Parameters:

name -

ref -

Throws:

Exception

AlreadyBoundException

lookupExchange

public static IExchange lookupExchange(String name)

Parameters:

name -

Returns:

lookupQueue

public static Queue lookupQueue(String name)

Parameters:

name -

Returns:

getQueues

public static Collection<Queue> getQueues()

Returns:

unbindQueue

public static void unbindQueue(String name)

Parameters:

name -

unbindExchange

public static void unbindExchange(String name)

Parameters:

name -

getServerName

private static String getServerName(String name)

name: - serverName/QueueName (serverName see a3servers.xml) - serverName/ExchangeName - QueueName - ExchangeName ...

Parameters:

name -

Returns:

the server name

getLocalName

public static String getLocalName(String name)

name:

• serverName/QueueName (serverName see a3servers.xml)
• serverName/ExchangeName
• QueueName
• ExchangeName ...

Parameters:

name -

Returns:

the QueueName, ExchangeName.

getGlobalName

public static String getGlobalName(String name)

isLocal

public static boolean isLocal(String name)

name: - serverName/QueueName (serverName see a3servers.xml) - serverName/ExchangeName - QueueName - ExchangeName ...

Parameters:

name -

Returns:

true if local

resolveServerId

public static short resolveServerId(String name)

Parameters:

name -

Returns:

Throws:

Exception

bindProxy

public static void bindProxy(ProxyName proxyName,
                             Proxy ref)
                      throws AlreadyBoundException

Parameters:

name -

ref -

Throws:

AlreadyBoundException

unbindProxy

public static void unbindProxy(ProxyName proxyName)

Parameters:

name -

lookupProxy

public static Proxy lookupProxy(ProxyName proxyName)

Parameters:

proxyName -

Returns:

getProxies

public static Collection<Proxy> getProxies()

Returns:

clearAll

public static void clearAll()

createDefaults

public static void createDefaults()
                           throws Exception

Throws:

Exception