Skip to content
Permalink
Browse files
The Queue API for OpenStack Marconi.
  • Loading branch information
Everett Toews committed Oct 18, 2013
1 parent 2e92538 commit 60fd86d3cd09ad2e76ed6cfc5c3874e48278336a
Showing 8 changed files with 679 additions and 10 deletions.
@@ -0,0 +1,123 @@
/*
* Licensed to jclouds, Inc. (jclouds) under one or more
* contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. jclouds 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.jclouds.openstack.marconi.v1.domain;

import com.google.common.base.Objects;

import java.util.Date;

/**
* The age of messages in a queue.
*
* @author Everett Toews
*/
public class Aged {

private int age;
private Date created;

protected Aged(int age, Date created) {
this.age = age;
this.created = created;
}

/**
* @return Age of the oldest/newest message in seconds.
*/
public int getAge() {
return age;
}

/**
* @return Date/Time of the oldest/newest message.
*/
public Date getCreated() {
return created;
}

@Override
public int hashCode() {
return Objects.hashCode(age, created);
}

@Override
public boolean equals(Object obj) {
if (this == obj) return true;
if (obj == null || getClass() != obj.getClass()) return false;
Aged that = Aged.class.cast(obj);
return Objects.equal(this.age, that.age) && Objects.equal(this.created, that.created);
}

protected Objects.ToStringHelper string() {
return Objects.toStringHelper(this)
.add("age", age).add("created", created);
}

@Override
public String toString() {
return string().toString();
}

public static Builder builder() {
return new ConcreteBuilder();
}

public Builder toBuilder() {
return new ConcreteBuilder().fromAged(this);
}

public static abstract class Builder {
protected abstract Builder self();

protected int age;
protected Date created;

/**
* @see Aged#age
*/
public Builder age(int age) {
this.age = age;
return self();
}

/**
* @see Aged#created
*/
public Builder created(Date created) {
this.created = created;
return self();
}

public Aged build() {
return new Aged(age, created);
}

public Builder fromAged(Aged in) {
return this.age(in.getAge()).created(in.getCreated());
}
}

private static class ConcreteBuilder extends Builder {
@Override
protected ConcreteBuilder self() {
return this;
}
}

}
@@ -0,0 +1,187 @@
/*
* Licensed to jclouds, Inc. (jclouds) under one or more
* contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. jclouds 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.jclouds.openstack.marconi.v1.domain;

import com.google.common.base.Objects;
import com.google.common.base.Optional;
import org.jclouds.javax.annotation.Nullable;

import java.beans.ConstructorProperties;

/**
* Statistics on messages in this queue.
*
* @author Everett Toews
*/
public class MessagesStats {

private int claimed;
private int free;
private int total;
private Aged oldest;
private Aged newest;

@ConstructorProperties({
"claimed", "free", "total", "oldest", "newest"
})
protected MessagesStats(int claimed, int free, int total, @Nullable Aged oldest, @Nullable Aged newest) {
this.claimed = claimed;
this.free = free;
this.total = total;
this.oldest = oldest;
this.newest = newest;
}

/**
* @return The number of claimed messages in this queue.
*/
public int getClaimed() {
return claimed;
}

/**
* @return The number of free messages in this queue.
*/
public int getFree() {
return free;
}

/**
* @return The total number of messages in this queue.
*/
public int getTotal() {
return total;
}

/**
* @return Statistics on the oldest messages in this queue. If the value of total is 0, then oldest is not present.
*/
public Optional<Aged> getOldest() {
return Optional.fromNullable(oldest);
}

/**
* @return Statistics on the newest messages in this queue. If the value of total is 0, then newest is not present.
*/
public Optional<Aged> getNewest() {
return Optional.fromNullable(newest);
}

@Override
public int hashCode() {
return Objects.hashCode(claimed, free, total, oldest, newest);
}

@Override
public boolean equals(Object obj) {
if (this == obj) return true;
if (obj == null || getClass() != obj.getClass()) return false;
MessagesStats that = MessagesStats.class.cast(obj);
return Objects.equal(this.claimed, that.claimed)
&& Objects.equal(this.free, that.free)
&& Objects.equal(this.total, that.total)
&& Objects.equal(this.oldest, that.oldest)
&& Objects.equal(this.newest, that.newest);
}

protected Objects.ToStringHelper string() {
return Objects.toStringHelper(this).omitNullValues()
.add("claimed", claimed).add("free", free).add("total", total).add("oldest", oldest).add("newest", newest);
}

@Override
public String toString() {
return string().toString();
}

public static Builder builder() {
return new ConcreteBuilder();
}

public Builder toBuilder() {
return new ConcreteBuilder().fromMessagesStats(this);
}

public static abstract class Builder {
protected abstract Builder self();

protected int claimed;
protected int free;
protected int total;
protected Aged oldest;
protected Aged newest;

/**
* @see MessagesStats#claimed
*/
public Builder claimed(int claimed) {
this.claimed = claimed;
return self();
}

/**
* @see MessagesStats#free
*/
public Builder free(int free) {
this.free = free;
return self();
}

/**
* @see MessagesStats#total
*/
public Builder total(int total) {
this.total = total;
return self();
}

/**
* @see MessagesStats#oldest
*/
public Builder oldest(Aged oldest) {
this.oldest = oldest;
return self();
}

/**
* @see MessagesStats#newest
*/
public Builder newest(Aged newest) {
this.newest = newest;
return self();
}

public MessagesStats build() {
return new MessagesStats(claimed, free, total, oldest, newest);
}

public Builder fromMessagesStats(MessagesStats in) {
return this.claimed(in.getClaimed()).free(in.getFree()).total(in.getTotal()).oldest(in.getOldest().orNull())
.newest(in.getNewest().orNull());
}
}

private static class ConcreteBuilder extends Builder {
@Override
protected ConcreteBuilder self() {
return this;
}
}

}
@@ -0,0 +1,67 @@
/*
* Licensed to jclouds, Inc. (jclouds) under one or more
* contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. jclouds 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.jclouds.openstack.marconi.v1.domain;

import com.google.common.base.Objects;

import java.beans.ConstructorProperties;

/**
* Queue statistics, including how many messages are in the queue.
*
* @author Everett Toews
*/
public class QueueStats {

private MessagesStats messages;

protected QueueStats(MessagesStats messages) {
this.messages = messages;
}

/**
* @return The statistics of the messages in this queue.
*/
public MessagesStats getMessagesStats() {
return messages;
}

@Override
public int hashCode() {
return Objects.hashCode(messages);
}

@Override
public boolean equals(Object obj) {
if (this == obj) return true;
if (obj == null || getClass() != obj.getClass()) return false;
QueueStats that = QueueStats.class.cast(obj);
return Objects.equal(this.messages, that.messages);
}

protected Objects.ToStringHelper string() {
return Objects.toStringHelper(this)
.add("messagesStats", messages);
}

@Override
public String toString() {
return string().toString();
}
}

0 comments on commit 60fd86d

Please sign in to comment.