}
/**
+ * Notifies all listeners that a “PersistentRequestModified” message was
+ * received.
+ *
+ * @param persistentRequestModified
+ * The “PersistentRequestModified” message
+ */
+ private void fireReceivedPersistentRequestModified(PersistentRequestModified persistentRequestModified) {
+ for (FcpListener fcpListener: fcpListeners) {
+ fcpListener.receivedPersistentRequestModified(this, persistentRequestModified);
+ }
+ }
+
+ /**
+ * Notifies all listeners that a “PutSuccessful” message was received.
+ *
+ * @param putSuccessful
+ * The “PutSuccessful” message
+ */
+ private void fireReceivedPutSuccessful(PutSuccessful putSuccessful) {
+ for (FcpListener fcpListener: fcpListeners) {
+ fcpListener.receivedPutSuccessful(this, putSuccessful);
+ }
+ }
+
+ /**
* Notifies all listeners that a “ProtocolError” message was received.
*
* @param protocolError
fireReceivedFinishedCompression(new FinishedCompression(fcpMessage));
} else if ("GetFailed".equals(messageName)) {
fireReceivedGetFailed(new GetFailed(fcpMessage));
+ } else if ("PutSuccessful".equals(messageName)) {
+ fireReceivedPutSuccessful(new PutSuccessful(fcpMessage));
} else if ("PutFailed".equals(messageName)) {
fireReceivedPutFailed(new PutFailed(fcpMessage));
} else if ("DataFound".equals(messageName)) {
fireReceivedSSKKeypair(new SSKKeypair(fcpMessage));
} else if ("PeerRemoved".equals(messageName)) {
fireReceivedPeerRemoved(new PeerRemoved(fcpMessage));
+ } else if ("PersistentRequestModified".equals(messageName)) {
+ fireReceivedPersistentRequestModified(new PersistentRequestModified(fcpMessage));
} else if ("PersistentRequestRemoved".equals(messageName)) {
fireReceivedPersistentRequestRemoved(new PersistentRequestRemoved(fcpMessage));
} else if ("UnknownPeerNoteType".equals(messageName)) {