/**
* Creates a new FCP connection to the freenet node running on localhost,
* using the default port.
/**
* Creates a new FCP connection to the freenet node running on localhost,
* using the default port.
/**
* Creates a new FCP connection to the Freenet node running on the given
* host, listening on the default port.
/**
* Creates a new FCP connection to the Freenet node running on the given
* host, listening on the default port.
/**
* Creates a new FCP connection to the Freenet node running on the given
* host, listening on the given port.
/**
* Creates a new FCP connection to the Freenet node running on the given
* host, listening on the given port.
/**
* Creates a new FCP connection to the Freenet node running at the given
* address, listening on the default port.
/**
* Creates a new FCP connection to the Freenet node running at the given
* address, listening on the default port.
/**
* Creates a new FCP connection to the Freenet node running at the given
* address, listening on the given port.
/**
* Creates a new FCP connection to the Freenet node running at the given
* address, listening on the given port.
* @see FcpListener#receivedNodeHello(FcpConnection, NodeHello)
* @param nodeHello
* The “NodeHello” message
*/
private void fireReceivedNodeHello(NodeHello nodeHello) {
* @see FcpListener#receivedNodeHello(FcpConnection, NodeHello)
* @param nodeHello
* The “NodeHello” message
*/
private void fireReceivedNodeHello(NodeHello nodeHello) {
* @see FcpListener#receivedCloseConnectionDuplicateClientName(FcpConnection,
* CloseConnectionDuplicateClientName)
* @param closeConnectionDuplicateClientName
* The “CloseConnectionDuplicateClientName” message
*/
private void fireReceivedCloseConnectionDuplicateClientName(CloseConnectionDuplicateClientName closeConnectionDuplicateClientName) {
* @see FcpListener#receivedCloseConnectionDuplicateClientName(FcpConnection,
* CloseConnectionDuplicateClientName)
* @param closeConnectionDuplicateClientName
* The “CloseConnectionDuplicateClientName” message
*/
private void fireReceivedCloseConnectionDuplicateClientName(CloseConnectionDuplicateClientName closeConnectionDuplicateClientName) {
fcpListener.receivedCloseConnectionDuplicateClientName(this, closeConnectionDuplicateClientName);
}
}
/**
* Notifies listeners that a “SSKKeypair” message was received.
fcpListener.receivedCloseConnectionDuplicateClientName(this, closeConnectionDuplicateClientName);
}
}
/**
* Notifies listeners that a “SSKKeypair” message was received.
* @see FcpListener#receivedSSKKeypair(FcpConnection, SSKKeypair)
* @param sskKeypair
* The “SSKKeypair” message
*/
private void fireReceivedSSKKeypair(SSKKeypair sskKeypair) {
* @see FcpListener#receivedSSKKeypair(FcpConnection, SSKKeypair)
* @param sskKeypair
* The “SSKKeypair” message
*/
private void fireReceivedSSKKeypair(SSKKeypair sskKeypair) {
fcpListener.receivedSSKKeypair(this, sskKeypair);
}
}
/**
* Notifies listeners that a “Peer” message was received.
fcpListener.receivedSSKKeypair(this, sskKeypair);
}
}
/**
* Notifies listeners that a “Peer” message was received.
* @see FcpListener#receivedPeer(FcpConnection, Peer)
* @param peer
* The “Peer” message
*/
private void fireReceivedPeer(Peer peer) {
* @see FcpListener#receivedPeer(FcpConnection, Peer)
* @param peer
* The “Peer” message
*/
private void fireReceivedPeer(Peer peer) {
fcpListener.receivedPeer(this, peer);
}
}
/**
* Notifies all listeners that an “EndListPeers” message was received.
fcpListener.receivedPeer(this, peer);
}
}
/**
* Notifies all listeners that an “EndListPeers” message was received.
* @see FcpListener#receivedEndListPeers(FcpConnection, EndListPeers)
* @param endListPeers
* The “EndListPeers” message
*/
private void fireReceivedEndListPeers(EndListPeers endListPeers) {
* @see FcpListener#receivedEndListPeers(FcpConnection, EndListPeers)
* @param endListPeers
* The “EndListPeers” message
*/
private void fireReceivedEndListPeers(EndListPeers endListPeers) {
fcpListener.receivedEndListPeers(this, endListPeers);
}
}
/**
* Notifies all listeners that a “PeerNote” message was received.
fcpListener.receivedEndListPeers(this, endListPeers);
}
}
/**
* Notifies all listeners that a “PeerNote” message was received.
* @see FcpListener#receivedPeerNote(FcpConnection, PeerNote)
* @param peerNote
*/
private void fireReceivedPeerNote(PeerNote peerNote) {
* @see FcpListener#receivedPeerNote(FcpConnection, PeerNote)
* @param peerNote
*/
private void fireReceivedPeerNote(PeerNote peerNote) {
fcpListener.receivedPeerNote(this, peerNote);
}
}
/**
* Notifies all listeners that an “EndListPeerNotes” message was received.
fcpListener.receivedPeerNote(this, peerNote);
}
}
/**
* Notifies all listeners that an “EndListPeerNotes” message was received.
* @see FcpListener#receivedEndListPeerNotes(FcpConnection,
* EndListPeerNotes)
* @param endListPeerNotes
* The “EndListPeerNotes” message
*/
private void fireReceivedEndListPeerNotes(EndListPeerNotes endListPeerNotes) {
* @see FcpListener#receivedEndListPeerNotes(FcpConnection,
* EndListPeerNotes)
* @param endListPeerNotes
* The “EndListPeerNotes” message
*/
private void fireReceivedEndListPeerNotes(EndListPeerNotes endListPeerNotes) {
fcpListener.receivedEndListPeerNotes(this, endListPeerNotes);
}
}
/**
* Notifies all listeners that a “PeerRemoved” message was received.
fcpListener.receivedEndListPeerNotes(this, endListPeerNotes);
}
}
/**
* Notifies all listeners that a “PeerRemoved” message was received.
* @see FcpListener#receivedPeerRemoved(FcpConnection, PeerRemoved)
* @param peerRemoved
* The “PeerRemoved” message
*/
private void fireReceivedPeerRemoved(PeerRemoved peerRemoved) {
* @see FcpListener#receivedPeerRemoved(FcpConnection, PeerRemoved)
* @param peerRemoved
* The “PeerRemoved” message
*/
private void fireReceivedPeerRemoved(PeerRemoved peerRemoved) {
fcpListener.receivedPeerRemoved(this, peerRemoved);
}
}
/**
* Notifies all listeners that a “NodeData” message was received.
fcpListener.receivedPeerRemoved(this, peerRemoved);
}
}
/**
* Notifies all listeners that a “NodeData” message was received.
* @see FcpListener#receivedNodeData(FcpConnection, NodeData)
* @param nodeData
* The “NodeData” message
*/
private void fireReceivedNodeData(NodeData nodeData) {
* @see FcpListener#receivedNodeData(FcpConnection, NodeData)
* @param nodeData
* The “NodeData” message
*/
private void fireReceivedNodeData(NodeData nodeData) {
fcpListener.receivedNodeData(this, nodeData);
}
}
/**
* Notifies all listeners that a “TestDDAReply” message was received.
fcpListener.receivedNodeData(this, nodeData);
}
}
/**
* Notifies all listeners that a “TestDDAReply” message was received.
* @see FcpListener#receivedTestDDAReply(FcpConnection, TestDDAReply)
* @param testDDAReply
* The “TestDDAReply” message
*/
private void fireReceivedTestDDAReply(TestDDAReply testDDAReply) {
* @see FcpListener#receivedTestDDAReply(FcpConnection, TestDDAReply)
* @param testDDAReply
* The “TestDDAReply” message
*/
private void fireReceivedTestDDAReply(TestDDAReply testDDAReply) {
fcpListener.receivedTestDDAReply(this, testDDAReply);
}
}
/**
* Notifies all listeners that a “TestDDAComplete” message was received.
fcpListener.receivedTestDDAReply(this, testDDAReply);
}
}
/**
* Notifies all listeners that a “TestDDAComplete” message was received.
* @see FcpListener#receivedTestDDAComplete(FcpConnection, TestDDAComplete)
* @param testDDAComplete
* The “TestDDAComplete” message
*/
private void fireReceivedTestDDAComplete(TestDDAComplete testDDAComplete) {
* @see FcpListener#receivedTestDDAComplete(FcpConnection, TestDDAComplete)
* @param testDDAComplete
* The “TestDDAComplete” message
*/
private void fireReceivedTestDDAComplete(TestDDAComplete testDDAComplete) {
fcpListener.receivedTestDDAComplete(this, testDDAComplete);
}
}
/**
* Notifies all listeners that a “PersistentGet” message was received.
fcpListener.receivedTestDDAComplete(this, testDDAComplete);
}
}
/**
* Notifies all listeners that a “PersistentGet” message was received.
* @see FcpListener#receivedPersistentGet(FcpConnection, PersistentGet)
* @param persistentGet
* The “PersistentGet” message
*/
private void fireReceivedPersistentGet(PersistentGet persistentGet) {
* @see FcpListener#receivedPersistentGet(FcpConnection, PersistentGet)
* @param persistentGet
* The “PersistentGet” message
*/
private void fireReceivedPersistentGet(PersistentGet persistentGet) {
fcpListener.receivedPersistentGet(this, persistentGet);
}
}
/**
* Notifies all listeners that a “PersistentPut” message was received.
fcpListener.receivedPersistentGet(this, persistentGet);
}
}
/**
* Notifies all listeners that a “PersistentPut” message was received.
* @see FcpListener#receivedPersistentPut(FcpConnection, PersistentPut)
* @param persistentPut
* The “PersistentPut” message
*/
private void fireReceivedPersistentPut(PersistentPut persistentPut) {
* @see FcpListener#receivedPersistentPut(FcpConnection, PersistentPut)
* @param persistentPut
* The “PersistentPut” message
*/
private void fireReceivedPersistentPut(PersistentPut persistentPut) {
* @see FcpListener#receivedEndListPersistentRequests(FcpConnection,
* EndListPersistentRequests)
* @param endListPersistentRequests
* The “EndListPersistentRequests” message
*/
private void fireReceivedEndListPersistentRequests(EndListPersistentRequests endListPersistentRequests) {
* @see FcpListener#receivedEndListPersistentRequests(FcpConnection,
* EndListPersistentRequests)
* @param endListPersistentRequests
* The “EndListPersistentRequests” message
*/
private void fireReceivedEndListPersistentRequests(EndListPersistentRequests endListPersistentRequests) {
fcpListener.receivedEndListPersistentRequests(this, endListPersistentRequests);
}
}
/**
* Notifies all listeners that a “URIGenerated” message was received.
fcpListener.receivedEndListPersistentRequests(this, endListPersistentRequests);
}
}
/**
* Notifies all listeners that a “URIGenerated” message was received.
* @see FcpListener#receivedURIGenerated(FcpConnection, URIGenerated)
* @param uriGenerated
* The “URIGenerated” message
*/
private void fireReceivedURIGenerated(URIGenerated uriGenerated) {
* @see FcpListener#receivedURIGenerated(FcpConnection, URIGenerated)
* @param uriGenerated
* The “URIGenerated” message
*/
private void fireReceivedURIGenerated(URIGenerated uriGenerated) {
fcpListener.receivedURIGenerated(this, uriGenerated);
}
}
/**
* Notifies all listeners that a “DataFound” message was received.
fcpListener.receivedURIGenerated(this, uriGenerated);
}
}
/**
* Notifies all listeners that a “DataFound” message was received.
* @see FcpListener#receivedDataFound(FcpConnection, DataFound)
* @param dataFound
* The “DataFound” message
*/
private void fireReceivedDataFound(DataFound dataFound) {
* @see FcpListener#receivedDataFound(FcpConnection, DataFound)
* @param dataFound
* The “DataFound” message
*/
private void fireReceivedDataFound(DataFound dataFound) {
fcpListener.receivedDataFound(this, dataFound);
}
}
/**
* Notifies all listeners that an “AllData” message was received.
fcpListener.receivedDataFound(this, dataFound);
}
}
/**
* Notifies all listeners that an “AllData” message was received.
* @see FcpListener#receivedAllData(FcpConnection, AllData)
* @param allData
* The “AllData” message
*/
private void fireReceivedAllData(AllData allData) {
* @see FcpListener#receivedAllData(FcpConnection, AllData)
* @param allData
* The “AllData” message
*/
private void fireReceivedAllData(AllData allData) {
fcpListener.receivedAllData(this, allData);
}
}
/**
* Notifies all listeners that a “SimpleProgress” message was received.
fcpListener.receivedAllData(this, allData);
}
}
/**
* Notifies all listeners that a “SimpleProgress” message was received.
* @see FcpListener#receivedSimpleProgress(FcpConnection, SimpleProgress)
* @param simpleProgress
* The “SimpleProgress” message
*/
private void fireReceivedSimpleProgress(SimpleProgress simpleProgress) {
* @see FcpListener#receivedSimpleProgress(FcpConnection, SimpleProgress)
* @param simpleProgress
* The “SimpleProgress” message
*/
private void fireReceivedSimpleProgress(SimpleProgress simpleProgress) {
fcpListener.receivedSimpleProgress(this, simpleProgress);
}
}
/**
* Notifies all listeners that a “StartedCompression” message was received.
fcpListener.receivedSimpleProgress(this, simpleProgress);
}
}
/**
* Notifies all listeners that a “StartedCompression” message was received.
* @see FcpListener#receivedStartedCompression(FcpConnection,
* StartedCompression)
* @param startedCompression
* The “StartedCompression” message
*/
private void fireReceivedStartedCompression(StartedCompression startedCompression) {
* @see FcpListener#receivedStartedCompression(FcpConnection,
* StartedCompression)
* @param startedCompression
* The “StartedCompression” message
*/
private void fireReceivedStartedCompression(StartedCompression startedCompression) {
fcpListener.receivedStartedCompression(this, startedCompression);
}
}
/**
* Notifies all listeners that a “FinishedCompression” message was received.
fcpListener.receivedStartedCompression(this, startedCompression);
}
}
/**
* Notifies all listeners that a “FinishedCompression” message was received.
* @see FcpListener#receviedFinishedCompression(FcpConnection,
* FinishedCompression)
* @param finishedCompression
* The “FinishedCompression” message
*/
private void fireReceivedFinishedCompression(FinishedCompression finishedCompression) {
* @see FcpListener#receviedFinishedCompression(FcpConnection,
* FinishedCompression)
* @param finishedCompression
* The “FinishedCompression” message
*/
private void fireReceivedFinishedCompression(FinishedCompression finishedCompression) {
* @see FcpListener#receivedUnknownPeerNoteType(FcpConnection,
* UnknownPeerNoteType)
* @param unknownPeerNoteType
* The “UnknownPeerNoteType” message
*/
private void fireReceivedUnknownPeerNoteType(UnknownPeerNoteType unknownPeerNoteType) {
* @see FcpListener#receivedUnknownPeerNoteType(FcpConnection,
* UnknownPeerNoteType)
* @param unknownPeerNoteType
* The “UnknownPeerNoteType” message
*/
private void fireReceivedUnknownPeerNoteType(UnknownPeerNoteType unknownPeerNoteType) {
* @see FcpListener#receivedUnknownNodeIdentifier(FcpConnection,
* UnknownNodeIdentifier)
* @param unknownNodeIdentifier
* The “UnknownNodeIdentifier” message
*/
private void fireReceivedUnknownNodeIdentifier(UnknownNodeIdentifier unknownNodeIdentifier) {
* @see FcpListener#receivedUnknownNodeIdentifier(FcpConnection,
* UnknownNodeIdentifier)
* @param unknownNodeIdentifier
* The “UnknownNodeIdentifier” message
*/
private void fireReceivedUnknownNodeIdentifier(UnknownNodeIdentifier unknownNodeIdentifier) {
fcpListener.receivedUnknownNodeIdentifier(this, unknownNodeIdentifier);
}
}
/**
* Notifies all listeners that a “ConfigData” message was received.
fcpListener.receivedUnknownNodeIdentifier(this, unknownNodeIdentifier);
}
}
/**
* Notifies all listeners that a “ConfigData” message was received.
* @see FcpListener#receivedConfigData(FcpConnection, ConfigData)
* @param configData
* The “ConfigData” message
*/
private void fireReceivedConfigData(ConfigData configData) {
* @see FcpListener#receivedConfigData(FcpConnection, ConfigData)
* @param configData
* The “ConfigData” message
*/
private void fireReceivedConfigData(ConfigData configData) {
fcpListener.receivedConfigData(this, configData);
}
}
/**
* Notifies all listeners that a “GetFailed” message was received.
fcpListener.receivedConfigData(this, configData);
}
}
/**
* Notifies all listeners that a “GetFailed” message was received.
* @see FcpListener#receivedGetFailed(FcpConnection, GetFailed)
* @param getFailed
* The “GetFailed” message
*/
private void fireReceivedGetFailed(GetFailed getFailed) {
* @see FcpListener#receivedGetFailed(FcpConnection, GetFailed)
* @param getFailed
* The “GetFailed” message
*/
private void fireReceivedGetFailed(GetFailed getFailed) {
fcpListener.receivedGetFailed(this, getFailed);
}
}
/**
* Notifies all listeners that a “PutFailed” message was received.
fcpListener.receivedGetFailed(this, getFailed);
}
}
/**
* Notifies all listeners that a “PutFailed” message was received.
* @see FcpListener#receivedPutFailed(FcpConnection, PutFailed)
* @param putFailed
* The “PutFailed” message
*/
private void fireReceivedPutFailed(PutFailed putFailed) {
* @see FcpListener#receivedPutFailed(FcpConnection, PutFailed)
* @param putFailed
* The “PutFailed” message
*/
private void fireReceivedPutFailed(PutFailed putFailed) {
* @see FcpListener#receivedIdentifierCollision(FcpConnection,
* IdentifierCollision)
* @param identifierCollision
* The “IdentifierCollision” message
*/
private void fireReceivedIdentifierCollision(IdentifierCollision identifierCollision) {
* @see FcpListener#receivedIdentifierCollision(FcpConnection,
* IdentifierCollision)
* @param identifierCollision
* The “IdentifierCollision” message
*/
private void fireReceivedIdentifierCollision(IdentifierCollision identifierCollision) {
fcpListener.receivedIdentifierCollision(this, identifierCollision);
}
}
/**
* Notifies all listeners that an “PersistentPutDir” message was received.
fcpListener.receivedIdentifierCollision(this, identifierCollision);
}
}
/**
* Notifies all listeners that an “PersistentPutDir” message was received.
* @see FcpListener#receivedPersistentPutDir(FcpConnection,
* PersistentPutDir)
* @param persistentPutDir
* The “PersistentPutDir” message
*/
private void fireReceivedPersistentPutDir(PersistentPutDir persistentPutDir) {
* @see FcpListener#receivedPersistentPutDir(FcpConnection,
* PersistentPutDir)
* @param persistentPutDir
* The “PersistentPutDir” message
*/
private void fireReceivedPersistentPutDir(PersistentPutDir persistentPutDir) {
* @see FcpListener#receivedPersistentRequestRemoved(FcpConnection,
* PersistentRequestRemoved)
* @param persistentRequestRemoved
* The “PersistentRequestRemoved” message
*/
private void fireReceivedPersistentRequestRemoved(PersistentRequestRemoved persistentRequestRemoved) {
* @see FcpListener#receivedPersistentRequestRemoved(FcpConnection,
* PersistentRequestRemoved)
* @param persistentRequestRemoved
* The “PersistentRequestRemoved” message
*/
private void fireReceivedPersistentRequestRemoved(PersistentRequestRemoved persistentRequestRemoved) {
fcpListener.receivedPersistentRequestRemoved(this, persistentRequestRemoved);
}
}
/**
* Notifies all listeners that a “SubscribedUSKUpdate” message was received.
fcpListener.receivedPersistentRequestRemoved(this, persistentRequestRemoved);
}
}
/**
* Notifies all listeners that a “SubscribedUSKUpdate” message was received.
* @see FcpListener#receivedSubscribedUSKUpdate(FcpConnection,
* SubscribedUSKUpdate)
* @param subscribedUSKUpdate
* The “SubscribedUSKUpdate” message
*/
private void fireReceivedSubscribedUSKUpdate(SubscribedUSKUpdate subscribedUSKUpdate) {
* @see FcpListener#receivedSubscribedUSKUpdate(FcpConnection,
* SubscribedUSKUpdate)
* @param subscribedUSKUpdate
* The “SubscribedUSKUpdate” message
*/
private void fireReceivedSubscribedUSKUpdate(SubscribedUSKUpdate subscribedUSKUpdate) {
fcpListener.receivedSubscribedUSKUpdate(this, subscribedUSKUpdate);
}
}
/**
* Notifies all listeners that a “PluginInfo” message was received.
fcpListener.receivedSubscribedUSKUpdate(this, subscribedUSKUpdate);
}
}
/**
* Notifies all listeners that a “PluginInfo” message was received.
* @see FcpListener#receivedPluginInfo(FcpConnection, PluginInfo)
* @param pluginInfo
* The “PluginInfo” message
*/
private void fireReceivedPluginInfo(PluginInfo pluginInfo) {
* @see FcpListener#receivedPluginInfo(FcpConnection, PluginInfo)
* @param pluginInfo
* The “PluginInfo” message
*/
private void fireReceivedPluginInfo(PluginInfo pluginInfo) {
fcpListener.receivedPluginInfo(this, pluginInfo);
}
}
/**
* Notifies all listeners that an “FCPPluginReply” message was received.
fcpListener.receivedPluginInfo(this, pluginInfo);
}
}
/**
* Notifies all listeners that an “FCPPluginReply” message was received.
* @see FcpListener#receivedFCPPluginReply(FcpConnection, FCPPluginReply)
* @param fcpPluginReply
* The “FCPPluginReply” message
*/
private void fireReceivedFCPPluginReply(FCPPluginReply fcpPluginReply) {
* @see FcpListener#receivedFCPPluginReply(FcpConnection, FCPPluginReply)
* @param fcpPluginReply
* The “FCPPluginReply” message
*/
private void fireReceivedFCPPluginReply(FCPPluginReply fcpPluginReply) {
* @see FcpListener#receivedPersistentRequestModified(FcpConnection,
* PersistentRequestModified)
* @param persistentRequestModified
* The “PersistentRequestModified” message
*/
private void fireReceivedPersistentRequestModified(PersistentRequestModified persistentRequestModified) {
* @see FcpListener#receivedPersistentRequestModified(FcpConnection,
* PersistentRequestModified)
* @param persistentRequestModified
* The “PersistentRequestModified” message
*/
private void fireReceivedPersistentRequestModified(PersistentRequestModified persistentRequestModified) {
fcpListener.receivedPersistentRequestModified(this, persistentRequestModified);
}
}
/**
* Notifies all listeners that a “PutSuccessful” message was received.
fcpListener.receivedPersistentRequestModified(this, persistentRequestModified);
}
}
/**
* Notifies all listeners that a “PutSuccessful” message was received.
* @see FcpListener#receivedPutSuccessful(FcpConnection, PutSuccessful)
* @param putSuccessful
* The “PutSuccessful” message
*/
private void fireReceivedPutSuccessful(PutSuccessful putSuccessful) {
* @see FcpListener#receivedPutSuccessful(FcpConnection, PutSuccessful)
* @param putSuccessful
* The “PutSuccessful” message
*/
private void fireReceivedPutSuccessful(PutSuccessful putSuccessful) {
fcpListener.receivedPutSuccessful(this, putSuccessful);
}
}
/**
* Notifies all listeners that a “PutFetchable” message was received.
fcpListener.receivedPutSuccessful(this, putSuccessful);
}
}
/**
* Notifies all listeners that a “PutFetchable” message was received.
* @see FcpListener#receivedPutFetchable(FcpConnection, PutFetchable)
* @param putFetchable
* The “PutFetchable” message
*/
private void fireReceivedPutFetchable(PutFetchable putFetchable) {
* @see FcpListener#receivedPutFetchable(FcpConnection, PutFetchable)
* @param putFetchable
* The “PutFetchable” message
*/
private void fireReceivedPutFetchable(PutFetchable putFetchable) {
fcpListener.receivedPutFetchable(this, putFetchable);
}
}
/**
* Notifies all listeners that a “ProtocolError” message was received.
fcpListener.receivedPutFetchable(this, putFetchable);
}
}
/**
* Notifies all listeners that a “ProtocolError” message was received.
* @see FcpListener#receivedProtocolError(FcpConnection, ProtocolError)
* @param protocolError
* The “ProtocolError” message
*/
private void fireReceivedProtocolError(ProtocolError protocolError) {
* @see FcpListener#receivedProtocolError(FcpConnection, ProtocolError)
* @param protocolError
* The “ProtocolError” message
*/
private void fireReceivedProtocolError(ProtocolError protocolError) {
fcpListener.receivedProtocolError(this, protocolError);
}
}
/**
* Notifies all registered listeners that a message has been received.
fcpListener.receivedProtocolError(this, protocolError);
}
}
/**
* Notifies all registered listeners that a message has been received.
* @see FcpListener#receivedMessage(FcpConnection, FcpMessage)
* @param fcpMessage
* The message that was received
*/
private void fireMessageReceived(FcpMessage fcpMessage) {
* @see FcpListener#receivedMessage(FcpConnection, FcpMessage)
* @param fcpMessage
* The message that was received
*/
private void fireMessageReceived(FcpMessage fcpMessage) {
fcpListener.receivedMessage(this, fcpMessage);
}
}
/**
* Notifies all listeners that the connection to the node was closed.
fcpListener.receivedMessage(this, fcpMessage);
}
}
/**
* Notifies all listeners that the connection to the node was closed.
* @param throwable
* The exception that caused the disconnect, or <code>null</code>
* if there was no exception
* @see FcpListener#connectionClosed(FcpConnection, Throwable)
*/
private void fireConnectionClosed(Throwable throwable) {
* @param throwable
* The exception that caused the disconnect, or <code>null</code>
* if there was no exception
* @see FcpListener#connectionClosed(FcpConnection, Throwable)
*/
private void fireConnectionClosed(Throwable throwable) {
/**
* Handles the given message, notifying listeners. This message should only
* be called by {@link FcpConnectionHandler}.
/**
* Handles the given message, notifying listeners. This message should only
* be called by {@link FcpConnectionHandler}.
* @param throwable
* The exception that caused the disconnect, or <code>null</code>
* if there was no exception
* @param throwable
* The exception that caused the disconnect, or <code>null</code>
* if there was no exception
if (connectionHandler != null) {
connectionHandler.stop();
connectionHandler = null;
if (connectionHandler != null) {
connectionHandler.stop();
connectionHandler = null;
/**
* Incremets the counter in {@link #incomingMessageStatistics} by <cod>1</code>
* for the given message name.
/**
* Incremets the counter in {@link #incomingMessageStatistics} by <cod>1</code>
* for the given message name.
/**
* A wrapper around an {@link InputStream} that only supplies a limit number
* of bytes from the underlying input stream.
/**
* A wrapper around an {@link InputStream} that only supplies a limit number
* of bytes from the underlying input stream.
/**
* Creates a new LimitedInputStream that supplies at most
* <code>length</code> bytes from the given input stream.
/**
* Creates a new LimitedInputStream that supplies at most
* <code>length</code> bytes from the given input stream.
/**
* {@inheritDoc} This method does nothing, as {@link #mark(int)} and
* {@link #reset()} are not supported.
/**
* {@inheritDoc} This method does nothing, as {@link #mark(int)} and
* {@link #reset()} are not supported.
/**
* {@inheritDoc} This method does nothing, as {@link #mark(int)} and
* {@link #reset()} are not supported.
/**
* {@inheritDoc} This method does nothing, as {@link #mark(int)} and
* {@link #reset()} are not supported.