[ONOS-2408]Data model and utility class about RFC 7047 (ovsdb protocol).
The whole lib of ovsdb provides the function of encode to jasonRPC and
decode to Pojo to consumer, the bussiness of coordination of
communication is implemented by adapter.
Change-Id: I4c35426273394c1699207e5a4f2e98cead59f1e1
diff --git a/ovsdb/rfc/src/main/java/org/onosproject/ovsdb/rfc/message/MonitorRequest.java b/ovsdb/rfc/src/main/java/org/onosproject/ovsdb/rfc/message/MonitorRequest.java
new file mode 100644
index 0000000..e2176ae
--- /dev/null
+++ b/ovsdb/rfc/src/main/java/org/onosproject/ovsdb/rfc/message/MonitorRequest.java
@@ -0,0 +1,101 @@
+/*
+ * Copyright 2015 Open Networking Laboratory
+ *
+ * Licensed 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.onosproject.ovsdb.rfc.message;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import java.util.Objects;
+import java.util.Set;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+
+/**
+ * Monitor Requst information that need to monitor table.
+ */
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public final class MonitorRequest {
+ @JsonIgnore
+ private final String tableName;
+ private final Set<String> columns;
+ private final MonitorSelect select;
+
+ /**
+ * Constructs a MonitorRequest object.
+ * @param tableName table name
+ * @param columns a set of column name
+ * @param select monitor action
+ */
+ public MonitorRequest(String tableName, Set<String> columns,
+ MonitorSelect select) {
+ checkNotNull(tableName, "tableName is not null");
+ checkNotNull(columns, "columns is not null");
+ checkNotNull(select, "select is not null");
+ this.tableName = tableName;
+ this.columns = columns;
+ this.select = select;
+ }
+
+ /**
+ * Returns tableName.
+ * @return tableName
+ */
+ public String getTableName() {
+ return tableName;
+ }
+
+ /**
+ * Returns select.
+ * @return select
+ */
+ public MonitorSelect getSelect() {
+ return select;
+ }
+
+ /**
+ * Returns columns.
+ * @return columns
+ */
+ public Set<String> getColumns() {
+ return columns;
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(tableName, select, columns);
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj) {
+ return true;
+ }
+ if (obj instanceof MonitorRequest) {
+ final MonitorRequest other = (MonitorRequest) obj;
+ return Objects.equals(this.tableName, other.tableName)
+ && Objects.equals(this.select, other.select)
+ && Objects.equals(this.columns, other.columns);
+ }
+ return false;
+ }
+
+ @Override
+ public String toString() {
+ return toStringHelper(this).add("tableName", tableName)
+ .add("select", select).add("columns", columns).toString();
+ }
+}