org.jivesoftware.smackx.filetransfer

Class StreamNegotiator

java.lang.Object

org.jivesoftware.smackx.filetransfer.StreamNegotiator

Direct Known Subclasses:

FaultTolerantNegotiator, IBBTransferNegotiator, Socks5TransferNegotiator

public abstract class StreamNegotiator
extends Object

After the file transfer negotiation process is completed according to XEP-0096, the negotiation process is passed off to a particular stream negotiator. The stream negotiator will then negotiate the chosen stream and return the stream to transfer the file.

Author:

Alexander Wenckus

Field Summary

Fields

Modifier and Type	Field and Description
protected static EventManger<String,IQ,SmackException.NotConnectedException>	initationSetEvents A event manager for stream initiation requests send to us.

Constructor Summary

Constructors

Constructor and Description
StreamNegotiator()

Method Summary

Modifier and Type	Method and Description
abstract InputStream	createIncomingStream(StreamInitiation initiation) This method handles the file stream download negotiation process.
protected static StreamInitiation	createInitiationAccept(StreamInitiation streamInitiationOffer, String[] namespaces) Creates the initiation acceptance stanza(/packet) to forward to the stream initiator.
abstract OutputStream	createOutgoingStream(String streamID, String initiator, String target) This method handles the file upload stream negotiation process.
abstract String[]	getNamespaces() Returns the XMPP namespace reserved for this particular type of file transfer.
protected IQ	initiateIncomingStream(XMPPConnection connection, StreamInitiation initiation)
protected abstract void	newStreamInitiation(String from, String streamID) Signal that a new stream initiation arrived.
static void	signal(String eventKey, IQ eventValue)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

initationSetEvents

protected static final EventManger<String,IQ,SmackException.NotConnectedException> initationSetEvents

A event manager for stream initiation requests send to us.

Those are typical XEP-45 Open or XEP-65 Bytestream IQ requests. The even key is in the format "initiationFrom + '\t' + streamId"

Constructor Detail

StreamNegotiator

public StreamNegotiator()

Method Detail

createInitiationAccept

protected static StreamInitiation createInitiationAccept(StreamInitiation streamInitiationOffer,
                                                         String[] namespaces)

Creates the initiation acceptance stanza(/packet) to forward to the stream initiator.

Parameters:

streamInitiationOffer - The offer from the stream initiator to connect for a stream.

namespaces - The namespace that relates to the accepted means of transfer.

Returns:

The response to be forwarded to the initiator.

initiateIncomingStream

protected final IQ initiateIncomingStream(XMPPConnection connection,
                                          StreamInitiation initiation)
                                   throws SmackException.NoResponseException,
                                          XMPPException.XMPPErrorException,
                                          SmackException.NotConnectedException

Throws:

SmackException.NoResponseException

XMPPException.XMPPErrorException

SmackException.NotConnectedException

newStreamInitiation

protected abstract void newStreamInitiation(String from,
                                            String streamID)

Signal that a new stream initiation arrived. The negotiator may needs to prepare for it.

Parameters:

from - The initiator of the file transfer.

streamID - The stream ID related to the transfer.

createIncomingStream

public abstract InputStream createIncomingStream(StreamInitiation initiation)
                                          throws XMPPException.XMPPErrorException,
                                                 InterruptedException,
                                                 SmackException.NoResponseException,
                                                 SmackException

This method handles the file stream download negotiation process. The appropriate stream negotiator's initiate incoming stream is called after an appropriate file transfer method is selected. The manager will respond to the initiator with the selected means of transfer, then it will handle any negotiation specific to the particular transfer method. This method returns the InputStream, ready to transfer the file.

Parameters:

initiation - The initiation that triggered this download.

Returns:

After the negotiation process is complete, the InputStream to write a file to is returned.

Throws:

XMPPException.XMPPErrorException - If an error occurs during this process an XMPPException is thrown.

InterruptedException - If thread is interrupted.

SmackException

SmackException.NoResponseException

createOutgoingStream

public abstract OutputStream createOutgoingStream(String streamID,
                                                  String initiator,
                                                  String target)
                                           throws XMPPException.XMPPErrorException,
                                                  SmackException.NoResponseException,
                                                  SmackException,
                                                  XMPPException

This method handles the file upload stream negotiation process. The particular stream negotiator is determined during the file transfer negotiation process. This method returns the OutputStream to transmit the file to the remote user.

Parameters:

streamID - The streamID that uniquely identifies the file transfer.

initiator - The fully-qualified JID of the initiator of the file transfer.

target - The fully-qualified JID of the target or receiver of the file transfer.

Returns:

The negotiated stream ready for data.

Throws:

XMPPException.XMPPErrorException - If an error occurs during the negotiation process an exception will be thrown.

SmackException

XMPPException

SmackException.NoResponseException

getNamespaces

public abstract String[] getNamespaces()

Returns the XMPP namespace reserved for this particular type of file transfer.

Returns:

Returns the XMPP namespace reserved for this particular type of file transfer.

signal

public static void signal(String eventKey,
                          IQ eventValue)