org.apache.qpid.console
Class Session
java.lang.Object
org.apache.qpid.console.Session
public class Session
- extends Object
Method Summary |
void |
addBroker(String url)
|
ArrayList<String> |
bindingKeys()
|
void |
close()
|
protected QMFObject |
createQMFObject(SchemaClass schema,
boolean hasProperties,
boolean hasStats,
boolean isManaged)
|
protected QMFObject |
createQMFObject(SchemaClass schema,
org.apache.qpid.transport.codec.Decoder dec,
boolean hasProperties,
boolean hasStats,
boolean isManaged)
|
Object |
decodeValue(org.apache.qpid.transport.codec.Decoder dec,
short type)
|
void |
encodeValue(org.apache.qpid.transport.codec.Encoder enc,
short type,
Object val)
|
Broker |
getBroker(long BrokerBank)
|
ArrayList<ClassKey> |
getClasses(String packageName)
|
ArrayList<QMFObject> |
getObjects(HashMap<String,Object> args)
|
ArrayList<String> |
getPackages()
|
SchemaClass |
getSchema(ClassKey key)
|
protected SchemaClass |
getSchema(ClassKey key,
boolean waitForStable)
|
void |
handleAgentRemoved(Agent agent)
|
void |
handleBrokerConnect(Broker broker)
|
void |
handleBrokerDisconnect(Broker broker)
|
void |
handleBrokerResponse(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
void |
handleClassIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
void |
handleCommandComplete(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
void |
handleContentIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence,
boolean hasProperties,
boolean hasStatistics)
|
void |
handleEventIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
void |
handleHeartbeatIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence,
Message msg)
|
void |
handleMethodResponse(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
void |
handleNewAgent(Agent agent)
|
void |
handlePackageIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
void |
handleSchemaResponse(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
|
MethodResult |
invokeMethod(QMFObject obj,
String name,
List<Object> args,
boolean synchronous,
int timeToLive)
|
QMFObject |
makeObject(ClassKey key)
|
QMFObject |
makeObject(String keyString)
|
void |
removeBroker(Broker broker)
|
boolean |
selectMatch(QMFObject obj)
|
protected long |
sendMethodRequest(QMFObject obj,
Broker aBroker,
String name,
List<Object> args,
boolean synchronous,
int timeToLive)
|
protected void |
waitForStable()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CONTEXT_SYNC
public static final int CONTEXT_SYNC
- See Also:
- Constant Field Values
CONTEXT_STARTUP
public static final int CONTEXT_STARTUP
- See Also:
- Constant Field Values
CONTEXT_MULTIGET
public static final int CONTEXT_MULTIGET
- See Also:
- Constant Field Values
DEFAULT_GET_WAIT_TIME
public static final int DEFAULT_GET_WAIT_TIME
- See Also:
- Constant Field Values
recieveObjects
public boolean recieveObjects
recieveEvents
public boolean recieveEvents
recieveHeartbeat
public boolean recieveHeartbeat
userBindings
public boolean userBindings
console
public Console console
packages
protected HashMap<String,HashMap<String,SchemaClass>> packages
brokers
protected ArrayList<Broker> brokers
sequenceManager
protected SequenceManager sequenceManager
lockObject
protected Object lockObject
syncSequenceList
protected ArrayList<Long> syncSequenceList
getResult
protected ArrayList<QMFObject> getResult
syncResult
protected Object syncResult
Session
public Session()
Session
public Session(Console console)
addBroker
public void addBroker(String url)
bindingKeys
public ArrayList<String> bindingKeys()
close
public void close()
createQMFObject
protected QMFObject createQMFObject(SchemaClass schema,
boolean hasProperties,
boolean hasStats,
boolean isManaged)
createQMFObject
protected QMFObject createQMFObject(SchemaClass schema,
org.apache.qpid.transport.codec.Decoder dec,
boolean hasProperties,
boolean hasStats,
boolean isManaged)
decodeValue
public Object decodeValue(org.apache.qpid.transport.codec.Decoder dec,
short type)
encodeValue
public void encodeValue(org.apache.qpid.transport.codec.Encoder enc,
short type,
Object val)
getBroker
public Broker getBroker(long BrokerBank)
getClasses
public ArrayList<ClassKey> getClasses(String packageName)
getObjects
public ArrayList<QMFObject> getObjects(HashMap<String,Object> args)
getPackages
public ArrayList<String> getPackages()
getSchema
public SchemaClass getSchema(ClassKey key)
getSchema
protected SchemaClass getSchema(ClassKey key,
boolean waitForStable)
handleAgentRemoved
public void handleAgentRemoved(Agent agent)
handleBrokerConnect
public void handleBrokerConnect(Broker broker)
handleBrokerDisconnect
public void handleBrokerDisconnect(Broker broker)
handleBrokerResponse
public void handleBrokerResponse(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
handleClassIndicator
public void handleClassIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
handleCommandComplete
public void handleCommandComplete(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
handleContentIndicator
public void handleContentIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence,
boolean hasProperties,
boolean hasStatistics)
handleEventIndicator
public void handleEventIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
handleHeartbeatIndicator
public void handleHeartbeatIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence,
Message msg)
handleMethodResponse
public void handleMethodResponse(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
handleNewAgent
public void handleNewAgent(Agent agent)
handlePackageIndicator
public void handlePackageIndicator(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
handleSchemaResponse
public void handleSchemaResponse(Broker broker,
org.apache.qpid.transport.codec.Decoder decoder,
long sequence)
invokeMethod
public MethodResult invokeMethod(QMFObject obj,
String name,
List<Object> args,
boolean synchronous,
int timeToLive)
makeObject
public QMFObject makeObject(ClassKey key)
makeObject
public QMFObject makeObject(String keyString)
removeBroker
public void removeBroker(Broker broker)
selectMatch
public boolean selectMatch(QMFObject obj)
sendMethodRequest
protected long sendMethodRequest(QMFObject obj,
Broker aBroker,
String name,
List<Object> args,
boolean synchronous,
int timeToLive)
waitForStable
protected void waitForStable()
Licensed to the Apache Software Foundation