org.apache.qpid.server.state
Class AMQStateManager

java.lang.Object
  extended by org.apache.qpid.server.state.AMQStateManager
All Implemented Interfaces:
org.apache.qpid.protocol.AMQMethodListener

public class AMQStateManager
extends Object
implements org.apache.qpid.protocol.AMQMethodListener

The state manager is responsible for managing the state of the protocol session.

For each AMQProtocolHandler there is a separate state manager.


Constructor Summary
AMQStateManager(VirtualHostRegistry virtualHostRegistry, AMQProtocolSession protocolSession)
           
 
Method Summary
 void addStateListener(StateListener listener)
           
 void changeState(AMQState newState)
           
 void error(Exception e)
           
 AMQState getCurrentState()
           
 AMQProtocolSession getProtocolSession()
           
 VirtualHostRegistry getVirtualHostRegistry()
           
<B extends org.apache.qpid.framing.AMQMethodBody>
boolean
methodReceived(org.apache.qpid.protocol.AMQMethodEvent<B> evt)
           
 void removeStateListener(StateListener listener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AMQStateManager

public AMQStateManager(VirtualHostRegistry virtualHostRegistry,
                       AMQProtocolSession protocolSession)
Method Detail

getCurrentState

public AMQState getCurrentState()

changeState

public void changeState(AMQState newState)
                 throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

error

public void error(Exception e)
Specified by:
error in interface org.apache.qpid.protocol.AMQMethodListener

methodReceived

public <B extends org.apache.qpid.framing.AMQMethodBody> boolean methodReceived(org.apache.qpid.protocol.AMQMethodEvent<B> evt)
                       throws org.apache.qpid.AMQException
Specified by:
methodReceived in interface org.apache.qpid.protocol.AMQMethodListener
Throws:
org.apache.qpid.AMQException

addStateListener

public void addStateListener(StateListener listener)

removeStateListener

public void removeStateListener(StateListener listener)

getVirtualHostRegistry

public VirtualHostRegistry getVirtualHostRegistry()

getProtocolSession

public AMQProtocolSession getProtocolSession()


Licensed to the Apache Software Foundation