@namespace("gr.grnet.aquarium.message.avro")
protocol AquariumEvents {
- enum _EventVersion {
- VERSION_1_0
- }
-
record _AnyValue {
union {
null,
}
record _ResourceEvent {
- string @aliases(["ID"]) originalID;
- string @aliased(["_id, idInStore"]) inStoreID;
+ string @aliases(["originalID", "ID"]) id;
+ string @aliased(["_id", "inStoreID"]) idInStore;
long occurredMillis;
- long receivedMillis;
+ long receivedMillis = 0;
string userID;
string clientID;
- _EventVersion eventVersion;
- string @aliases(["resource"]) resourceType;
+ string eventVersion = "1.0";
+ string @aliases(["resourceType"]) resource;
string instanceID;
string value;
map<_AnyValue> details;
}
record _IMEvent {
- string @aliases(["ID"]) originalID;
- string @aliases(["_id, idInStore"]) inStoreID;
+ string @aliases(["originalID", "ID"]) id;
+ string @aliased(["_id", "inStoreID"]) idInStore;
long occurredMillis;
- long receivedMillis;
+ long receivedMillis = 0;
string userID;
string clientID;
- _EventVersion eventVersion;
+ string eventVersion = "1.0";
boolean isActive;
string role;
map<_AnyValue> details;
@SuppressWarnings("all")
public interface AquariumEvents {
- public static final org.apache.avro.Protocol PROTOCOL = org.apache.avro.Protocol.parse("{\"protocol\":\"AquariumEvents\",\"namespace\":\"gr.grnet.aquarium.message.avro\",\"types\":[{\"type\":\"enum\",\"name\":\"_EventVersion\",\"symbols\":[\"VERSION_1_0\"]},{\"type\":\"record\",\"name\":\"_AnyValue\",\"fields\":[{\"name\":\"anyValue\",\"type\":[\"null\",\"int\",\"long\",\"boolean\",\"double\",\"bytes\",\"string\"]}]},{\"type\":\"record\",\"name\":\"_ResourceEvent\",\"fields\":[{\"name\":\"originalID\",\"type\":\"string\",\"aliases\":[\"ID\"]},{\"name\":\"inStoreID\",\"type\":\"string\"},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\"},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":\"_EventVersion\"},{\"name\":\"resourceType\",\"type\":\"string\",\"aliases\":[\"resource\"]},{\"name\":\"instanceID\",\"type\":\"string\"},{\"name\":\"value\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":\"_AnyValue\"}}]},{\"type\":\"record\",\"name\":\"_IMEvent\",\"fields\":[{\"name\":\"originalID\",\"type\":\"string\",\"aliases\":[\"ID\"]},{\"name\":\"inStoreID\",\"type\":\"string\",\"aliases\":[\"_id, idInStore\"]},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\"},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":\"_EventVersion\"},{\"name\":\"isActive\",\"type\":\"boolean\"},{\"name\":\"role\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":\"_AnyValue\"}}]}],\"messages\":{}}");
+ public static final org.apache.avro.Protocol PROTOCOL = org.apache.avro.Protocol.parse("{\"protocol\":\"AquariumEvents\",\"namespace\":\"gr.grnet.aquarium.message.avro\",\"types\":[{\"type\":\"record\",\"name\":\"_AnyValue\",\"fields\":[{\"name\":\"anyValue\",\"type\":[\"null\",\"int\",\"long\",\"boolean\",\"double\",\"bytes\",\"string\"]}]},{\"type\":\"record\",\"name\":\"_ResourceEvent\",\"fields\":[{\"name\":\"id\",\"type\":\"string\",\"aliases\":[\"originalID\",\"ID\"]},{\"name\":\"idInStore\",\"type\":\"string\"},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\",\"default\":0},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":\"string\",\"default\":\"1.0\"},{\"name\":\"resource\",\"type\":\"string\",\"aliases\":[\"resourceType\"]},{\"name\":\"instanceID\",\"type\":\"string\"},{\"name\":\"value\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":\"_AnyValue\"}}]},{\"type\":\"record\",\"name\":\"_IMEvent\",\"fields\":[{\"name\":\"id\",\"type\":\"string\",\"aliases\":[\"originalID\",\"ID\"]},{\"name\":\"idInStore\",\"type\":\"string\"},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\",\"default\":0},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":\"string\",\"default\":\"1.0\"},{\"name\":\"isActive\",\"type\":\"boolean\"},{\"name\":\"role\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":\"_AnyValue\"}}]}],\"messages\":{}}");
@SuppressWarnings("all")
public interface Callback extends AquariumEvents {
package gr.grnet.aquarium.message.avro;
@SuppressWarnings("all")
public class _IMEvent extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"_IMEvent\",\"namespace\":\"gr.grnet.aquarium.message.avro\",\"fields\":[{\"name\":\"originalID\",\"type\":\"string\",\"aliases\":[\"ID\"]},{\"name\":\"inStoreID\",\"type\":\"string\",\"aliases\":[\"_id, idInStore\"]},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\"},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":{\"type\":\"enum\",\"name\":\"_EventVersion\",\"symbols\":[\"VERSION_1_0\"]}},{\"name\":\"isActive\",\"type\":\"boolean\"},{\"name\":\"role\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":{\"type\":\"record\",\"name\":\"_AnyValue\",\"fields\":[{\"name\":\"anyValue\",\"type\":[\"null\",\"int\",\"long\",\"boolean\",\"double\",\"bytes\",\"string\"]}]}}}]}");
- @Deprecated public java.lang.CharSequence originalID;
- @Deprecated public java.lang.CharSequence inStoreID;
+ public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"_IMEvent\",\"namespace\":\"gr.grnet.aquarium.message.avro\",\"fields\":[{\"name\":\"id\",\"type\":\"string\",\"aliases\":[\"originalID\",\"ID\"]},{\"name\":\"idInStore\",\"type\":\"string\"},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\",\"default\":0},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":\"string\",\"default\":\"1.0\"},{\"name\":\"isActive\",\"type\":\"boolean\"},{\"name\":\"role\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":{\"type\":\"record\",\"name\":\"_AnyValue\",\"fields\":[{\"name\":\"anyValue\",\"type\":[\"null\",\"int\",\"long\",\"boolean\",\"double\",\"bytes\",\"string\"]}]}}}]}");
+ @Deprecated public java.lang.CharSequence id;
+ @Deprecated public java.lang.CharSequence idInStore;
@Deprecated public long occurredMillis;
@Deprecated public long receivedMillis;
@Deprecated public java.lang.CharSequence userID;
@Deprecated public java.lang.CharSequence clientID;
- @Deprecated public gr.grnet.aquarium.message.avro._EventVersion eventVersion;
+ @Deprecated public java.lang.CharSequence eventVersion;
@Deprecated public boolean isActive;
@Deprecated public java.lang.CharSequence role;
@Deprecated public java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue> details;
// Used by DatumWriter. Applications should not call.
public java.lang.Object get(int field$) {
switch (field$) {
- case 0: return originalID;
- case 1: return inStoreID;
+ case 0: return id;
+ case 1: return idInStore;
case 2: return occurredMillis;
case 3: return receivedMillis;
case 4: return userID;
@SuppressWarnings(value="unchecked")
public void put(int field$, java.lang.Object value$) {
switch (field$) {
- case 0: originalID = (java.lang.CharSequence)value$; break;
- case 1: inStoreID = (java.lang.CharSequence)value$; break;
+ case 0: id = (java.lang.CharSequence)value$; break;
+ case 1: idInStore = (java.lang.CharSequence)value$; break;
case 2: occurredMillis = (java.lang.Long)value$; break;
case 3: receivedMillis = (java.lang.Long)value$; break;
case 4: userID = (java.lang.CharSequence)value$; break;
case 5: clientID = (java.lang.CharSequence)value$; break;
- case 6: eventVersion = (gr.grnet.aquarium.message.avro._EventVersion)value$; break;
+ case 6: eventVersion = (java.lang.CharSequence)value$; break;
case 7: isActive = (java.lang.Boolean)value$; break;
case 8: role = (java.lang.CharSequence)value$; break;
case 9: details = (java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue>)value$; break;
}
/**
- * Gets the value of the 'originalID' field.
+ * Gets the value of the 'id' field.
*/
- public java.lang.CharSequence getOriginalID() {
- return originalID;
+ public java.lang.CharSequence getId() {
+ return id;
}
/**
- * Sets the value of the 'originalID' field.
+ * Sets the value of the 'id' field.
* @param value the value to set.
*/
- public void setOriginalID(java.lang.CharSequence value) {
- this.originalID = value;
+ public void setId(java.lang.CharSequence value) {
+ this.id = value;
}
/**
- * Gets the value of the 'inStoreID' field.
+ * Gets the value of the 'idInStore' field.
*/
- public java.lang.CharSequence getInStoreID() {
- return inStoreID;
+ public java.lang.CharSequence getIdInStore() {
+ return idInStore;
}
/**
- * Sets the value of the 'inStoreID' field.
+ * Sets the value of the 'idInStore' field.
* @param value the value to set.
*/
- public void setInStoreID(java.lang.CharSequence value) {
- this.inStoreID = value;
+ public void setIdInStore(java.lang.CharSequence value) {
+ this.idInStore = value;
}
/**
/**
* Gets the value of the 'eventVersion' field.
*/
- public gr.grnet.aquarium.message.avro._EventVersion getEventVersion() {
+ public java.lang.CharSequence getEventVersion() {
return eventVersion;
}
* Sets the value of the 'eventVersion' field.
* @param value the value to set.
*/
- public void setEventVersion(gr.grnet.aquarium.message.avro._EventVersion value) {
+ public void setEventVersion(java.lang.CharSequence value) {
this.eventVersion = value;
}
public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<_IMEvent>
implements org.apache.avro.data.RecordBuilder<_IMEvent> {
- private java.lang.CharSequence originalID;
- private java.lang.CharSequence inStoreID;
+ private java.lang.CharSequence id;
+ private java.lang.CharSequence idInStore;
private long occurredMillis;
private long receivedMillis;
private java.lang.CharSequence userID;
private java.lang.CharSequence clientID;
- private gr.grnet.aquarium.message.avro._EventVersion eventVersion;
+ private java.lang.CharSequence eventVersion;
private boolean isActive;
private java.lang.CharSequence role;
private java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue> details;
/** Creates a Builder by copying an existing _IMEvent instance */
private Builder(gr.grnet.aquarium.message.avro._IMEvent other) {
super(gr.grnet.aquarium.message.avro._IMEvent.SCHEMA$);
- if (isValidValue(fields()[0], other.originalID)) {
- this.originalID = (java.lang.CharSequence) data().deepCopy(fields()[0].schema(), other.originalID);
+ if (isValidValue(fields()[0], other.id)) {
+ this.id = (java.lang.CharSequence) data().deepCopy(fields()[0].schema(), other.id);
fieldSetFlags()[0] = true;
}
- if (isValidValue(fields()[1], other.inStoreID)) {
- this.inStoreID = (java.lang.CharSequence) data().deepCopy(fields()[1].schema(), other.inStoreID);
+ if (isValidValue(fields()[1], other.idInStore)) {
+ this.idInStore = (java.lang.CharSequence) data().deepCopy(fields()[1].schema(), other.idInStore);
fieldSetFlags()[1] = true;
}
if (isValidValue(fields()[2], other.occurredMillis)) {
fieldSetFlags()[5] = true;
}
if (isValidValue(fields()[6], other.eventVersion)) {
- this.eventVersion = (gr.grnet.aquarium.message.avro._EventVersion) data().deepCopy(fields()[6].schema(), other.eventVersion);
+ this.eventVersion = (java.lang.CharSequence) data().deepCopy(fields()[6].schema(), other.eventVersion);
fieldSetFlags()[6] = true;
}
if (isValidValue(fields()[7], other.isActive)) {
}
}
- /** Gets the value of the 'originalID' field */
- public java.lang.CharSequence getOriginalID() {
- return originalID;
+ /** Gets the value of the 'id' field */
+ public java.lang.CharSequence getId() {
+ return id;
}
- /** Sets the value of the 'originalID' field */
- public gr.grnet.aquarium.message.avro._IMEvent.Builder setOriginalID(java.lang.CharSequence value) {
+ /** Sets the value of the 'id' field */
+ public gr.grnet.aquarium.message.avro._IMEvent.Builder setId(java.lang.CharSequence value) {
validate(fields()[0], value);
- this.originalID = value;
+ this.id = value;
fieldSetFlags()[0] = true;
return this;
}
- /** Checks whether the 'originalID' field has been set */
- public boolean hasOriginalID() {
+ /** Checks whether the 'id' field has been set */
+ public boolean hasId() {
return fieldSetFlags()[0];
}
- /** Clears the value of the 'originalID' field */
- public gr.grnet.aquarium.message.avro._IMEvent.Builder clearOriginalID() {
- originalID = null;
+ /** Clears the value of the 'id' field */
+ public gr.grnet.aquarium.message.avro._IMEvent.Builder clearId() {
+ id = null;
fieldSetFlags()[0] = false;
return this;
}
- /** Gets the value of the 'inStoreID' field */
- public java.lang.CharSequence getInStoreID() {
- return inStoreID;
+ /** Gets the value of the 'idInStore' field */
+ public java.lang.CharSequence getIdInStore() {
+ return idInStore;
}
- /** Sets the value of the 'inStoreID' field */
- public gr.grnet.aquarium.message.avro._IMEvent.Builder setInStoreID(java.lang.CharSequence value) {
+ /** Sets the value of the 'idInStore' field */
+ public gr.grnet.aquarium.message.avro._IMEvent.Builder setIdInStore(java.lang.CharSequence value) {
validate(fields()[1], value);
- this.inStoreID = value;
+ this.idInStore = value;
fieldSetFlags()[1] = true;
return this;
}
- /** Checks whether the 'inStoreID' field has been set */
- public boolean hasInStoreID() {
+ /** Checks whether the 'idInStore' field has been set */
+ public boolean hasIdInStore() {
return fieldSetFlags()[1];
}
- /** Clears the value of the 'inStoreID' field */
- public gr.grnet.aquarium.message.avro._IMEvent.Builder clearInStoreID() {
- inStoreID = null;
+ /** Clears the value of the 'idInStore' field */
+ public gr.grnet.aquarium.message.avro._IMEvent.Builder clearIdInStore() {
+ idInStore = null;
fieldSetFlags()[1] = false;
return this;
}
}
/** Gets the value of the 'eventVersion' field */
- public gr.grnet.aquarium.message.avro._EventVersion getEventVersion() {
+ public java.lang.CharSequence getEventVersion() {
return eventVersion;
}
/** Sets the value of the 'eventVersion' field */
- public gr.grnet.aquarium.message.avro._IMEvent.Builder setEventVersion(gr.grnet.aquarium.message.avro._EventVersion value) {
+ public gr.grnet.aquarium.message.avro._IMEvent.Builder setEventVersion(java.lang.CharSequence value) {
validate(fields()[6], value);
this.eventVersion = value;
fieldSetFlags()[6] = true;
public _IMEvent build() {
try {
_IMEvent record = new _IMEvent();
- record.originalID = fieldSetFlags()[0] ? this.originalID : (java.lang.CharSequence) defaultValue(fields()[0]);
- record.inStoreID = fieldSetFlags()[1] ? this.inStoreID : (java.lang.CharSequence) defaultValue(fields()[1]);
+ record.id = fieldSetFlags()[0] ? this.id : (java.lang.CharSequence) defaultValue(fields()[0]);
+ record.idInStore = fieldSetFlags()[1] ? this.idInStore : (java.lang.CharSequence) defaultValue(fields()[1]);
record.occurredMillis = fieldSetFlags()[2] ? this.occurredMillis : (java.lang.Long) defaultValue(fields()[2]);
record.receivedMillis = fieldSetFlags()[3] ? this.receivedMillis : (java.lang.Long) defaultValue(fields()[3]);
record.userID = fieldSetFlags()[4] ? this.userID : (java.lang.CharSequence) defaultValue(fields()[4]);
record.clientID = fieldSetFlags()[5] ? this.clientID : (java.lang.CharSequence) defaultValue(fields()[5]);
- record.eventVersion = fieldSetFlags()[6] ? this.eventVersion : (gr.grnet.aquarium.message.avro._EventVersion) defaultValue(fields()[6]);
+ record.eventVersion = fieldSetFlags()[6] ? this.eventVersion : (java.lang.CharSequence) defaultValue(fields()[6]);
record.isActive = fieldSetFlags()[7] ? this.isActive : (java.lang.Boolean) defaultValue(fields()[7]);
record.role = fieldSetFlags()[8] ? this.role : (java.lang.CharSequence) defaultValue(fields()[8]);
record.details = fieldSetFlags()[9] ? this.details : (java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue>) defaultValue(fields()[9]);
package gr.grnet.aquarium.message.avro;
@SuppressWarnings("all")
public class _ResourceEvent extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
- public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"_ResourceEvent\",\"namespace\":\"gr.grnet.aquarium.message.avro\",\"fields\":[{\"name\":\"originalID\",\"type\":\"string\",\"aliases\":[\"ID\"]},{\"name\":\"inStoreID\",\"type\":\"string\"},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\"},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":{\"type\":\"enum\",\"name\":\"_EventVersion\",\"symbols\":[\"VERSION_1_0\"]}},{\"name\":\"resourceType\",\"type\":\"string\",\"aliases\":[\"resource\"]},{\"name\":\"instanceID\",\"type\":\"string\"},{\"name\":\"value\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":{\"type\":\"record\",\"name\":\"_AnyValue\",\"fields\":[{\"name\":\"anyValue\",\"type\":[\"null\",\"int\",\"long\",\"boolean\",\"double\",\"bytes\",\"string\"]}]}}}]}");
- @Deprecated public java.lang.CharSequence originalID;
- @Deprecated public java.lang.CharSequence inStoreID;
+ public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"_ResourceEvent\",\"namespace\":\"gr.grnet.aquarium.message.avro\",\"fields\":[{\"name\":\"id\",\"type\":\"string\",\"aliases\":[\"originalID\",\"ID\"]},{\"name\":\"idInStore\",\"type\":\"string\"},{\"name\":\"occurredMillis\",\"type\":\"long\"},{\"name\":\"receivedMillis\",\"type\":\"long\",\"default\":0},{\"name\":\"userID\",\"type\":\"string\"},{\"name\":\"clientID\",\"type\":\"string\"},{\"name\":\"eventVersion\",\"type\":\"string\",\"default\":\"1.0\"},{\"name\":\"resource\",\"type\":\"string\",\"aliases\":[\"resourceType\"]},{\"name\":\"instanceID\",\"type\":\"string\"},{\"name\":\"value\",\"type\":\"string\"},{\"name\":\"details\",\"type\":{\"type\":\"map\",\"values\":{\"type\":\"record\",\"name\":\"_AnyValue\",\"fields\":[{\"name\":\"anyValue\",\"type\":[\"null\",\"int\",\"long\",\"boolean\",\"double\",\"bytes\",\"string\"]}]}}}]}");
+ @Deprecated public java.lang.CharSequence id;
+ @Deprecated public java.lang.CharSequence idInStore;
@Deprecated public long occurredMillis;
@Deprecated public long receivedMillis;
@Deprecated public java.lang.CharSequence userID;
@Deprecated public java.lang.CharSequence clientID;
- @Deprecated public gr.grnet.aquarium.message.avro._EventVersion eventVersion;
- @Deprecated public java.lang.CharSequence resourceType;
+ @Deprecated public java.lang.CharSequence eventVersion;
+ @Deprecated public java.lang.CharSequence resource;
@Deprecated public java.lang.CharSequence instanceID;
@Deprecated public java.lang.CharSequence value;
@Deprecated public java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue> details;
// Used by DatumWriter. Applications should not call.
public java.lang.Object get(int field$) {
switch (field$) {
- case 0: return originalID;
- case 1: return inStoreID;
+ case 0: return id;
+ case 1: return idInStore;
case 2: return occurredMillis;
case 3: return receivedMillis;
case 4: return userID;
case 5: return clientID;
case 6: return eventVersion;
- case 7: return resourceType;
+ case 7: return resource;
case 8: return instanceID;
case 9: return value;
case 10: return details;
@SuppressWarnings(value="unchecked")
public void put(int field$, java.lang.Object value$) {
switch (field$) {
- case 0: originalID = (java.lang.CharSequence)value$; break;
- case 1: inStoreID = (java.lang.CharSequence)value$; break;
+ case 0: id = (java.lang.CharSequence)value$; break;
+ case 1: idInStore = (java.lang.CharSequence)value$; break;
case 2: occurredMillis = (java.lang.Long)value$; break;
case 3: receivedMillis = (java.lang.Long)value$; break;
case 4: userID = (java.lang.CharSequence)value$; break;
case 5: clientID = (java.lang.CharSequence)value$; break;
- case 6: eventVersion = (gr.grnet.aquarium.message.avro._EventVersion)value$; break;
- case 7: resourceType = (java.lang.CharSequence)value$; break;
+ case 6: eventVersion = (java.lang.CharSequence)value$; break;
+ case 7: resource = (java.lang.CharSequence)value$; break;
case 8: instanceID = (java.lang.CharSequence)value$; break;
case 9: value = (java.lang.CharSequence)value$; break;
case 10: details = (java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue>)value$; break;
}
/**
- * Gets the value of the 'originalID' field.
+ * Gets the value of the 'id' field.
*/
- public java.lang.CharSequence getOriginalID() {
- return originalID;
+ public java.lang.CharSequence getId() {
+ return id;
}
/**
- * Sets the value of the 'originalID' field.
+ * Sets the value of the 'id' field.
* @param value the value to set.
*/
- public void setOriginalID(java.lang.CharSequence value) {
- this.originalID = value;
+ public void setId(java.lang.CharSequence value) {
+ this.id = value;
}
/**
- * Gets the value of the 'inStoreID' field.
+ * Gets the value of the 'idInStore' field.
*/
- public java.lang.CharSequence getInStoreID() {
- return inStoreID;
+ public java.lang.CharSequence getIdInStore() {
+ return idInStore;
}
/**
- * Sets the value of the 'inStoreID' field.
+ * Sets the value of the 'idInStore' field.
* @param value the value to set.
*/
- public void setInStoreID(java.lang.CharSequence value) {
- this.inStoreID = value;
+ public void setIdInStore(java.lang.CharSequence value) {
+ this.idInStore = value;
}
/**
/**
* Gets the value of the 'eventVersion' field.
*/
- public gr.grnet.aquarium.message.avro._EventVersion getEventVersion() {
+ public java.lang.CharSequence getEventVersion() {
return eventVersion;
}
* Sets the value of the 'eventVersion' field.
* @param value the value to set.
*/
- public void setEventVersion(gr.grnet.aquarium.message.avro._EventVersion value) {
+ public void setEventVersion(java.lang.CharSequence value) {
this.eventVersion = value;
}
/**
- * Gets the value of the 'resourceType' field.
+ * Gets the value of the 'resource' field.
*/
- public java.lang.CharSequence getResourceType() {
- return resourceType;
+ public java.lang.CharSequence getResource() {
+ return resource;
}
/**
- * Sets the value of the 'resourceType' field.
+ * Sets the value of the 'resource' field.
* @param value the value to set.
*/
- public void setResourceType(java.lang.CharSequence value) {
- this.resourceType = value;
+ public void setResource(java.lang.CharSequence value) {
+ this.resource = value;
}
/**
public static class Builder extends org.apache.avro.specific.SpecificRecordBuilderBase<_ResourceEvent>
implements org.apache.avro.data.RecordBuilder<_ResourceEvent> {
- private java.lang.CharSequence originalID;
- private java.lang.CharSequence inStoreID;
+ private java.lang.CharSequence id;
+ private java.lang.CharSequence idInStore;
private long occurredMillis;
private long receivedMillis;
private java.lang.CharSequence userID;
private java.lang.CharSequence clientID;
- private gr.grnet.aquarium.message.avro._EventVersion eventVersion;
- private java.lang.CharSequence resourceType;
+ private java.lang.CharSequence eventVersion;
+ private java.lang.CharSequence resource;
private java.lang.CharSequence instanceID;
private java.lang.CharSequence value;
private java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue> details;
/** Creates a Builder by copying an existing _ResourceEvent instance */
private Builder(gr.grnet.aquarium.message.avro._ResourceEvent other) {
super(gr.grnet.aquarium.message.avro._ResourceEvent.SCHEMA$);
- if (isValidValue(fields()[0], other.originalID)) {
- this.originalID = (java.lang.CharSequence) data().deepCopy(fields()[0].schema(), other.originalID);
+ if (isValidValue(fields()[0], other.id)) {
+ this.id = (java.lang.CharSequence) data().deepCopy(fields()[0].schema(), other.id);
fieldSetFlags()[0] = true;
}
- if (isValidValue(fields()[1], other.inStoreID)) {
- this.inStoreID = (java.lang.CharSequence) data().deepCopy(fields()[1].schema(), other.inStoreID);
+ if (isValidValue(fields()[1], other.idInStore)) {
+ this.idInStore = (java.lang.CharSequence) data().deepCopy(fields()[1].schema(), other.idInStore);
fieldSetFlags()[1] = true;
}
if (isValidValue(fields()[2], other.occurredMillis)) {
fieldSetFlags()[5] = true;
}
if (isValidValue(fields()[6], other.eventVersion)) {
- this.eventVersion = (gr.grnet.aquarium.message.avro._EventVersion) data().deepCopy(fields()[6].schema(), other.eventVersion);
+ this.eventVersion = (java.lang.CharSequence) data().deepCopy(fields()[6].schema(), other.eventVersion);
fieldSetFlags()[6] = true;
}
- if (isValidValue(fields()[7], other.resourceType)) {
- this.resourceType = (java.lang.CharSequence) data().deepCopy(fields()[7].schema(), other.resourceType);
+ if (isValidValue(fields()[7], other.resource)) {
+ this.resource = (java.lang.CharSequence) data().deepCopy(fields()[7].schema(), other.resource);
fieldSetFlags()[7] = true;
}
if (isValidValue(fields()[8], other.instanceID)) {
}
}
- /** Gets the value of the 'originalID' field */
- public java.lang.CharSequence getOriginalID() {
- return originalID;
+ /** Gets the value of the 'id' field */
+ public java.lang.CharSequence getId() {
+ return id;
}
- /** Sets the value of the 'originalID' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setOriginalID(java.lang.CharSequence value) {
+ /** Sets the value of the 'id' field */
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setId(java.lang.CharSequence value) {
validate(fields()[0], value);
- this.originalID = value;
+ this.id = value;
fieldSetFlags()[0] = true;
return this;
}
- /** Checks whether the 'originalID' field has been set */
- public boolean hasOriginalID() {
+ /** Checks whether the 'id' field has been set */
+ public boolean hasId() {
return fieldSetFlags()[0];
}
- /** Clears the value of the 'originalID' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder clearOriginalID() {
- originalID = null;
+ /** Clears the value of the 'id' field */
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder clearId() {
+ id = null;
fieldSetFlags()[0] = false;
return this;
}
- /** Gets the value of the 'inStoreID' field */
- public java.lang.CharSequence getInStoreID() {
- return inStoreID;
+ /** Gets the value of the 'idInStore' field */
+ public java.lang.CharSequence getIdInStore() {
+ return idInStore;
}
- /** Sets the value of the 'inStoreID' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setInStoreID(java.lang.CharSequence value) {
+ /** Sets the value of the 'idInStore' field */
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setIdInStore(java.lang.CharSequence value) {
validate(fields()[1], value);
- this.inStoreID = value;
+ this.idInStore = value;
fieldSetFlags()[1] = true;
return this;
}
- /** Checks whether the 'inStoreID' field has been set */
- public boolean hasInStoreID() {
+ /** Checks whether the 'idInStore' field has been set */
+ public boolean hasIdInStore() {
return fieldSetFlags()[1];
}
- /** Clears the value of the 'inStoreID' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder clearInStoreID() {
- inStoreID = null;
+ /** Clears the value of the 'idInStore' field */
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder clearIdInStore() {
+ idInStore = null;
fieldSetFlags()[1] = false;
return this;
}
}
/** Gets the value of the 'eventVersion' field */
- public gr.grnet.aquarium.message.avro._EventVersion getEventVersion() {
+ public java.lang.CharSequence getEventVersion() {
return eventVersion;
}
/** Sets the value of the 'eventVersion' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setEventVersion(gr.grnet.aquarium.message.avro._EventVersion value) {
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setEventVersion(java.lang.CharSequence value) {
validate(fields()[6], value);
this.eventVersion = value;
fieldSetFlags()[6] = true;
return this;
}
- /** Gets the value of the 'resourceType' field */
- public java.lang.CharSequence getResourceType() {
- return resourceType;
+ /** Gets the value of the 'resource' field */
+ public java.lang.CharSequence getResource() {
+ return resource;
}
- /** Sets the value of the 'resourceType' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setResourceType(java.lang.CharSequence value) {
+ /** Sets the value of the 'resource' field */
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder setResource(java.lang.CharSequence value) {
validate(fields()[7], value);
- this.resourceType = value;
+ this.resource = value;
fieldSetFlags()[7] = true;
return this;
}
- /** Checks whether the 'resourceType' field has been set */
- public boolean hasResourceType() {
+ /** Checks whether the 'resource' field has been set */
+ public boolean hasResource() {
return fieldSetFlags()[7];
}
- /** Clears the value of the 'resourceType' field */
- public gr.grnet.aquarium.message.avro._ResourceEvent.Builder clearResourceType() {
- resourceType = null;
+ /** Clears the value of the 'resource' field */
+ public gr.grnet.aquarium.message.avro._ResourceEvent.Builder clearResource() {
+ resource = null;
fieldSetFlags()[7] = false;
return this;
}
public _ResourceEvent build() {
try {
_ResourceEvent record = new _ResourceEvent();
- record.originalID = fieldSetFlags()[0] ? this.originalID : (java.lang.CharSequence) defaultValue(fields()[0]);
- record.inStoreID = fieldSetFlags()[1] ? this.inStoreID : (java.lang.CharSequence) defaultValue(fields()[1]);
+ record.id = fieldSetFlags()[0] ? this.id : (java.lang.CharSequence) defaultValue(fields()[0]);
+ record.idInStore = fieldSetFlags()[1] ? this.idInStore : (java.lang.CharSequence) defaultValue(fields()[1]);
record.occurredMillis = fieldSetFlags()[2] ? this.occurredMillis : (java.lang.Long) defaultValue(fields()[2]);
record.receivedMillis = fieldSetFlags()[3] ? this.receivedMillis : (java.lang.Long) defaultValue(fields()[3]);
record.userID = fieldSetFlags()[4] ? this.userID : (java.lang.CharSequence) defaultValue(fields()[4]);
record.clientID = fieldSetFlags()[5] ? this.clientID : (java.lang.CharSequence) defaultValue(fields()[5]);
- record.eventVersion = fieldSetFlags()[6] ? this.eventVersion : (gr.grnet.aquarium.message.avro._EventVersion) defaultValue(fields()[6]);
- record.resourceType = fieldSetFlags()[7] ? this.resourceType : (java.lang.CharSequence) defaultValue(fields()[7]);
+ record.eventVersion = fieldSetFlags()[6] ? this.eventVersion : (java.lang.CharSequence) defaultValue(fields()[6]);
+ record.resource = fieldSetFlags()[7] ? this.resource : (java.lang.CharSequence) defaultValue(fields()[7]);
record.instanceID = fieldSetFlags()[8] ? this.instanceID : (java.lang.CharSequence) defaultValue(fields()[8]);
record.value = fieldSetFlags()[9] ? this.value : (java.lang.CharSequence) defaultValue(fields()[9]);
record.details = fieldSetFlags()[10] ? this.details : (java.util.Map<java.lang.CharSequence,gr.grnet.aquarium.message.avro._AnyValue>) defaultValue(fields()[10]);
package gr.grnet.aquarium.message.avro
+import java.io.ByteArrayOutputStream
+import org.apache.avro.io.{EncoderFactory, Encoder, JsonEncoder}
+import org.apache.avro.specific.SpecificDatumWriter
import org.junit.{Assert, Test}
+import java.util
+import org.codehaus.jackson.{JsonEncoding, JsonFactory}
/**
*
*/
class ResourceEventTest {
@Test
- def testJSON() {
+ def testJSONSchema() {
val rcEvent = new _ResourceEvent()
val schema = rcEvent.getSchema
val generatedPrettySchema = schema.toString(true)
val goodJSONSchema =
- """{
+ """{
| "type" : "record",
| "name" : "_ResourceEvent",
| "namespace" : "gr.grnet.aquarium.message.avro",
| "fields" : [ {
- | "name" : "originalID",
+ | "name" : "id",
| "type" : "string",
- | "aliases" : [ "ID" ]
+ | "aliases" : [ "originalID", "ID" ]
| }, {
- | "name" : "inStoreID",
+ | "name" : "idInStore",
| "type" : "string"
| }, {
| "name" : "occurredMillis",
| "type" : "long"
| }, {
| "name" : "receivedMillis",
- | "type" : "long"
+ | "type" : "long",
+ | "default" : 0
| }, {
| "name" : "userID",
| "type" : "string"
| "type" : "string"
| }, {
| "name" : "eventVersion",
- | "type" : {
- | "type" : "enum",
- | "name" : "_EventVersion",
- | "symbols" : [ "VERSION_1_0" ]
- | }
+ | "type" : "string",
+ | "default" : "1.0"
| }, {
- | "name" : "resourceType",
+ | "name" : "resource",
| "type" : "string",
- | "aliases" : [ "resource" ]
+ | "aliases" : [ "resourceType" ]
| }, {
| "name" : "instanceID",
| "type" : "string"
Assert.assertEquals(goodJSONSchema, generatedPrettySchema)
}
+
+ @Test
+ def testJSONObjectOutput() {
+ val rcEvent = _ResourceEvent.newBuilder().
+ setId("id-1").
+ setClientID("client-1").
+ setResource("diskspace").
+ setInstanceID("1").
+ setIdInStore("").
+ setOccurredMillis(1000L).
+ setUserID("foouser").
+ setValue("123.32").
+ setDetails(new util.HashMap[CharSequence, _AnyValue]()).
+ build()
+
+ val schema = rcEvent.getSchema
+ val out = new ByteArrayOutputStream()
+ val encoder = EncoderFactory.get().jsonEncoder(schema, out)
+ val jsonGenerator = new JsonFactory().
+ createJsonGenerator(out, JsonEncoding.UTF8).
+ useDefaultPrettyPrinter()
+ encoder.configure(jsonGenerator)
+ val writer = new SpecificDatumWriter[_ResourceEvent](schema)
+
+ writer.write(rcEvent, encoder)
+
+ encoder.flush()
+
+ val generatedJSON = out.toString
+
+ val goodJSONString =
+ """{
+ | "id" : "id-1",
+ | "idInStore" : "",
+ | "occurredMillis" : 1000,
+ | "receivedMillis" : 0,
+ | "userID" : "foouser",
+ | "clientID" : "client-1",
+ | "eventVersion" : "1.0",
+ | "resource" : "diskspace",
+ | "instanceID" : "1",
+ | "value" : "123.32",
+ | "details" : {
+ | }
+ |}""".stripMargin
+
+ Assert.assertEquals(goodJSONString, generatedJSON)
+ }
}
projects / aquarium / commitdiff