You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/09/18 21:29:53 UTC
[2/5] storm git commit: Add missing file
Add missing file
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cf505187
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cf505187
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cf505187
Branch: refs/heads/master
Commit: cf5051872682b38137a9b297e80498c78f631685
Parents: f64121b
Author: zhuol <zh...@yahoo-inc.com>
Authored: Fri Sep 18 11:53:56 2015 -0500
Committer: zhuol <zh...@yahoo-inc.com>
Committed: Fri Sep 18 11:53:56 2015 -0500
----------------------------------------------------------------------
.../storm/utils/WorkerBackpressureCallback.java | 26 ++++++++++++++++++++
1 file changed, 26 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/cf505187/storm-core/src/jvm/backtype/storm/utils/WorkerBackpressureCallback.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/utils/WorkerBackpressureCallback.java b/storm-core/src/jvm/backtype/storm/utils/WorkerBackpressureCallback.java
new file mode 100755
index 0000000..24aef09
--- /dev/null
+++ b/storm-core/src/jvm/backtype/storm/utils/WorkerBackpressureCallback.java
@@ -0,0 +1,26 @@
+/**
+ * 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 backtype.storm.utils;
+
+public interface WorkerBackpressureCallback {
+
+ void onEvent(Object obj) throws Exception;
+
+}