ROBOT_DEMO: move to contribs

[orte.git] / orte / contrib / Robot_Demo / src / org / ocera / orte / demo / Publishers / MagnetCmdPublish.java

diff --git a/orte/contrib/Robot_Demo/src/org/ocera/orte/demo/Publishers/MagnetCmdPublish.java b/orte/contrib/Robot_Demo/src/org/ocera/orte/demo/Publishers/MagnetCmdPublish.java
new file mode 100644 (file)
index 0000000..101c5da
--- /dev/null
+++ b/orte/contrib/Robot_Demo/src/org/ocera/orte/demo/Publishers/MagnetCmdPublish.java
@@ -0,0 +1,73 @@
+package org.ocera.orte.demo.Publishers;
+
+import java.util.concurrent.locks.ReentrantReadWriteLock;
+import java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock;
+import java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock;
+
+import org.ocera.orte.DomainApp;
+import org.ocera.orte.Publication;
+import org.ocera.orte.demo.DataTypes.MagnetCmdType;
+import org.ocera.orte.types.NtpTime;
+import org.ocera.orte.types.PublProp;
+
+public class MagnetCmdPublish {
+       
+       private boolean isCancelled = true;
+       private MagnetCmdType magnetmsg;
+       private Publication pub;
+       private PublProp publProp;
+       private DomainApp appDomain;
+       
+       private final ReentrantReadWriteLock controlRrwl = new ReentrantReadWriteLock(true);
+       private final ReadLock rcLock = controlRrwl.readLock();
+       private final WriteLock wcLock = controlRrwl.writeLock();
+       
+       public MagnetCmdPublish(DomainApp appDomain) {
+               this.appDomain = appDomain;
+               
+           NtpTime persistence = new NtpTime(3);
+           int strength = 100;
+           
+           magnetmsg = new MagnetCmdType(appDomain,"magnet_cmd");
+           
+           publProp = new PublProp(magnetmsg.getTopic(),
+                                                                        "magnet_cmd",                                  
+                                                                        persistence,
+                                                                        strength);
+       }
+       
+       public void start() {
+               wcLock.lock();
+               try {
+                       isCancelled = false;
+                   pub = appDomain.createPublication(publProp, magnetmsg);
+               }
+               finally {
+                       wcLock.unlock();
+               }
+       }
+       
+       public void cancel() {
+               wcLock.lock();
+               try {
+                       isCancelled = true;
+                       pub.destroy();
+               } finally {
+                       wcLock.unlock();
+               }
+       }
+       
+       public boolean isCancelled() {
+               rcLock.lock();
+               try {
+                       return isCancelled;
+               } finally {
+                       rcLock.unlock();
+               }
+       }
+       
+       public void send(int magnet) {
+               magnetmsg.magnet = magnet;
+               pub.send(magnetmsg);
+       }
+}