Repository: incubator-rocketmq Updated Branches: refs/heads/spec b39f6c9fd -> 3735a3f4d
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: add exception ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17 Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/2f14f71e Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/2f14f71e Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/2f14f71e Branch: refs/heads/spec Commit: 2f14f71e440aa00588f6288619d708b9db8b3ed2 Parents: b39f6c9 Author: vintagewang <[email protected]> Authored: Thu Dec 29 11:02:06 2016 +0800 Committer: vintagewang <[email protected]> Committed: Thu Dec 29 11:02:06 2016 +0800 ---------------------------------------------------------------------- .../org/apache/openmessaging/MessageHeader.java | 32 +++++++++++++++++++ .../openmessaging/MessageHeaderConst.java | 33 -------------------- .../openmessaging/exception/OMSException.java | 20 ++++++++++++ .../exception/OMSRuntimeException.java | 21 +++++++++++++ 4 files changed, 73 insertions(+), 33 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java new file mode 100644 index 0000000..82257fc --- /dev/null +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java @@ -0,0 +1,32 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF 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.apache.openmessaging; + +public class MessageHeader { + public static final String MessageId = "MessageId"; + public static final String Topic = "Topic"; + public static final String BornTimestamp = "BornTimestamp"; + public static final String BornHost = "BornHost"; + public static final String StoreTimestamp = "StoreTimestamp"; + public static final String StoreHost = "StoreHost"; + public static final String StartTime = "StartTime"; + public static final String StopTime = "StopTime"; + public static final String Timeout = "Timeout"; + public static final String Priority = "Priority"; + public static final String Reliability = "Reliability"; + public static final String SearchKey = "SearchKey"; +} http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java deleted file mode 100644 index a0d10e2..0000000 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java +++ /dev/null @@ -1,33 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF 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.apache.openmessaging; - - -public class MessageHeaderConst { - public static final String OMSTopic = "OMSTopic"; - public static final String OMSBornTimestamp = "OMSBornTimestamp"; - public static final String OMSBornHost = "OMSBornHost"; - public static final String OMSStoreTimestamp = "OMSStoreTimestamp"; - public static final String OMSStoreHost = "OMSStoreHost"; - public static final String OMSStartTime = "OMSStartTime"; - public static final String OMSStopTime = "OMSStopTime"; - public static final String OMSTimeout = "OMSTimeout"; - public static final String OMSPriority = "OMSPriority"; - public static final String OMSReliability = "OMSReliability"; - public static final String OMSSearchKey = "OMSSearchKey"; - public static final String OMSMsgId = "OMSMsgId"; -} http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java new file mode 100644 index 0000000..de134b9 --- /dev/null +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF 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.apache.openmessaging.exception; + +public class OMSException extends Exception { +} http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java new file mode 100644 index 0000000..ee38600 --- /dev/null +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java @@ -0,0 +1,21 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF 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.apache.openmessaging.exception; + +public class OMSRuntimeException extends RuntimeException { +}
