Commit 5b0f9817 authored by Andre Freyssinet's avatar Andre Freyssinet

throwsExceptionOnFullDest

parent 9f5b7402
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2010 - 2017 ScalAgent Distributed Technologies
* Copyright (C) 2010 - 2020 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -312,9 +312,9 @@ public class AcquisitionModule implements ReliableTransmitter {
}
/**
* In <b>request mode</b> (period <= 0), a message received on the acquisition
* In <b>request mode</b> (period &lt;= 0), a message received on the acquisition
* destination will launch an acquisition process. If the message holds
* non-null properties, these properties are first transmitted to the handler.<br>
* non-null properties, these properties are first transmitted to the handler.
* <br>
* In other modes (<b>periodic mode</b> or <b>daemon</b>), such a message
* should not be received, so it is forwarded to the DMQ.
......
This source diff could not be displayed because it is too large. You can view the blob instead.
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2010 - 2018 ScalAgent Distributed Technologies
* Copyright (C) 2010 - 2020 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -226,10 +226,6 @@ public class DistributionQueue extends Queue {
return nbMsgsReceiveSinceCreation - nbMsgsSentToDMQSinceCreation - getPendingMessageCount();
}
/**
* @see DistributionModule#processMessages(ClientMessages)
* @see Destination#preProcess(AgentId, ClientMessages)
*/
public ClientMessages preProcess(AgentId from, ClientMessages cm) {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "DistributionQueue.preProcess(" + from + ", " + cm + ')');
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2010 - 2017 ScalAgent Distributed Technologies
* Copyright (C) 2010 - 2020 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -151,10 +151,6 @@ public class DistributionTopic extends Topic {
}
}
/**
* @see DistributionModule#processMessages(ClientMessages)
* @see Destination#preProcess(AgentId, ClientMessages)
*/
public ClientMessages preProcess(AgentId from, ClientMessages cm) {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "DistributionTopic. preProcess(" + from + ", " + cm + ')');
......
/*
* Copyright (C) 2010 - 2012 ScalAgent Distributed Technologies
* Copyright (C) 2010 - 2020 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -42,7 +42,7 @@ public class NotificationDistributionHandler implements DistributionHandler {
/** the queue to send the notification to */
private AgentId remoteDestinationID = null;
/** @see DistributionHandler#init(Properties) */
@Override
public void init(Properties properties, boolean firstTime) {
remoteDestinationID = AgentId.fromString(properties.getProperty("remoteAgentID"));
......@@ -51,7 +51,7 @@ public class NotificationDistributionHandler implements DistributionHandler {
+ remoteDestinationID + ")");
}
/** @see DistributionHandler#distribute(Message) */
@Override
public void distribute(Message message) throws Exception {
/* building a ClientMessages object for the notification */
ClientMessages cm = new ClientMessages();
......@@ -68,7 +68,7 @@ public class NotificationDistributionHandler implements DistributionHandler {
Channel.sendTo(remoteDestinationID, an);
}
/** @see AcquisitionHandler#close() */
@Override
public void close() {
// Nothing to do
}
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2013 - 2019 ScalAgent Distributed Technologies
* Copyright (C) 2013 - 2020 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -72,7 +72,7 @@ public class QueueArrivalState implements Encodable, Serializable {
/**
* Saves this state if modified.
* @throws Exception
* @throws IOException if an error occurs.
*/
public void save() throws IOException {
if (modified) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment