diff options
Diffstat (limited to 'orkbasej/java/net/sf/oreka/messages')
7 files changed, 374 insertions, 0 deletions
diff --git a/orkbasej/java/net/sf/oreka/messages/AsyncMessage.java b/orkbasej/java/net/sf/oreka/messages/AsyncMessage.java new file mode 100644 index 0000000..7cfa9f5 --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/AsyncMessage.java @@ -0,0 +1,18 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages; + +public abstract class AsyncMessage extends Message { + +} diff --git a/orkbasej/java/net/sf/oreka/messages/Message.java b/orkbasej/java/net/sf/oreka/messages/Message.java new file mode 100644 index 0000000..72dfaad --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/Message.java @@ -0,0 +1,19 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages; + +import net.sf.oreka.*; + +public abstract class Message implements OrkObject { +} diff --git a/orkbasej/java/net/sf/oreka/messages/SimpleResponseMessage.java b/orkbasej/java/net/sf/oreka/messages/SimpleResponseMessage.java new file mode 100644 index 0000000..2da9131 --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/SimpleResponseMessage.java @@ -0,0 +1,56 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages; + +import net.sf.oreka.OrkException; +import net.sf.oreka.serializers.OrkSerializer; + +public class SimpleResponseMessage extends AsyncMessage { + + boolean success = false; + String comment = ""; + + public void define(OrkSerializer serializer) throws OrkException { + + success = serializer.booleanValue("success", success, true); + comment = serializer.stringValue("comment", comment, false); + } + + public String getOrkClassName() { + + return "simpleresponse"; + } + + public void validate() { + // TODO Auto-generated method stub + + } + + public String getComment() { + return comment; + } + + public void setComment(String comment) { + this.comment = comment; + } + + public boolean isSuccess() { + return success; + } + + public void setSuccess(boolean success) { + this.success = success; + } + +} diff --git a/orkbasej/java/net/sf/oreka/messages/SyncMessage.java b/orkbasej/java/net/sf/oreka/messages/SyncMessage.java new file mode 100644 index 0000000..0aae393 --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/SyncMessage.java @@ -0,0 +1,19 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages; + +public abstract class SyncMessage extends Message { + + public abstract AsyncMessage process(); +} diff --git a/orkbasej/java/net/sf/oreka/messages/test/TestMessage.java b/orkbasej/java/net/sf/oreka/messages/test/TestMessage.java new file mode 100644 index 0000000..6ac8fea --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/test/TestMessage.java @@ -0,0 +1,97 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages.test; + +import net.sf.oreka.*; +import net.sf.oreka.messages.AsyncMessage; +import net.sf.oreka.messages.SyncMessage; +import net.sf.oreka.serializers.*; + +public class TestMessage extends SyncMessage +{ + static final String orkObjectClass = "test"; + + public enum TestEnum {value1, value2, value3}; + + String stringParm = ""; + int intParm = 0; + double doubleParm = 0.0; + boolean boolParm = false; + TestEnum enumParm = TestEnum.value1; + + public String getOrkClassName() + { + return orkObjectClass; + } + + public void define(OrkSerializer serializer) throws OrkException + { + //serializer.stringValue("command", orkObjectClass, true); + intParm = serializer.intValue("intParm", intParm, true); + doubleParm = serializer.doubleValue("doubleParm", doubleParm, false); + stringParm = serializer.stringValue("stringParm", stringParm, false); + boolParm = serializer.booleanValue("boolParm", boolParm, false); + enumParm = (TestEnum)serializer.enumValue("enumParm", enumParm, false); + } + + public void validate() + { + ; + } + + public AsyncMessage process() + { + return null; + } + + public int getIntParm() { + return intParm; + } + + public void setIntParm(int intParm) { + this.intParm = intParm; + } + + public String getStringParm() { + return stringParm; + } + + public void setStringParm(String stringParm) { + this.stringParm = stringParm; + } + + public boolean isBoolParm() { + return boolParm; + } + + public void setBoolParm(boolean boolParm) { + this.boolParm = boolParm; + } + + public double getDoubleParm() { + return doubleParm; + } + + public void setDoubleParm(double doubleParm) { + this.doubleParm = doubleParm; + } + + public TestEnum getEnumParm() { + return enumParm; + } + + public void setEnumParm(TestEnum enumParm) { + this.enumParm = enumParm; + } +} diff --git a/orkbasej/java/net/sf/oreka/messages/test/TestNestedMessage.java b/orkbasej/java/net/sf/oreka/messages/test/TestNestedMessage.java new file mode 100644 index 0000000..c949652 --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/test/TestNestedMessage.java @@ -0,0 +1,108 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages.test; + +import net.sf.oreka.*; +import net.sf.oreka.messages.AsyncMessage; +import net.sf.oreka.messages.SyncMessage; +import net.sf.oreka.serializers.*; + +public class TestNestedMessage extends SyncMessage +{ + static final String orkObjectClass = "testnested"; + + public enum TestEnum {value1, value2, value3}; + + String stringParm = ""; + int intParm = 0; + double doubleParm = 0.0; + boolean boolParm = false; + TestEnum enumParm = TestEnum.value1; + TestSubMessage subMsg = new TestSubMessage(); + + + public String getOrkClassName() + { + return orkObjectClass; + } + + public void define(OrkSerializer serializer) throws OrkException + { + //serializer.stringValue("command", orkObjectClass, true); + intParm = serializer.intValue("intParm", intParm, true); + doubleParm = serializer.doubleValue("doubleParm", doubleParm, false); + stringParm = serializer.stringValue("stringParm", stringParm, false); + boolParm = serializer.booleanValue("boolParm", boolParm, false); + enumParm = (TestEnum)serializer.enumValue("enumParm", enumParm, false); + subMsg = (TestSubMessage)serializer.objectValue("testsub", subMsg, false); + } + + public void validate() + { + ; + } + + public AsyncMessage process() + { + return null; + } + + public int getIntParm() { + return intParm; + } + + public void setIntParm(int intParm) { + this.intParm = intParm; + } + + public String getStringParm() { + return stringParm; + } + + public void setStringParm(String stringParm) { + this.stringParm = stringParm; + } + + public boolean isBoolParm() { + return boolParm; + } + + public void setBoolParm(boolean boolParm) { + this.boolParm = boolParm; + } + + public double getDoubleParm() { + return doubleParm; + } + + public void setDoubleParm(double doubleParm) { + this.doubleParm = doubleParm; + } + + public TestEnum getEnumParm() { + return enumParm; + } + + public void setEnumParm(TestEnum enumParm) { + this.enumParm = enumParm; + } + + public TestSubMessage getSubMsg() { + return subMsg; + } + + public void setSubMsg(TestSubMessage subMsg) { + this.subMsg = subMsg; + } +}
\ No newline at end of file diff --git a/orkbasej/java/net/sf/oreka/messages/test/TestSubMessage.java b/orkbasej/java/net/sf/oreka/messages/test/TestSubMessage.java new file mode 100644 index 0000000..919e995 --- /dev/null +++ b/orkbasej/java/net/sf/oreka/messages/test/TestSubMessage.java @@ -0,0 +1,57 @@ +/* + * Oreka -- A media capture and retrieval platform + * + * Copyright (C) 2005, orecx LLC + * + * http://www.orecx.com + * + * This program is free software, distributed under the terms of + * the GNU General Public License. + * Please refer to http://www.gnu.org/copyleft/gpl.html + * + */ + +package net.sf.oreka.messages.test; + +import net.sf.oreka.OrkException; +import net.sf.oreka.OrkObject; +import net.sf.oreka.serializers.OrkSerializer; + +public class TestSubMessage implements OrkObject { + + String stringSubParm = ""; + int intSubParm = 0; + + public void define(OrkSerializer serializer) throws OrkException { + + stringSubParm = serializer.stringValue("stringsubparm",stringSubParm,false); + intSubParm = serializer.intValue("intsubparm", intSubParm, false); + } + + public String getOrkClassName() { + + return "testsub"; + } + + public void validate() { + // TODO Auto-generated method stub + + } + + public int getIntSubParm() { + return intSubParm; + } + + public void setIntSubParm(int intSubParm) { + this.intSubParm = intSubParm; + } + + public String getStringSubParm() { + return stringSubParm; + } + + public void setStringSubParm(String stringSubParm) { + this.stringSubParm = stringSubParm; + } + +} |