public class QueueManager
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CANNOTCANCELITEM |
static java.lang.String |
CANNOTCOPYFILE |
static java.lang.String |
CANNOTDELETE |
static java.lang.String |
CANNOTGETINFO |
static java.lang.String |
CANNOTLIST |
static java.lang.String |
CANNOTLOGOUT |
static java.lang.String |
CANNOTMAKEDIRECTORY |
static java.lang.String |
CANNOTRENAME |
static int |
DEFAULTSIZE |
static int |
HIGH |
static java.lang.String |
HTTPERROR |
static java.lang.String |
IOERROR |
static java.lang.String |
ITEMNOTFOUND |
static int |
MAXSEQ |
static int |
NORMAL |
static java.lang.String |
NOTIMPLEMENTED |
static int |
QUEUE |
static int |
QUEUEIN |
static int |
QUEUEOUT |
static int |
SLEEPTIME |
Modifier and Type | Method and Description |
---|---|
long |
add(TransferController controller)
Add to queue.
|
long |
add(TransferController controller,
int priority)
Add to queue.
|
void |
cancelItem(long itemid,
boolean force)
Cancel item from queue.
|
int |
getConcurrency()
Returns max concurrent transfers for the QueueManager.
|
boolean |
getDestroy() |
static QueueManager |
getInstance()
Return QueueManager instance.
|
java.util.List<java.lang.Long> |
getQueueItems(int queueid)
Returns list of item id from a given queue.
|
int |
getQueueSize(int queueid)
Return size of a given queue.
|
TransferStatus |
getStatus(long id)
Return transfer status for a given id.
|
boolean |
isSuspend() |
void |
reset() |
void |
run()
Main loop.
|
void |
setConcurrency(int cn)
Set concurrent asynchronous transfers.
|
void |
setDestroy(boolean st) |
void |
setSuspend(boolean suspend) |
public static final java.lang.String NOTIMPLEMENTED
public static final java.lang.String CANNOTMAKEDIRECTORY
public static final java.lang.String CANNOTRENAME
public static final java.lang.String CANNOTDELETE
public static final java.lang.String CANNOTCOPYFILE
public static final java.lang.String CANNOTGETINFO
public static final java.lang.String CANNOTLIST
public static final java.lang.String CANNOTLOGOUT
public static final java.lang.String ITEMNOTFOUND
public static final java.lang.String CANNOTCANCELITEM
public static final java.lang.String HTTPERROR
public static final java.lang.String IOERROR
public static int SLEEPTIME
public static int HIGH
public static int NORMAL
public static int QUEUEIN
public static int QUEUE
public static int QUEUEOUT
public static int DEFAULTSIZE
public static int MAXSEQ
public static QueueManager getInstance()
public void setConcurrency(int cn)
cn
- public int getConcurrency()
public long add(TransferController controller, int priority)
controller
- priority
- 0=NORMAL, 1=HIGHpublic long add(TransferController controller)
controller
- public void cancelItem(long itemid, boolean force) throws ClientException
itemid
- force
- bypass UPLOADING or DOWNLOADING state.ClientException
public int getQueueSize(int queueid)
queueid
- public java.util.List<java.lang.Long> getQueueItems(int queueid)
queueid
- public void reset()
public TransferStatus getStatus(long id) throws ClientException
id
- ClientException
public void run()
run
in interface java.lang.Runnable
public void setDestroy(boolean st)
public boolean getDestroy()
public boolean isSuspend()
public void setSuspend(boolean suspend)