org.apache.qpid.server.state
Class AMQStateManager
java.lang.Object
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AMQStateManager
public AMQStateManager(VirtualHostRegistry virtualHostRegistry,
AMQProtocolSession protocolSession)
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