pshell_config/mxsc
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Closedown

Browse Source
This commit is contained in:
gac-S_Changer
2017-02-10 11:28:12 +01:00
parent b192a9c635
commit 00551fbd4e
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/PuckDetection.java
View File

@@ -56,6 +56,9 @@ public class PuckDetection extends DeviceBase{
doClose();
super.doInitialize();
pucks = new PuckState[PUCKS_NUMBER];
for (int i=0; i<PUCKS_NUMBER; i++ ){
pucks[i] = new PuckState();
}
thread = new Thread(new Runnable() {
@Override
public void run() {
@@ -69,23 +72,18 @@ public class PuckDetection extends DeviceBase{
void subscriberTask(){
try{
System.out.println("Start");
setState(State.Ready);
org.zeromq.ZMQ.Context context = org.zeromq.ZMQ.context(1);
org.zeromq.ZMQ.Socket subscriber = context.socket(org.zeromq.ZMQ.SUB);
System.out.println("Start - 1");
subscriber.connect(server);
subscriber.subscribe("Status".getBytes());
System.out.println("Start - 2");
try{
while (!Thread.currentThread().isInterrupted()) {
System.out.println("Enter");
String type = subscriber.recvStr();
System.out.println(type);
String contents = subscriber.recvStr();
System.out.println(contents);
processMessage(contents);
System.out.println("Exit");
}
} finally{
for (PuckState puck:pucks){