imagej/ch.psi.imagej.zmq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Removed dependency ...

Browse Source
This commit is contained in:
ebner 2013-06-11 08:10:29 +02:00
parent df80d7b007
commit cd70bff6f5
2 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ch.psi.imagej.zeromq/pom.xml
View File

@ -27,7 +27,7 @@
<configuration> <configuration>
<finalName>ZeroMQ_Viewer-${pom.version}</finalName> <finalName>ZeroMQ_Viewer-${pom.version}</finalName>
<appendAssemblyId>false</appendAssemblyId> <appendAssemblyId>false</appendAssemblyId>
<archive/> <archive />
<descriptorRefs> <descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef> <descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs> </descriptorRefs>

15
ch.psi.imagej.zeromq/src/main/java/ch/psi/imagej/zeromq/ZeroMQViewer.java
View File

@ -21,6 +21,7 @@ import javax.swing.Timer;
import org.jeromq.ZMQ; import org.jeromq.ZMQ;
public class ZeroMQViewer implements PlugIn { public class ZeroMQViewer implements PlugIn {
private static final Logger logger = Logger.getLogger(ZeroMQViewer.class.getName()); private static final Logger logger = Logger.getLogger(ZeroMQViewer.class.getName());
@ -103,13 +104,14 @@ public class ZeroMQViewer implements PlugIn {
logger.info("Connected to: tcp://"+hostname+":"+port); logger.info("Connected to: tcp://"+hostname+":"+port);
while(collect){ while(collect){
byte[] message = socket.recv(); byte[] header = socket.recv();
byte[] content = null; byte[] content = null;
if (socket.hasReceiveMore()) { if (socket.hasReceiveMore()) {
content = socket.recv(); content = socket.recv();
} }
logger.info(new String(message));
updateImage(content); readHeader(header);
readContent(content);
} }
socket.close(); socket.close();
@ -134,7 +136,12 @@ public class ZeroMQViewer implements PlugIn {
} }
} }
public void updateImage(byte[] content) { private void readHeader(byte[] header){
String sheader = new String(header);
logger.info(sheader);
}
private void readContent(byte[] content) {
try { try {
if (img == null) { if (img == null) {
// TODO eventually use ByteProcessor or BinaryProcessor // TODO eventually use ByteProcessor or BinaryProcessor