@Override
public void attachToSubparser(final Subparser subparser) {
+ subparser.help("Query the server for new messages.");
subparser.addArgument("-t", "--timeout")
.type(double.class)
- .setDefault(1.0)
+ .setDefault(3.0)
.help("Number of seconds to wait for new messages (negative values disable timeout)");
subparser.addArgument("--ignore-attachments")
.help("Don’t download attachments of received messages.")
if (inJson) {
final var jsonWriter = new JsonWriter(System.out);
- dbusconnection.addSigHandler(Signal.MessageReceived.class, messageReceived -> {
+ dbusconnection.addSigHandler(Signal.MessageReceived.class, signal, messageReceived -> {
var envelope = new JsonMessageEnvelope(messageReceived);
final var object = Map.of("envelope", envelope);
jsonWriter.write(object);
});
- dbusconnection.addSigHandler(Signal.ReceiptReceived.class, receiptReceived -> {
+ dbusconnection.addSigHandler(Signal.ReceiptReceived.class, signal, receiptReceived -> {
var envelope = new JsonMessageEnvelope(receiptReceived);
final var object = Map.of("envelope", envelope);
jsonWriter.write(object);
});
- dbusconnection.addSigHandler(Signal.SyncMessageReceived.class, syncReceived -> {
+ dbusconnection.addSigHandler(Signal.SyncMessageReceived.class, signal, syncReceived -> {
var envelope = new JsonMessageEnvelope(syncReceived);
final var object = Map.of("envelope", envelope);
jsonWriter.write(object);
} else {
final var writer = new PlainTextWriterImpl(System.out);
- dbusconnection.addSigHandler(Signal.MessageReceived.class, messageReceived -> {
+ dbusconnection.addSigHandler(Signal.MessageReceived.class, signal, messageReceived -> {
writer.println("Envelope from: {}", messageReceived.getSender());
writer.println("Timestamp: {}", DateUtils.formatTimestamp(messageReceived.getTimestamp()));
writer.println("Body: {}", messageReceived.getMessage());
writer.println();
});
- dbusconnection.addSigHandler(Signal.ReceiptReceived.class, receiptReceived -> {
+ dbusconnection.addSigHandler(Signal.ReceiptReceived.class, signal, receiptReceived -> {
writer.println("Receipt from: {}", receiptReceived.getSender());
writer.println("Timestamp: {}", DateUtils.formatTimestamp(receiptReceived.getTimestamp()));
});
- dbusconnection.addSigHandler(Signal.SyncMessageReceived.class, syncReceived -> {
+ dbusconnection.addSigHandler(Signal.SyncMessageReceived.class, signal, syncReceived -> {
writer.println("Sync Envelope from: {} to: {}",
syncReceived.getSource(),
syncReceived.getDestination());
returnOnTimeout = false;
timeout = 3600;
}
- boolean ignoreAttachments = ns.getBoolean("ignore_attachments");
+ boolean ignoreAttachments = ns.getBoolean("ignore-attachments");
try {
final var handler = inJson ? new JsonReceiveMessageHandler(m) : new ReceiveMessageHandler(m);
m.receiveMessages((long) (timeout * 1000),