org.apache.qpid.console
Class Broker

java.lang.Object
  extended by org.apache.qpid.console.Broker
All Implemented Interfaces:
MessageListener

public class Broker
extends Object
implements MessageListener


Nested Class Summary
(package private)  class Broker.HeaderInfo
           
 
Field Summary
 HashMap<String,Agent> Agents
           
(package private)  UUID brokerId
           
(package private)  org.apache.qpid.client.AMQConnection connection
           
(package private)  boolean sessionTransacted
           
static int SYNC_TIME
           
 String url
           
 
Constructor Summary
Broker(Session session, String url)
           
 
Method Summary
 int brokerBank()
           
protected  Broker.HeaderInfo CheckHeader(org.apache.qpid.transport.codec.Decoder decoder)
           
 org.apache.qpid.transport.codec.Encoder createEncoder(char opcode, long sequence)
           
 Message createMessage(org.apache.qpid.transport.codec.Encoder enc)
           
 void decrementOutstanding()
           
protected  void finalize()
           
 boolean getSyncInFlight()
           
 void incrementOutstanding()
           
 boolean isConnected()
           
 void onMessage(Message msg)
           
 void send(org.apache.qpid.transport.codec.Encoder enc)
           
 void send(Message msg)
           
 void send(Message msg, String routingKey)
           
 void send(Message msg, String routingKey, int ttl)
           
protected  org.apache.qpid.transport.codec.Encoder setHeader(org.apache.qpid.transport.codec.Encoder enc, char opcode, long sequence)
           
 void setSyncInFlight(boolean inFlight)
           
 void shutdown()
           
protected  void tryToConnect()
           
 void updateAgent(QMFObject obj)
           
 void waitForStable()
           
 void waitForSync(int timeout)
           
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

SYNC_TIME

public static final int SYNC_TIME
See Also:
Constant Field Values

sessionTransacted

boolean sessionTransacted

connection

org.apache.qpid.client.AMQConnection connection

url

public String url

Agents

public HashMap<String,Agent> Agents

brokerId

UUID brokerId
Constructor Detail

Broker

public Broker(Session session,
              String url)
Method Detail

brokerBank

public int brokerBank()

CheckHeader

protected Broker.HeaderInfo CheckHeader(org.apache.qpid.transport.codec.Decoder decoder)

createEncoder

public org.apache.qpid.transport.codec.Encoder createEncoder(char opcode,
                                                             long sequence)

createMessage

public Message createMessage(org.apache.qpid.transport.codec.Encoder enc)

decrementOutstanding

public void decrementOutstanding()

finalize

protected void finalize()
Overrides:
finalize in class Object

getSyncInFlight

public boolean getSyncInFlight()

incrementOutstanding

public void incrementOutstanding()

isConnected

public boolean isConnected()

onMessage

public void onMessage(Message msg)
Specified by:
onMessage in interface MessageListener

send

public void send(org.apache.qpid.transport.codec.Encoder enc)

send

public void send(Message msg)

send

public void send(Message msg,
                 String routingKey)

send

public void send(Message msg,
                 String routingKey,
                 int ttl)

setHeader

protected org.apache.qpid.transport.codec.Encoder setHeader(org.apache.qpid.transport.codec.Encoder enc,
                                                            char opcode,
                                                            long sequence)

setSyncInFlight

public void setSyncInFlight(boolean inFlight)

shutdown

public void shutdown()

tryToConnect

protected void tryToConnect()

updateAgent

public void updateAgent(QMFObject obj)

waitForStable

public void waitForStable()

waitForSync

public void waitForSync(int timeout)


Licensed to the Apache Software Foundation