update version to 1.5
This commit is contained in:
@@ -116,8 +116,9 @@ public class EMDNEmul {
|
||||
executor.scheduleAtFixedRate(()->{
|
||||
for (byte[] message : messages) {
|
||||
LOG.trace("Publish message: {}", message);
|
||||
publisher.send(message);
|
||||
publisher.sendMore(message);
|
||||
}
|
||||
publisher.send(new byte[0]);
|
||||
LOG.trace("Sleep... ");
|
||||
}, 1, 5, TimeUnit.SECONDS);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user