org.apache.qpid.console
Class Session

java.lang.Object
  extended by org.apache.qpid.console.Session

public class Session
extends Object


Field Summary
protected  ArrayList<Broker> brokers
           
 Console console
           
static int CONTEXT_MULTIGET
           
static int CONTEXT_STARTUP
           
static int CONTEXT_SYNC
           
static int DEFAULT_GET_WAIT_TIME
           
protected  ArrayList<QMFObject> getResult
           
protected  Object lockObject
           
protected  HashMap<String,HashMap<String,SchemaClass>> packages
           
 boolean recieveEvents
           
 boolean recieveHeartbeat
           
 boolean recieveObjects
           
protected  SequenceManager sequenceManager
           
protected  Object syncResult
           
protected  ArrayList<Long> syncSequenceList
           
 boolean userBindings
           
 
Constructor Summary
Session()
           
Session(Console console)
           
 
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
 

Field Detail

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
Constructor Detail

Session

public Session()

Session

public Session(Console console)
Method Detail

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