org.apache.qpid.console
Class Broker
java.lang.Object
org.apache.qpid.console.Broker
- All Implemented Interfaces:
- MessageListener
public class Broker
- extends Object
- implements MessageListener
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
Broker
public Broker(Session session,
String url)
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