@Deprecated public class QueueInfo extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
QueueInfo.QueueInfoDelegateFactory
Deprecated.
A factory for creating object store-specific queue info delegates
|
Constructor and Description |
---|
QueueInfo(QueueInfo other)
Deprecated.
|
QueueInfo(String name,
MuleContext muleContext,
QueueConfiguration config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
canTakeFromStore()
Deprecated.
|
void |
clear()
Deprecated.
|
boolean |
equals(Object obj)
Deprecated.
|
int |
getCapacity()
Deprecated.
|
String |
getName()
Deprecated.
|
int |
getSize()
Deprecated.
|
ListableObjectStore<Serializable> |
getStore()
Deprecated.
|
int |
hashCode()
Deprecated.
|
boolean |
isQueueTransactional()
Deprecated.
|
boolean |
isQueueTransient()
Deprecated.
|
boolean |
offer(Serializable o,
int room,
long timeout)
Deprecated.
|
Serializable |
peek()
Deprecated.
|
Serializable |
poll(long timeout)
Deprecated.
|
void |
putNow(Serializable o)
Deprecated.
|
static void |
registerDelegateFactory(Class<? extends ObjectStore> storeType,
QueueInfo.QueueInfoDelegateFactory factory)
Deprecated.
|
void |
setConfig(QueueConfiguration config)
Deprecated.
|
Serializable |
takeNextItemFromStore(long timeout)
Deprecated.
|
void |
untake(Serializable item)
Deprecated.
|
void |
writeToObjectStore(Serializable data)
Deprecated.
|
public QueueInfo(String name, MuleContext muleContext, QueueConfiguration config)
public QueueInfo(QueueInfo other)
public void setConfig(QueueConfiguration config)
public String getName()
public void putNow(Serializable o)
public boolean offer(Serializable o, int room, long timeout) throws InterruptedException, ObjectStoreException
public Serializable poll(long timeout) throws InterruptedException
InterruptedException
public Serializable peek() throws InterruptedException
InterruptedException
public void untake(Serializable item) throws InterruptedException, ObjectStoreException
public int getSize()
public void clear() throws InterruptedException
InterruptedException
public ListableObjectStore<Serializable> getStore()
public static void registerDelegateFactory(Class<? extends ObjectStore> storeType, QueueInfo.QueueInfoDelegateFactory factory)
public int getCapacity()
public boolean canTakeFromStore()
public Serializable takeNextItemFromStore(long timeout) throws InterruptedException
InterruptedException
public void writeToObjectStore(Serializable data) throws InterruptedException, ObjectStoreException
public boolean isQueueTransient()
public boolean isQueueTransactional()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.