stack/core/src/main/java/org/apache/usergrid/mq/Queue.java - usergrid - Git at Google

 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
  * The ASF 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.apache.usergrid.mq;


 import java.util.Map;
 import java.util.TreeMap;
 import java.util.UUID;

 import org.apache.commons.lang.StringUtils;

 import org.apache.usergrid.utils.UUIDUtils;

 import com.fasterxml.jackson.annotation.JsonAnyGetter;
 import com.fasterxml.jackson.annotation.JsonAnySetter;
 import com.fasterxml.jackson.annotation.JsonIgnore;

 import static java.util.UUID.nameUUIDFromBytes;

 import static org.apache.commons.collections.MapUtils.getBooleanValue;
 import static org.apache.commons.collections.MapUtils.getByteValue;
 import static org.apache.commons.collections.MapUtils.getDoubleValue;
 import static org.apache.commons.collections.MapUtils.getFloatValue;
 import static org.apache.commons.collections.MapUtils.getIntValue;
 import static org.apache.commons.collections.MapUtils.getLongValue;
 import static org.apache.commons.collections.MapUtils.getShortValue;
 import static org.apache.commons.collections.MapUtils.getString;
 import static org.apache.usergrid.utils.MapUtils.hashMap;


 public class Queue {

     public static final String QUEUE_ID = "uuid";
     public static final String QUEUE_PATH = "path";
     public static final String QUEUE_CREATED = "created";
     public static final String QUEUE_MODIFIED = "modified";
     public static final String QUEUE_NEWEST = "newest";
     public static final String QUEUE_OLDEST = "oldest";

     @SuppressWarnings("rawtypes")
     public static final Map<String, Class> QUEUE_PROPERTIES =
             hashMap( QUEUE_PATH, ( Class ) String.class ).map( QUEUE_ID, UUID.class ).map( QUEUE_CREATED, Long.class )
                     .map( QUEUE_MODIFIED, Long.class ).map( QUEUE_NEWEST, UUID.class ).map( QUEUE_OLDEST, UUID.class );

     protected Map<String, Object> properties = new TreeMap<String, Object>( String.CASE_INSENSITIVE_ORDER );


     public Queue( String path ) {
         setPath( path );
     }


     public Queue( Map<String, Object> properties ) {
         this.properties.putAll( properties );
     }


     @Override
     public String toString() {
         return getPath();
     }


     @JsonIgnore
     public String getPath() {
         return getString( properties, QUEUE_PATH );
     }


     public void setPath( String path ) {
         properties.put( QUEUE_PATH, path );
     }


     @JsonIgnore
     public long getCreated() {
         return getLongValue( properties, QUEUE_CREATED );
     }


     public void setCreated( long created ) {
         properties.put( QUEUE_CREATED, created );
     }


     @JsonIgnore
     public long getModified() {
         return getLongValue( properties, QUEUE_MODIFIED );
     }


     public void setModified( long modified ) {
         properties.put( QUEUE_MODIFIED, modified );
     }


     public static Queue getDestination( String path ) {
         if ( path == null ) {
             return null;
         }
         return new Queue( path );
     }


     @JsonAnySetter
     public void setProperty( String key, Object value ) {
         properties.put( key, value );
     }


     @JsonAnyGetter
     public Map<String, Object> getProperties() {
         return properties;
     }


     public static String[] getQueueParentPaths( String queuePath ) {
         queuePath = queuePath.toLowerCase().trim();
         String[] segments = StringUtils.split( queuePath, '/' );
         String[] paths = new String[segments.length + 1];
         paths[0] = "/";
         for ( int i = 0; i < segments.length; i++ ) {
             paths[i + 1] = "/" + StringUtils.join( segments, '/', 0, i + 1 ) + "/";
         }
         return paths;
     }


     public static String[] getQueuePathSegments( String queuePath ) {
         queuePath = queuePath.toLowerCase().trim();
         String[] segments = StringUtils.split( queuePath, '/' );
         return segments;
     }


     public static String normalizeQueuePath( String queuePath ) {
         if ( queuePath == null ) {
             return null;
         }
         queuePath = queuePath.toLowerCase().trim();
         if ( queuePath.length() == 0 ) {
             return null;
         }
         queuePath = "/" + StringUtils.join( StringUtils.split( queuePath, '/' ), '/' );
         if ( !queuePath.endsWith( "/" ) ) {
             queuePath += "/";
         }
         return queuePath;
     }


     public static UUID getQueueId( String queuePath ) {
         if ( queuePath == null ) {
             return null;
         }
         // is the queuePath already a UUID?
         UUID uuid = UUIDUtils.tryGetUUID( queuePath );
         if ( uuid != null ) {
             return uuid;
         }
         // UUID queuePath string might have been normalized
         // look for /00000000-0000-0000-0000-000000000000/
         // or /00000000-0000-0000-0000-000000000000
         if ( ( queuePath.length() == 38 ) && queuePath.startsWith( "/" ) && queuePath.endsWith( "/" ) ) {
             uuid = UUIDUtils.tryExtractUUID( queuePath, 1 );
             if ( uuid != null ) {
                 return uuid;
             }
         }
         else if ( ( queuePath.length() == 37 ) && queuePath.startsWith( "/" ) ) {
             uuid = UUIDUtils.tryExtractUUID( queuePath, 1 );
             if ( uuid != null ) {
                 return uuid;
             }
         }
         queuePath = normalizeQueuePath( queuePath );
         if ( queuePath == null ) {
             return null;
         }
         uuid = nameUUIDFromBytes( queuePath.getBytes() );
         return uuid;
     }


     @JsonIgnore
     public UUID getUuid() {
         return getQueueId( getPath() );
     }


     public float getFloatProperty( String name ) {
         return getFloatValue( properties, name );
     }


     public void setFloatProperty( String name, float value ) {
         properties.put( name, value );
     }


     public double getDoubleProperty( String name ) {
         return getDoubleValue( properties, name );
     }


     public void setDoubleProperty( String name, double value ) {
         properties.put( name, value );
     }


     public int getIntProperty( String name ) {
         return getIntValue( properties, name );
     }


     public void setIntProperty( String name, int value ) {
         properties.put( name, value );
     }


     public long getLongProperty( String name ) {
         return getLongValue( properties, name );
     }


     public void setLongProperty( String name, long value ) {
         properties.put( name, value );
     }


     public Object getObjectProperty( String name ) {
         return properties.get( name );
     }


     public void setObjectProperty( String name, Object value ) {
         properties.put( name, value );
     }


     public short getShortProperty( String name ) {
         return getShortValue( properties, name );
     }


     public void setShortProperty( String name, short value ) {
         properties.put( name, value );
     }


     public String getStringProperty( String name ) {
         return getString( properties, name );
     }


     public void setStringProperty( String name, String value ) {
         properties.put( name, value );
     }


     public boolean getBooleanProperty( String name ) {
         return getBooleanValue( properties, name );
     }


     public void setBooleanProperty( String name, boolean value ) {
         properties.put( name, value );
     }


     public byte getByteProperty( String name ) {
         return getByteValue( properties, name );
     }


     public void setByteProperty( String name, byte value ) {
         properties.put( name, value );
     }
 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one or more
	* contributor license agreements. See the NOTICE file distributed with
	* this work for additional information regarding copyright ownership.
	* The ASF 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.apache.usergrid.mq;


	import java.util.Map;
	import java.util.TreeMap;
	import java.util.UUID;

	import org.apache.commons.lang.StringUtils;

	import org.apache.usergrid.utils.UUIDUtils;

	import com.fasterxml.jackson.annotation.JsonAnyGetter;
	import com.fasterxml.jackson.annotation.JsonAnySetter;
	import com.fasterxml.jackson.annotation.JsonIgnore;

	import static java.util.UUID.nameUUIDFromBytes;

	import static org.apache.commons.collections.MapUtils.getBooleanValue;
	import static org.apache.commons.collections.MapUtils.getByteValue;
	import static org.apache.commons.collections.MapUtils.getDoubleValue;
	import static org.apache.commons.collections.MapUtils.getFloatValue;
	import static org.apache.commons.collections.MapUtils.getIntValue;
	import static org.apache.commons.collections.MapUtils.getLongValue;
	import static org.apache.commons.collections.MapUtils.getShortValue;
	import static org.apache.commons.collections.MapUtils.getString;
	import static org.apache.usergrid.utils.MapUtils.hashMap;


	public class Queue {

	public static final String QUEUE_ID = "uuid";
	public static final String QUEUE_PATH = "path";
	public static final String QUEUE_CREATED = "created";
	public static final String QUEUE_MODIFIED = "modified";
	public static final String QUEUE_NEWEST = "newest";
	public static final String QUEUE_OLDEST = "oldest";

	@SuppressWarnings("rawtypes")
	public static final Map<String, Class> QUEUE_PROPERTIES =
	hashMap( QUEUE_PATH, ( Class ) String.class ).map( QUEUE_ID, UUID.class ).map( QUEUE_CREATED, Long.class )
	.map( QUEUE_MODIFIED, Long.class ).map( QUEUE_NEWEST, UUID.class ).map( QUEUE_OLDEST, UUID.class );

	protected Map<String, Object> properties = new TreeMap<String, Object>( String.CASE_INSENSITIVE_ORDER );


	public Queue( String path ) {
	setPath( path );
	}


	public Queue( Map<String, Object> properties ) {
	this.properties.putAll( properties );
	}


	@Override
	public String toString() {
	return getPath();
	}


	@JsonIgnore
	public String getPath() {
	return getString( properties, QUEUE_PATH );
	}


	public void setPath( String path ) {
	properties.put( QUEUE_PATH, path );
	}


	@JsonIgnore
	public long getCreated() {
	return getLongValue( properties, QUEUE_CREATED );
	}


	public void setCreated( long created ) {
	properties.put( QUEUE_CREATED, created );
	}


	@JsonIgnore
	public long getModified() {
	return getLongValue( properties, QUEUE_MODIFIED );
	}


	public void setModified( long modified ) {
	properties.put( QUEUE_MODIFIED, modified );
	}


	public static Queue getDestination( String path ) {
	if ( path == null ) {
	return null;
	}
	return new Queue( path );
	}


	@JsonAnySetter
	public void setProperty( String key, Object value ) {
	properties.put( key, value );
	}


	@JsonAnyGetter
	public Map<String, Object> getProperties() {
	return properties;
	}


	public static String[] getQueueParentPaths( String queuePath ) {
	queuePath = queuePath.toLowerCase().trim();
	String[] segments = StringUtils.split( queuePath, '/' );
	String[] paths = new String[segments.length + 1];
	paths[0] = "/";
	for ( int i = 0; i < segments.length; i++ ) {
	paths[i + 1] = "/" + StringUtils.join( segments, '/', 0, i + 1 ) + "/";
	}
	return paths;
	}


	public static String[] getQueuePathSegments( String queuePath ) {
	queuePath = queuePath.toLowerCase().trim();
	String[] segments = StringUtils.split( queuePath, '/' );
	return segments;
	}


	public static String normalizeQueuePath( String queuePath ) {
	if ( queuePath == null ) {
	return null;
	}
	queuePath = queuePath.toLowerCase().trim();
	if ( queuePath.length() == 0 ) {
	return null;
	}
	queuePath = "/" + StringUtils.join( StringUtils.split( queuePath, '/' ), '/' );
	if ( !queuePath.endsWith( "/" ) ) {
	queuePath += "/";
	}
	return queuePath;
	}


	public static UUID getQueueId( String queuePath ) {
	if ( queuePath == null ) {
	return null;
	}
	// is the queuePath already a UUID?
	UUID uuid = UUIDUtils.tryGetUUID( queuePath );
	if ( uuid != null ) {
	return uuid;
	}
	// UUID queuePath string might have been normalized
	// look for /00000000-0000-0000-0000-000000000000/
	// or /00000000-0000-0000-0000-000000000000
	if ( ( queuePath.length() == 38 ) && queuePath.startsWith( "/" ) && queuePath.endsWith( "/" ) ) {
	uuid = UUIDUtils.tryExtractUUID( queuePath, 1 );
	if ( uuid != null ) {
	return uuid;
	}
	}
	else if ( ( queuePath.length() == 37 ) && queuePath.startsWith( "/" ) ) {
	uuid = UUIDUtils.tryExtractUUID( queuePath, 1 );
	if ( uuid != null ) {
	return uuid;
	}
	}
	queuePath = normalizeQueuePath( queuePath );
	if ( queuePath == null ) {
	return null;
	}
	uuid = nameUUIDFromBytes( queuePath.getBytes() );
	return uuid;
	}


	@JsonIgnore
	public UUID getUuid() {
	return getQueueId( getPath() );
	}


	public float getFloatProperty( String name ) {
	return getFloatValue( properties, name );
	}


	public void setFloatProperty( String name, float value ) {
	properties.put( name, value );
	}


	public double getDoubleProperty( String name ) {
	return getDoubleValue( properties, name );
	}


	public void setDoubleProperty( String name, double value ) {
	properties.put( name, value );
	}


	public int getIntProperty( String name ) {
	return getIntValue( properties, name );
	}


	public void setIntProperty( String name, int value ) {
	properties.put( name, value );
	}


	public long getLongProperty( String name ) {
	return getLongValue( properties, name );
	}


	public void setLongProperty( String name, long value ) {
	properties.put( name, value );
	}


	public Object getObjectProperty( String name ) {
	return properties.get( name );
	}


	public void setObjectProperty( String name, Object value ) {
	properties.put( name, value );
	}


	public short getShortProperty( String name ) {
	return getShortValue( properties, name );
	}


	public void setShortProperty( String name, short value ) {
	properties.put( name, value );
	}


	public String getStringProperty( String name ) {
	return getString( properties, name );
	}


	public void setStringProperty( String name, String value ) {
	properties.put( name, value );
	}


	public boolean getBooleanProperty( String name ) {
	return getBooleanValue( properties, name );
	}


	public void setBooleanProperty( String name, boolean value ) {
	properties.put( name, value );
	}


	public byte getByteProperty( String name ) {
	return getByteValue( properties, name );
	}


	public void setByteProperty( String name, byte value ) {
	properties.put( name, value );
	}
	}