diff options
Diffstat (limited to 'qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/ConfiguredObjectBinding.java')
-rw-r--r-- | qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/ConfiguredObjectBinding.java | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/ConfiguredObjectBinding.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/ConfiguredObjectBinding.java new file mode 100644 index 0000000000..8b84a4c9bb --- /dev/null +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/ConfiguredObjectBinding.java @@ -0,0 +1,37 @@ +package org.apache.qpid.server.store.berkeleydb.tuple; + +import org.apache.qpid.server.store.ConfiguredObjectRecord; + +import com.sleepycat.bind.tuple.TupleBinding; +import com.sleepycat.bind.tuple.TupleInput; +import com.sleepycat.bind.tuple.TupleOutput; + +public class ConfiguredObjectBinding extends TupleBinding<ConfiguredObjectRecord> +{ + private static final ConfiguredObjectBinding INSTANCE = new ConfiguredObjectBinding(); + + public static ConfiguredObjectBinding getInstance() + { + return INSTANCE; + } + + /** non-public constructor forces getInstance instead */ + private ConfiguredObjectBinding() + { + } + + public ConfiguredObjectRecord entryToObject(TupleInput tupleInput) + { + String type = tupleInput.readString(); + String json = tupleInput.readString(); + ConfiguredObjectRecord configuredObject = new ConfiguredObjectRecord(null, type, json); + return configuredObject; + } + + public void objectToEntry(ConfiguredObjectRecord object, TupleOutput tupleOutput) + { + tupleOutput.writeString(object.getType()); + tupleOutput.writeString(object.getAttributes()); + } + +} |