[hornetq-commits] JBoss hornetq SVN: r10721 - in trunk/tests/unit-tests/src/test/java/org/hornetq/tests: util and 1 other directory.

Author: borges Date: 2011-05-24 07:00:09 -0400 (Tue, 24 May 2011) New Revision: 10721 Added: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMContext.java trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMNameParser.java trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/NonSerializableFactory.java Removed: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMContext.java trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMNameParser.java trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/NonSerializableFactory.java Log: Move classes into correct package Copied: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMContext.java (from rev 10720, trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMContext.java) =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMContext.java (rev 0) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMContext.java 2011-05-24 11:00:09 UTC (rev 10721) @@ -0,0 +1,377 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.tests.unit.util; + +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Collections; +import java.util.HashMap; +import java.util.Hashtable; +import java.util.Iterator; +import java.util.List; +import java.util.Map; + +import javax.naming.Binding; +import javax.naming.Context; +import javax.naming.Name; +import javax.naming.NameAlreadyBoundException; +import javax.naming.NameNotFoundException; +import javax.naming.NameParser; +import javax.naming.NamingEnumeration; +import javax.naming.NamingException; +import javax.naming.RefAddr; +import javax.naming.Reference; + +import org.hornetq.core.logging.Logger; + +/** + * @author <a href="mailto:ovidiu@feodorov.com">Ovidiu Feodorov</a> + * @version <tt>$Revision: 2868 $</tt> + * + * $Id: InVMContext.java 2868 2007-07-10 20:22:16Z timfox $ + */ +public class InVMContext implements Context, Serializable +{ + // Constants ----------------------------------------------------- + + private static final long serialVersionUID = 385743957345L; + + private static final Logger log = Logger.getLogger(InVMContext.class); + + // Static -------------------------------------------------------- + + // Attributes ---------------------------------------------------- + + protected Map map; + + protected NameParser parser = new InVMNameParser(); + + private String nameInNamespace = ""; + + // Constructors -------------------------------------------------- + + public InVMContext() + { + map = Collections.synchronizedMap(new HashMap()); + } + + public InVMContext(final String nameInNamespace) + { + this(); + this.nameInNamespace = nameInNamespace; + } + + // Context implementation ---------------------------------------- + + public Object lookup(final Name name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public Object lookup(String name) throws NamingException + { + name = trimSlashes(name); + int i = name.indexOf("/"); + String tok = i == -1 ? name : name.substring(0, i); + Object value = map.get(tok); + if (value == null) + { + throw new NameNotFoundException("Name not found: " + tok); + } + if (value instanceof InVMContext && i != -1) + { + return ((InVMContext)value).lookup(name.substring(i)); + } + if (value instanceof Reference) + { + Reference ref = (Reference)value; + RefAddr refAddr = ref.get("nns"); + + // we only deal with references create by NonSerializableFactory + String key = (String)refAddr.getContent(); + return NonSerializableFactory.lookup(key); + } + else + { + return value; + } + } + + public void bind(final Name name, final Object obj) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public void bind(final String name, final Object obj) throws NamingException + { + internalBind(name, obj, false); + } + + public void rebind(final Name name, final Object obj) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public void rebind(final String name, final Object obj) throws NamingException + { + internalBind(name, obj, true); + } + + public void unbind(final Name name) throws NamingException + { + unbind(name.toString()); + } + + public void unbind(String name) throws NamingException + { + name = trimSlashes(name); + int i = name.indexOf("/"); + boolean terminal = i == -1; + if (terminal) + { + map.remove(name); + } + else + { + String tok = name.substring(0, i); + InVMContext c = (InVMContext)map.get(tok); + if (c == null) + { + throw new NameNotFoundException("Context not found: " + tok); + } + c.unbind(name.substring(i)); + } + } + + public void rename(final Name oldName, final Name newName) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public void rename(final String oldName, final String newName) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public NamingEnumeration list(final Name name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public NamingEnumeration list(final String name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public NamingEnumeration listBindings(final Name name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public NamingEnumeration listBindings(String contextName) throws NamingException + { + contextName = trimSlashes(contextName); + if (!"".equals(contextName) && !".".equals(contextName)) + { + try + { + return ((InVMContext)lookup(contextName)).listBindings(""); + } + catch (Throwable t) + { + throw new NamingException(t.getMessage()); + } + } + + List l = new ArrayList(); + for (Iterator i = map.keySet().iterator(); i.hasNext();) + { + String name = (String)i.next(); + Object object = map.get(name); + l.add(new Binding(name, object)); + } + return new NamingEnumerationImpl(l.iterator()); + } + + public void destroySubcontext(final Name name) throws NamingException + { + destroySubcontext(name.toString()); + } + + public void destroySubcontext(final String name) throws NamingException + { + map.remove(trimSlashes(name)); + } + + public Context createSubcontext(final Name name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public Context createSubcontext(String name) throws NamingException + { + name = trimSlashes(name); + if (map.get(name) != null) + { + throw new NameAlreadyBoundException(name); + } + InVMContext c = new InVMContext(getNameInNamespace()); + map.put(name, c); + return c; + } + + public Object lookupLink(final Name name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public Object lookupLink(final String name) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public NameParser getNameParser(final Name name) throws NamingException + { + return getNameParser(name.toString()); + } + + public NameParser getNameParser(final String name) throws NamingException + { + return parser; + } + + public Name composeName(final Name name, final Name prefix) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public String composeName(final String name, final String prefix) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public Object addToEnvironment(final String propName, final Object propVal) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public Object removeFromEnvironment(final String propName) throws NamingException + { + throw new UnsupportedOperationException(); + } + + public Hashtable getEnvironment() throws NamingException + { + Hashtable env = new Hashtable(); + env.put("java.naming.factory.initial", "org.hornetq.jms.tests.tools.container.InVMInitialContextFactory"); + env.put("java.naming.provider.url", "org.jboss.naming:org.jnp.interface"); + return env; + } + + public void close() throws NamingException + { + } + + public String getNameInNamespace() throws NamingException + { + return nameInNamespace; + } + + // Public -------------------------------------------------------- + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + private String trimSlashes(String s) + { + int i = 0; + while (true) + { + if (i == s.length() || s.charAt(i) != '/') + { + break; + } + i++; + } + s = s.substring(i); + i = s.length() - 1; + while (true) + { + if (i == -1 || s.charAt(i) != '/') + { + break; + } + i--; + } + return s.substring(0, i + 1); + } + + private void internalBind(String name, final Object obj, final boolean rebind) throws NamingException + { + InVMContext.log.debug("Binding " + name + " obj " + obj + " rebind " + rebind); + name = trimSlashes(name); + int i = name.lastIndexOf("/"); + InVMContext c = this; + if (i != -1) + { + String path = name.substring(0, i); + c = (InVMContext)lookup(path); + } + name = name.substring(i + 1); + if (!rebind && c.map.get(name) != null) + { + throw new NameAlreadyBoundException(name); + } + c.map.put(name, obj); + } + + // Inner classes ------------------------------------------------- + + private class NamingEnumerationImpl implements NamingEnumeration + { + private final Iterator iterator; + + NamingEnumerationImpl(final Iterator bindingIterator) + { + iterator = bindingIterator; + } + + public void close() throws NamingException + { + throw new UnsupportedOperationException(); + } + + public boolean hasMore() throws NamingException + { + return iterator.hasNext(); + } + + public Object next() throws NamingException + { + return iterator.next(); + } + + public boolean hasMoreElements() + { + return iterator.hasNext(); + } + + public Object nextElement() + { + return iterator.next(); + } + } +} Copied: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMNameParser.java (from rev 10720, trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMNameParser.java) =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMNameParser.java (rev 0) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/InVMNameParser.java 2011-05-24 11:00:09 UTC (rev 10721) @@ -0,0 +1,71 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.tests.unit.util; + +import java.io.Serializable; +import java.util.Properties; + +import javax.naming.CompoundName; +import javax.naming.Name; +import javax.naming.NameParser; +import javax.naming.NamingException; + +/** + * @author <a href="mailto:ovidiu@feodorov.com">Ovidiu Feodorov</a> + * @version <tt>$Revision: 2868 $</tt> + * + * $Id: InVMNameParser.java 2868 2007-07-10 20:22:16Z timfox $ + */ +public class InVMNameParser implements NameParser, Serializable +{ + // Constants ----------------------------------------------------- + + private static final long serialVersionUID = 2925203703371001031L; + + // Static -------------------------------------------------------- + + static Properties syntax; + + static + { + InVMNameParser.syntax = new Properties(); + InVMNameParser.syntax.put("jndi.syntax.direction", "left_to_right"); + InVMNameParser.syntax.put("jndi.syntax.ignorecase", "false"); + InVMNameParser.syntax.put("jndi.syntax.separator", "/"); + } + + // Attributes ---------------------------------------------------- + + // Constructors -------------------------------------------------- + + // Public -------------------------------------------------------- + + public static Properties getSyntax() + { + return InVMNameParser.syntax; + } + + public Name parse(final String name) throws NamingException + { + return new CompoundName(name, InVMNameParser.syntax); + } + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + +} Copied: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/NonSerializableFactory.java (from rev 10720, trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/NonSerializableFactory.java) =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/NonSerializableFactory.java (rev 0) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/util/NonSerializableFactory.java 2011-05-24 11:00:09 UTC (rev 10721) @@ -0,0 +1,106 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ +package org.hornetq.tests.unit.util; + +import java.util.Collections; +import java.util.HashMap; +import java.util.Hashtable; +import java.util.Map; + +import javax.naming.Context; +import javax.naming.Name; +import javax.naming.NamingException; +import javax.naming.RefAddr; +import javax.naming.Reference; +import javax.naming.StringRefAddr; +import javax.naming.spi.ObjectFactory; + +import org.jboss.util.naming.Util; + +/** + * used by the default context when running in embedded local configuration + * @author <a href=&quot;ataylor(a)redhat.com&quot;&gt;Andy Taylor</a> + */ +public class NonSerializableFactory implements ObjectFactory +{ + + public NonSerializableFactory() + { + } + + public static void unbind(final Context ctx, final String strName) throws NamingException + { + Name name = ctx.getNameParser("").parse(strName); + int size = name.size(); + String atom = name.get(size - 1); + Context parentCtx = Util.createSubcontext(ctx, name.getPrefix(size - 1)); + String key = new StringBuilder().append(parentCtx.getNameInNamespace()).append("/").append(atom).toString(); + NonSerializableFactory.getWrapperMap().remove(key); + Util.unbind(ctx, strName); + } + + public static void rebind(final Context ctx, final String strName, final Object value) throws NamingException + { + Name name = ctx.getNameParser("").parse(strName); + int size = name.size(); + String atom = name.get(size - 1); + Context parentCtx = Util.createSubcontext(ctx, name.getPrefix(size - 1)); + String key = new StringBuilder().append(parentCtx.getNameInNamespace()).append("/").append(atom).toString(); + NonSerializableFactory.getWrapperMap().put(key, value); + String className = value.getClass().getName(); + String factory = NonSerializableFactory.class.getName(); + StringRefAddr addr = new StringRefAddr("nns", key); + Reference memoryRef = new Reference(className, addr, factory, null); + parentCtx.rebind(atom, memoryRef); + } + + public static void bind(final Context ctx, final String strName, final Object value) throws NamingException + { + Name name = ctx.getNameParser("").parse(strName); + int size = name.size(); + String atom = name.get(size - 1); + Context parentCtx = Util.createSubcontext(ctx, name.getPrefix(size - 1)); + String key = new StringBuilder().append(parentCtx.getNameInNamespace()).append("/").append(atom).toString(); + NonSerializableFactory.getWrapperMap().put(key, value); + String className = value.getClass().getName(); + String factory = NonSerializableFactory.class.getName(); + StringRefAddr addr = new StringRefAddr("nns", key); + Reference memoryRef = new Reference(className, addr, factory, null); + + parentCtx.bind(atom, memoryRef); + } + + public static Object lookup(final String name) throws NamingException + { + if (NonSerializableFactory.getWrapperMap().get(name) == null) + { + throw new NamingException(name + " not found"); + } + return NonSerializableFactory.getWrapperMap().get(name); + } + + public Object getObjectInstance(final Object obj, final Name name, final Context nameCtx, final Hashtable env) throws Exception + { + Reference ref = (Reference)obj; + RefAddr addr = ref.get("nns"); + String key = (String)addr.getContent(); + return NonSerializableFactory.getWrapperMap().get(key); + } + + public static Map getWrapperMap() + { + return NonSerializableFactory.wrapperMap; + } + + private static Map wrapperMap = Collections.synchronizedMap(new HashMap()); +} \ No newline at end of file Deleted: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMContext.java =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMContext.java 2011-05-23 15:14:33 UTC (rev 10720) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMContext.java 2011-05-24 11:00:09 UTC (rev 10721) @@ -1,377 +0,0 @@ -/* - * Copyright 2009 Red Hat, Inc. - * Red Hat licenses this file to you under the Apache License, version - * 2.0 (the "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * http://www.apache.org/licenses/LICENSE-2.0 - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - * implied. See the License for the specific language governing - * permissions and limitations under the License. - */ -package org.hornetq.tests.unit.util; - -import java.io.Serializable; -import java.util.ArrayList; -import java.util.Collections; -import java.util.HashMap; -import java.util.Hashtable; -import java.util.Iterator; -import java.util.List; -import java.util.Map; - -import javax.naming.Binding; -import javax.naming.Context; -import javax.naming.Name; -import javax.naming.NameAlreadyBoundException; -import javax.naming.NameNotFoundException; -import javax.naming.NameParser; -import javax.naming.NamingEnumeration; -import javax.naming.NamingException; -import javax.naming.RefAddr; -import javax.naming.Reference; - -import org.hornetq.core.logging.Logger; - -/** - * @author <a href="mailto:ovidiu@feodorov.com">Ovidiu Feodorov</a> - * @version <tt>$Revision: 2868 $</tt> - * - * $Id: InVMContext.java 2868 2007-07-10 20:22:16Z timfox $ - */ -public class InVMContext implements Context, Serializable -{ - // Constants ----------------------------------------------------- - - private static final long serialVersionUID = 385743957345L; - - private static final Logger log = Logger.getLogger(InVMContext.class); - - // Static -------------------------------------------------------- - - // Attributes ---------------------------------------------------- - - protected Map map; - - protected NameParser parser = new InVMNameParser(); - - private String nameInNamespace = ""; - - // Constructors -------------------------------------------------- - - public InVMContext() - { - map = Collections.synchronizedMap(new HashMap()); - } - - public InVMContext(final String nameInNamespace) - { - this(); - this.nameInNamespace = nameInNamespace; - } - - // Context implementation ---------------------------------------- - - public Object lookup(final Name name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public Object lookup(String name) throws NamingException - { - name = trimSlashes(name); - int i = name.indexOf("/"); - String tok = i == -1 ? name : name.substring(0, i); - Object value = map.get(tok); - if (value == null) - { - throw new NameNotFoundException("Name not found: " + tok); - } - if (value instanceof InVMContext && i != -1) - { - return ((InVMContext)value).lookup(name.substring(i)); - } - if (value instanceof Reference) - { - Reference ref = (Reference)value; - RefAddr refAddr = ref.get("nns"); - - // we only deal with references create by NonSerializableFactory - String key = (String)refAddr.getContent(); - return NonSerializableFactory.lookup(key); - } - else - { - return value; - } - } - - public void bind(final Name name, final Object obj) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public void bind(final String name, final Object obj) throws NamingException - { - internalBind(name, obj, false); - } - - public void rebind(final Name name, final Object obj) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public void rebind(final String name, final Object obj) throws NamingException - { - internalBind(name, obj, true); - } - - public void unbind(final Name name) throws NamingException - { - unbind(name.toString()); - } - - public void unbind(String name) throws NamingException - { - name = trimSlashes(name); - int i = name.indexOf("/"); - boolean terminal = i == -1; - if (terminal) - { - map.remove(name); - } - else - { - String tok = name.substring(0, i); - InVMContext c = (InVMContext)map.get(tok); - if (c == null) - { - throw new NameNotFoundException("Context not found: " + tok); - } - c.unbind(name.substring(i)); - } - } - - public void rename(final Name oldName, final Name newName) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public void rename(final String oldName, final String newName) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public NamingEnumeration list(final Name name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public NamingEnumeration list(final String name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public NamingEnumeration listBindings(final Name name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public NamingEnumeration listBindings(String contextName) throws NamingException - { - contextName = trimSlashes(contextName); - if (!"".equals(contextName) && !".".equals(contextName)) - { - try - { - return ((InVMContext)lookup(contextName)).listBindings(""); - } - catch (Throwable t) - { - throw new NamingException(t.getMessage()); - } - } - - List l = new ArrayList(); - for (Iterator i = map.keySet().iterator(); i.hasNext();) - { - String name = (String)i.next(); - Object object = map.get(name); - l.add(new Binding(name, object)); - } - return new NamingEnumerationImpl(l.iterator()); - } - - public void destroySubcontext(final Name name) throws NamingException - { - destroySubcontext(name.toString()); - } - - public void destroySubcontext(final String name) throws NamingException - { - map.remove(trimSlashes(name)); - } - - public Context createSubcontext(final Name name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public Context createSubcontext(String name) throws NamingException - { - name = trimSlashes(name); - if (map.get(name) != null) - { - throw new NameAlreadyBoundException(name); - } - InVMContext c = new InVMContext(getNameInNamespace()); - map.put(name, c); - return c; - } - - public Object lookupLink(final Name name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public Object lookupLink(final String name) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public NameParser getNameParser(final Name name) throws NamingException - { - return getNameParser(name.toString()); - } - - public NameParser getNameParser(final String name) throws NamingException - { - return parser; - } - - public Name composeName(final Name name, final Name prefix) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public String composeName(final String name, final String prefix) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public Object addToEnvironment(final String propName, final Object propVal) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public Object removeFromEnvironment(final String propName) throws NamingException - { - throw new UnsupportedOperationException(); - } - - public Hashtable getEnvironment() throws NamingException - { - Hashtable env = new Hashtable(); - env.put("java.naming.factory.initial", "org.hornetq.jms.tests.tools.container.InVMInitialContextFactory"); - env.put("java.naming.provider.url", "org.jboss.naming:org.jnp.interface"); - return env; - } - - public void close() throws NamingException - { - } - - public String getNameInNamespace() throws NamingException - { - return nameInNamespace; - } - - // Public -------------------------------------------------------- - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - - // Private ------------------------------------------------------- - - private String trimSlashes(String s) - { - int i = 0; - while (true) - { - if (i == s.length() || s.charAt(i) != '/') - { - break; - } - i++; - } - s = s.substring(i); - i = s.length() - 1; - while (true) - { - if (i == -1 || s.charAt(i) != '/') - { - break; - } - i--; - } - return s.substring(0, i + 1); - } - - private void internalBind(String name, final Object obj, final boolean rebind) throws NamingException - { - InVMContext.log.debug("Binding " + name + " obj " + obj + " rebind " + rebind); - name = trimSlashes(name); - int i = name.lastIndexOf("/"); - InVMContext c = this; - if (i != -1) - { - String path = name.substring(0, i); - c = (InVMContext)lookup(path); - } - name = name.substring(i + 1); - if (!rebind && c.map.get(name) != null) - { - throw new NameAlreadyBoundException(name); - } - c.map.put(name, obj); - } - - // Inner classes ------------------------------------------------- - - private class NamingEnumerationImpl implements NamingEnumeration - { - private final Iterator iterator; - - NamingEnumerationImpl(final Iterator bindingIterator) - { - iterator = bindingIterator; - } - - public void close() throws NamingException - { - throw new UnsupportedOperationException(); - } - - public boolean hasMore() throws NamingException - { - return iterator.hasNext(); - } - - public Object next() throws NamingException - { - return iterator.next(); - } - - public boolean hasMoreElements() - { - return iterator.hasNext(); - } - - public Object nextElement() - { - return iterator.next(); - } - } -} Deleted: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMNameParser.java =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMNameParser.java 2011-05-23 15:14:33 UTC (rev 10720) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/InVMNameParser.java 2011-05-24 11:00:09 UTC (rev 10721) @@ -1,71 +0,0 @@ -/* - * Copyright 2009 Red Hat, Inc. - * Red Hat licenses this file to you under the Apache License, version - * 2.0 (the "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * http://www.apache.org/licenses/LICENSE-2.0 - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - * implied. See the License for the specific language governing - * permissions and limitations under the License. - */ -package org.hornetq.tests.unit.util; - -import java.io.Serializable; -import java.util.Properties; - -import javax.naming.CompoundName; -import javax.naming.Name; -import javax.naming.NameParser; -import javax.naming.NamingException; - -/** - * @author <a href="mailto:ovidiu@feodorov.com">Ovidiu Feodorov</a> - * @version <tt>$Revision: 2868 $</tt> - * - * $Id: InVMNameParser.java 2868 2007-07-10 20:22:16Z timfox $ - */ -public class InVMNameParser implements NameParser, Serializable -{ - // Constants ----------------------------------------------------- - - private static final long serialVersionUID = 2925203703371001031L; - - // Static -------------------------------------------------------- - - static Properties syntax; - - static - { - InVMNameParser.syntax = new Properties(); - InVMNameParser.syntax.put("jndi.syntax.direction", "left_to_right"); - InVMNameParser.syntax.put("jndi.syntax.ignorecase", "false"); - InVMNameParser.syntax.put("jndi.syntax.separator", "/"); - } - - // Attributes ---------------------------------------------------- - - // Constructors -------------------------------------------------- - - // Public -------------------------------------------------------- - - public static Properties getSyntax() - { - return InVMNameParser.syntax; - } - - public Name parse(final String name) throws NamingException - { - return new CompoundName(name, InVMNameParser.syntax); - } - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - - // Private ------------------------------------------------------- - - // Inner classes ------------------------------------------------- - -} Deleted: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/NonSerializableFactory.java =================================================================== --- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/NonSerializableFactory.java 2011-05-23 15:14:33 UTC (rev 10720) +++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/util/NonSerializableFactory.java 2011-05-24 11:00:09 UTC (rev 10721) @@ -1,106 +0,0 @@ -/* - * Copyright 2009 Red Hat, Inc. - * Red Hat licenses this file to you under the Apache License, version - * 2.0 (the "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * http://www.apache.org/licenses/LICENSE-2.0 - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - * implied. See the License for the specific language governing - * permissions and limitations under the License. - */ -package org.hornetq.tests.unit.util; - -import java.util.Collections; -import java.util.HashMap; -import java.util.Hashtable; -import java.util.Map; - -import javax.naming.Context; -import javax.naming.Name; -import javax.naming.NamingException; -import javax.naming.RefAddr; -import javax.naming.Reference; -import javax.naming.StringRefAddr; -import javax.naming.spi.ObjectFactory; - -import org.jboss.util.naming.Util; - -/** - * used by the default context when running in embedded local configuration - * @author <a href=&quot;ataylor(a)redhat.com&quot;&gt;Andy Taylor</a> - */ -public class NonSerializableFactory implements ObjectFactory -{ - - public NonSerializableFactory() - { - } - - public static void unbind(final Context ctx, final String strName) throws NamingException - { - Name name = ctx.getNameParser("").parse(strName); - int size = name.size(); - String atom = name.get(size - 1); - Context parentCtx = Util.createSubcontext(ctx, name.getPrefix(size - 1)); - String key = new StringBuilder().append(parentCtx.getNameInNamespace()).append("/").append(atom).toString(); - NonSerializableFactory.getWrapperMap().remove(key); - Util.unbind(ctx, strName); - } - - public static void rebind(final Context ctx, final String strName, final Object value) throws NamingException - { - Name name = ctx.getNameParser("").parse(strName); - int size = name.size(); - String atom = name.get(size - 1); - Context parentCtx = Util.createSubcontext(ctx, name.getPrefix(size - 1)); - String key = new StringBuilder().append(parentCtx.getNameInNamespace()).append("/").append(atom).toString(); - NonSerializableFactory.getWrapperMap().put(key, value); - String className = value.getClass().getName(); - String factory = NonSerializableFactory.class.getName(); - StringRefAddr addr = new StringRefAddr("nns", key); - Reference memoryRef = new Reference(className, addr, factory, null); - parentCtx.rebind(atom, memoryRef); - } - - public static void bind(final Context ctx, final String strName, final Object value) throws NamingException - { - Name name = ctx.getNameParser("").parse(strName); - int size = name.size(); - String atom = name.get(size - 1); - Context parentCtx = Util.createSubcontext(ctx, name.getPrefix(size - 1)); - String key = new StringBuilder().append(parentCtx.getNameInNamespace()).append("/").append(atom).toString(); - NonSerializableFactory.getWrapperMap().put(key, value); - String className = value.getClass().getName(); - String factory = NonSerializableFactory.class.getName(); - StringRefAddr addr = new StringRefAddr("nns", key); - Reference memoryRef = new Reference(className, addr, factory, null); - - parentCtx.bind(atom, memoryRef); - } - - public static Object lookup(final String name) throws NamingException - { - if (NonSerializableFactory.getWrapperMap().get(name) == null) - { - throw new NamingException(name + " not found"); - } - return NonSerializableFactory.getWrapperMap().get(name); - } - - public Object getObjectInstance(final Object obj, final Name name, final Context nameCtx, final Hashtable env) throws Exception - { - Reference ref = (Reference)obj; - RefAddr addr = ref.get("nns"); - String key = (String)addr.getContent(); - return NonSerializableFactory.getWrapperMap().get(key); - } - - public static Map getWrapperMap() - { - return NonSerializableFactory.wrapperMap; - } - - private static Map wrapperMap = Collections.synchronizedMap(new HashMap()); -} \ No newline at end of file