Updated Branches: refs/heads/master 206626dce -> eb870cc94
http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java ---------------------------------------------------------------------- diff --git a/jacob/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java b/jacob/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java deleted file mode 100644 index c0f5d05..0000000 --- a/jacob/src/test/java/org/apache/ode/jacob/examples/helloworld/HelloWorld.java +++ /dev/null @@ -1,206 +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.ode.jacob.examples.helloworld; - -import org.apache.ode.jacob.Channel; -import org.apache.ode.jacob.JacobRunnable; -import org.apache.ode.jacob.ReceiveProcess; -import org.apache.ode.jacob.Synch; -import org.apache.ode.jacob.Val; -import org.apache.ode.jacob.examples.sequence.Sequence; -import org.apache.ode.jacob.vpu.ExecutionQueueImpl; -import org.apache.ode.jacob.vpu.JacobVPU; - -/** - * Simple Hello World example to showcase different - * features and approaches of the Jacob API. - * - * Inspired by http://scienceblogs.com/goodmath/2007/04/16/back-to-calculus-a-better-intr-1/ - * - */ -@SuppressWarnings("serial") -public class HelloWorld extends JacobRunnable { - - public interface Callback<T, R extends Channel> extends Channel { - public void invoke(T value, R callback); - } - - static class ReliablePrinterProcess extends JacobRunnable { - private Callback<String, Synch> _in; - public ReliablePrinterProcess(Callback<String, Synch> in) { - _in = in; - } - - public void run() { - object(true, new ReceiveProcess() { - private static final long serialVersionUID = 1L; - }.setChannel(_in).setReceiver(new Callback<String, Synch>(){ - @Override - public void invoke(String value, Synch callback) { - System.out.println(value); - callback.ret(); - } - })); - } - } - - static class ReliableStringEmitterProcess extends JacobRunnable { - private String str; - private Callback<String, Synch> to; - - public ReliableStringEmitterProcess(String str, Callback<String, Synch> to) { - this.str = str; - this.to = to; - } - - public void run() { - Synch callback = newChannel(Synch.class, "callback channel to ACK " + str); - object(new ReceiveProcess() { - private static final long serialVersionUID = 1L; - }.setChannel(callback).setReceiver(new Synch() { - @Override - public void ret() { - System.out.println(str + " ACKed"); - } - })); - to.invoke(str, callback); - } - } - - static class PrinterProcess extends JacobRunnable { - private Val _in; - public PrinterProcess(Val in) { - _in = in; - } - - public void run() { - object(true, new ReceiveProcess() { - private static final long serialVersionUID = 1L; - }.setChannel(_in).setReceiver(new Val(){ - public void val(Object o) { - System.out.println(o); - } - })); - } - } - - static class StringEmitterProcess extends JacobRunnable { - private String str; - private Val to; - - public StringEmitterProcess(String str, Val to) { - this.str = str; - this.to = to; - } - - public void run() { - to.val(str); - } - } - - static class ForwarderProcess extends JacobRunnable { - private Val in; - private Val out; - public ForwarderProcess(Val in, Val out) { - this.in = in; - this.out = out; - } - - public void run() { - object(true, new ReceiveProcess() { - private static final long serialVersionUID = 1L; - }.setChannel(in).setReceiver(new Val(){ - public void val(Object o) { - out.val(o); - } - })); - } - } - - private void simpleHelloWorld() { - // new(out) - final Val out = newChannel(Val.class, "simpleHelloWorld-out"); - // new(x) - final Val x = newChannel(Val.class, "simpleHelloWorld-x"); - // *(?out(str).!sysout(str)) - instance(new PrinterProcess(out)); - // *(?x(str).!out(str)) - instance(new ForwarderProcess(x, out)); - - // !out(hello) | !out(world) - instance(new StringEmitterProcess("Hello", x)); - instance(new StringEmitterProcess("World", x)); - } - - private void reliableHelloWorld() { - // reliable version of the code above - // (new(callback).!out(hello).?callback) | (new(callback).!out(world).?callback) - - // new(rout) - Callback<String, Synch> rout = newChannel(Callback.class, "reliableHelloWorld-rout"); - // *(?rout(str).!sysout(str)) - instance(new ReliablePrinterProcess(rout)); - // (new(callback).!out(hello).?callback) - instance(new ReliableStringEmitterProcess("Hello", rout)); - // (new(callback).!out(world).?callback) - instance(new ReliableStringEmitterProcess("World", rout)); - } - - - private void sequencedHelloWorld() { - // send hello world as a sequence - // !out(hello).!out(world) - - // new(out) - final Val out = newChannel(Val.class, "sequencedHelloWorld-out"); - - final String[] greeting = {"Hello", "World"}; - instance(new Sequence(greeting.length, null) { - @Override - protected JacobRunnable doStep(final int step, final Synch done) { - return new JacobRunnable() { - @Override - public void run() { - instance(new StringEmitterProcess(greeting[step], out)); - done.ret(); - } - }; - } - }); - } - - @Override - public void run() { - simpleHelloWorld(); - reliableHelloWorld(); - sequencedHelloWorld(); - } - - public static void main(String args[]) { - JacobVPU vpu = new JacobVPU(); - vpu.setContext(new ExecutionQueueImpl(null)); - vpu.inject(new HelloWorld()); - while (vpu.execute()) { - System.out.println(vpu.isComplete() ? "<0>" : "."); - //vpu.dumpState(); - } - vpu.dumpState(); - } - -} http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/test/java/org/apache/ode/jacob/examples/sequence/Sequence.java ---------------------------------------------------------------------- diff --git a/jacob/src/test/java/org/apache/ode/jacob/examples/sequence/Sequence.java b/jacob/src/test/java/org/apache/ode/jacob/examples/sequence/Sequence.java deleted file mode 100644 index df4a785..0000000 --- a/jacob/src/test/java/org/apache/ode/jacob/examples/sequence/Sequence.java +++ /dev/null @@ -1,75 +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.ode.jacob.examples.sequence; - -import org.apache.ode.jacob.JacobRunnable; -import org.apache.ode.jacob.ReceiveProcess; -import org.apache.ode.jacob.Synch; - -/** - * Abstract process that executes a number of steps sequentially. - */ -@SuppressWarnings("serial") -public abstract class Sequence extends JacobRunnable { - private int _steps; - private int _current; - private Synch _done; - - /** - * Create a {@link Sequence} with a number of steps. - * - * @param steps number of steps - * @param done synchronous callback - */ - public Sequence(int steps, Synch done) { - _steps = steps; - _current = 0; - _done = done; - } - - /** - * Process execution block - */ - public void run() { - if (_current >= _steps) { - if (_done != null) { - _done.ret(); - } - } else { - Synch r = newChannel(Synch.class); - object(new ReceiveProcess() { - private static final long serialVersionUID = -6999108928780639603L; - }.setChannel(r).setReceiver(new Synch() { - public void ret() { - ++_current; - instance(Sequence.this); - } - })); - instance(doStep(_current, r)); - } - } - - /** - * Execute a step - * @param step step number - * @param done notification after step completion - * @return runnable process - */ - protected abstract JacobRunnable doStep(int step, Synch done); -} http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrint.java ---------------------------------------------------------------------- diff --git a/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrint.java b/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrint.java deleted file mode 100644 index 2c38a43..0000000 --- a/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrint.java +++ /dev/null @@ -1,34 +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.ode.jacob.examples.synch; - -import org.apache.ode.jacob.Channel; -import org.apache.ode.jacob.Synch; - -/** - * DOCUMENTME. - * <p>Created on Mar 4, 2004 at 4:21:03 PM.</p> - * - * @author Maciej Szefler <a href="mailto:[email protected]">mbs</a> - */ -public interface SynchPrint extends Channel { - - public Synch print(String msg); - -} http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java ---------------------------------------------------------------------- diff --git a/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java b/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java deleted file mode 100644 index b6a4942..0000000 --- a/jacob/src/test/java/org/apache/ode/jacob/examples/synch/SynchPrinter.java +++ /dev/null @@ -1,136 +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.ode.jacob.examples.synch; - -import org.apache.ode.jacob.JacobRunnable; -import org.apache.ode.jacob.ReceiveProcess; -import org.apache.ode.jacob.Synch; -import org.apache.ode.jacob.vpu.ExecutionQueueImpl; -import org.apache.ode.jacob.vpu.JacobVPU; - -import static org.apache.ode.jacob.ProcessUtil.receive; - -/** - * Example JACOB process illustrating the use of {@link SynchPrint} - * - * @author Maciej Szefler <a href="mailto:[email protected]">mbs</a> - */ -public class SynchPrinter { - - public static final class SystemPrinter extends JacobRunnable { - private static final long serialVersionUID = -8516348116865575605L; - - private SynchPrint _self; - - public SystemPrinter(SynchPrint self) { - _self = self; - } - - @SuppressWarnings("serial") - public void run() { - object(true, new ReceiveProcess() { - private static final long serialVersionUID = -1990741944766989782L; - }.setChannel(_self).setReceiver(new SynchPrint() { - public Synch print(String msg) { - System.out.println(msg); - return null; // Synch channel automatically created by JacobVPU - } - })); - } - } - - public static final class Tester extends JacobRunnable { - private static final long serialVersionUID = 7899682832271627464L; - - public void run() { - final SynchPrint p = newChannel(SynchPrint.class); - instance(new SystemPrinter(p)); - dudeWhoStoleMyCar(p) - .order("garlic chicken") - .and().then().order("white rice") - .and().then().order("wonton soup") - .and().then().order("fortune cookies") - .and().then().and().then().and().then().and().then() - .and().no().andthen(); - } - - public static PrinterProcess dudeWhoStoleMyCar(SynchPrint p) { - return new PrinterProcess(p); - } - - public static final class PrinterProcess implements Runnable { - private final SynchPrint printer; - final private PrinterProcess prev; - private PrinterProcess next; - private String message; - - public PrinterProcess(final SynchPrint p) { - this(p, null); - } - private PrinterProcess(final SynchPrint p, final PrinterProcess prev) { - printer = p; - this.prev = prev; - } - public PrinterProcess order(String message) { - this.message = message; - return this; - } - public PrinterProcess and() { - // noop - return this; - } - public PrinterProcess then() { - if (message == null) { - return this; - } - next = new PrinterProcess(printer, this); - return next; - } - public PrinterProcess no() { - return prev != null ? prev.no() : this; - } - public void andthen() { - run(); - } - - @Override - public void run() { - if (message != null) { - object(receive(printer.print(message), new Synch() { - private static final long serialVersionUID = 1L; - public void ret() { - if (next != null) { - next.run(); - } - } - })); - } - } - } - } - - public static void main(String args[]) { - JacobVPU vpu = new JacobVPU(); - vpu.setContext(new ExecutionQueueImpl(null)); - vpu.inject(new Tester()); - while (vpu.execute()) { - // run - } - } -} http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/test/java/org/apache/ode/jacob/vpu/ProxyConstructorTimingTest.java ---------------------------------------------------------------------- diff --git a/jacob/src/test/java/org/apache/ode/jacob/vpu/ProxyConstructorTimingTest.java b/jacob/src/test/java/org/apache/ode/jacob/vpu/ProxyConstructorTimingTest.java deleted file mode 100644 index 623e2ca..0000000 --- a/jacob/src/test/java/org/apache/ode/jacob/vpu/ProxyConstructorTimingTest.java +++ /dev/null @@ -1,176 +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.ode.jacob.vpu; - -import java.lang.reflect.InvocationHandler; -import java.lang.reflect.Method; -import java.lang.reflect.Proxy; - -import org.apache.ode.jacob.ChannelProxy; -import org.apache.ode.jacob.Channel; -import org.apache.ode.jacob.ProcessUtil; - -import junit.framework.TestCase; - - -public class ProxyConstructorTimingTest extends TestCase { - private static final long COUNT = 1000000L; - public ProxyConstructorTimingTest(String testName) { - super(testName); - } - - public void testDoNothing() throws Exception { - Greeter gp = (Greeter) Proxy.newProxyInstance(Greeter.class.getClassLoader(), - new Class<?>[] {ChannelProxy.class, Greeter.class}, new GreeterInvocationHandler(new GreeterImpl())); - assertEquals("Hello World", gp.hello("World")); - } - - public interface TestExecution { - public void execute() throws Exception; - } - - public class RepeatExecution implements TestExecution { - private final long count; - private final TestExecution test; - public RepeatExecution(long count, TestExecution test) { - this.count = count; - this.test = test; - } - public void execute() throws Exception { - for (long i = 0; i < count; i++) { - test.execute(); - } - } - } - - public class TimedExecution implements TestExecution { - private final String name; - private final TestExecution test; - public TimedExecution(String name, TestExecution test) { - this.name = name; - this.test = test; - } - public void execute() throws Exception { - NanoTimer timer = new NanoTimer().start(); - test.execute(); - System.out.println("TimedExecution(" + name + "): " + timer.stop() + "[ns]"); - } - } - - public void timedRepeatedExecution(String name, TestExecution test) throws Exception { - new TimedExecution(name, new RepeatExecution(COUNT, test)).execute(); - } - - public void manualTestProxyTiming() throws Exception { - timedRepeatedExecution("direct invocation", new TestExecution() { - @Override - public void execute() throws Exception { - // Create new instance every time - new GreeterImpl2().hello("World"); - } - }); - - timedRepeatedExecution("newProxyInstance", new TestExecution() { - @Override - public void execute() throws Exception { - Greeter gp = (Greeter) Proxy.newProxyInstance(Greeter.class.getClassLoader(), - new Class<?>[] {Greeter.class}, new GreeterInvocationHandler(new GreeterImpl2())); - gp.hello("World"); - } - }); - - final ProxyConstructor<Greeter> helper = new ProxyConstructor<Greeter>(Greeter.class); - timedRepeatedExecution("ProxyConstructor", new TestExecution() { - @Override - public void execute() throws Exception { - Greeter gp = (Greeter) helper.newInstance(new GreeterInvocationHandler(new GreeterImpl2())); - gp.hello("World"); - } - }); - } - - public interface Greeter extends Channel { - String hello(String name); - } - - @SuppressWarnings("serial") - public class GreeterImpl implements Greeter { - public String hello(String name) { - return "Hello " + name; - } - } - - @SuppressWarnings("serial") - public class GreeterImpl2 implements Greeter { - public String hello(String name) { - return ""; - } - } - - public class GreeterInvocationHandler implements InvocationHandler { - private Object greeter; - GreeterInvocationHandler(Object o) { - greeter = o; - } - - public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { - if(Object.class == method.getDeclaringClass()) { - String name = method.getName(); - if("equals".equals(name)) { - return proxy == args[0]; - } else if("hashCode".equals(name)) { - return System.identityHashCode(proxy); - } else if("toString".equals(name)) { - return proxy.getClass().getName() + "@" + - Integer.toHexString(System.identityHashCode(proxy)) + - ", with InvocationHandler " + this; - } else { - throw new IllegalStateException(String.valueOf(method)); - } - } - return method.invoke(greeter, args); - } - } - - // TODO: may be useful for other things? move it somewhere else? - public class NanoTimer { - private long start; - private long lap; - // TODO: we could also count laps... - public NanoTimer() { - // don't start by default, easy to just call .start(); - } - public NanoTimer start() { - start = System.nanoTime(); - lap = start; - return this; - } - public long stop() { - long span = System.nanoTime() - start; - start = 0; - lap = 0; - return span; - } - public long lap() { - long prev = lap; - lap = (start != 0) ? System.nanoTime() : 0; - return lap - prev; - } - } -} http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/jacob/src/test/resources/log4j.properties b/jacob/src/test/resources/log4j.properties deleted file mode 100644 index 9c6599f..0000000 --- a/jacob/src/test/resources/log4j.properties +++ /dev/null @@ -1,34 +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. -# - -# Set root logger level to WARN and its only appender to CONSOLE -log4j.rootLogger=WARN, file - -# log4j properties to work with command line tools. -log4j.category.org.apache.ode=INFO - -# Console appender -log4j.appender.stdout=org.apache.log4j.ConsoleAppender -log4j.appender.stdout.layout=org.apache.log4j.PatternLayout -log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n - -log4j.appender.file=org.apache.log4j.FileAppender -log4j.appender.file.File=target/test.log -log4j.appender.file.layout=org.apache.log4j.PatternLayout -log4j.appender.file.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n -log4j.appender.file.append=false - http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/xdt/org/apache/ode/jacob/ChannelListener.xdt ---------------------------------------------------------------------- diff --git a/jacob/src/xdt/org/apache/ode/jacob/ChannelListener.xdt b/jacob/src/xdt/org/apache/ode/jacob/ChannelListener.xdt deleted file mode 100644 index 38fdea3..0000000 --- a/jacob/src/xdt/org/apache/ode/jacob/ChannelListener.xdt +++ /dev/null @@ -1,39 +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. - * - * SOURCE FILE GENERATATED BY JACOB CHANNEL CLASS GENERATOR - * !!! DO NOT EDIT !!!! - */ -package <XDtPackage:packageOf><XDtClass:fullClassName/></XDtPackage:packageOf>; - -import org.apache.commons.logging.LogFactory; -import org.apache.commons.logging.Log; - -public abstract class <XDtClass:classOf><XDtClass:fullClassName/>ChannelListener</XDtClass:classOf> - extends org.apache.ode.jacob.ChannelListener<<XDtClass:classOf><XDtClass:fullClassName/>Channel</XDtClass:classOf>> - implements <XDtClass:classOf><XDtClass:fullClassName/></XDtClass:classOf> - { - private static final Log __log = LogFactory.getLog(<XDtClass:classOf><XDtClass:fullClassName/>ChannelListener</XDtClass:classOf>.class); - protected Log log() { return __log; } - - protected <XDtClass:classOf><XDtClass:fullClassName/>ChannelListener</XDtClass:classOf>( - <XDtClass:classOf><XDtClass:fullClassName/>Channel</XDtClass:classOf> channel) { - super(channel); - } - -} http://git-wip-us.apache.org/repos/asf/ode/blob/eb870cc9/jacob/src/xdt/org/apache/ode/jacob/channel.xdt ---------------------------------------------------------------------- diff --git a/jacob/src/xdt/org/apache/ode/jacob/channel.xdt b/jacob/src/xdt/org/apache/ode/jacob/channel.xdt deleted file mode 100644 index b77feff..0000000 --- a/jacob/src/xdt/org/apache/ode/jacob/channel.xdt +++ /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. - * - * SOURCE FILE GENERATATED BY JACOB CHANNEL CLASS GENERATOR - * !!! DO NOT EDIT !!!! - */ -package <XDtPackage:packageOf><XDtClass:fullClassName/></XDtPackage:packageOf>; - -public interface <XDtClass:classOf><XDtClass:fullClassName/>Channel</XDtClass:classOf> - extends <XDtClass:ifHasClassTag tagName="jacob.parent"> - <XDtClass:classTagValue tagName="jacob.parent"/>, - </XDtClass:ifHasClassTag> - <XDtClass:ifDoesntHaveClassTag tagName="jacob.parent"> - org.apache.ode.jacob.Channel, - </XDtClass:ifDoesntHaveClassTag> - <XDtClass:classOf><XDtClass:fullClassName/></XDtClass:classOf> -{ -}
