org.apache.activemq.broker
Class ConnectionContext

java.lang.Object
  extended by org.apache.activemq.broker.ConnectionContext

public class ConnectionContext
extends java.lang.Object

Used to hold context information needed to process requests sent to a broker.

Version:
$Revision: 1.5 $

Constructor Summary
ConnectionContext()
           
ConnectionContext(ConnectionInfo info)
           
 
Method Summary
 int decrementReference()
           
 Broker getBroker()
           
 java.lang.String getClientId()
           
 Connection getConnection()
           
 ConnectionId getConnectionId()
           
 Connector getConnector()
           
 java.lang.Object getLongTermStoreContext()
           
 MessageAuthorizationPolicy getMessageAuthorizationPolicy()
           
 MessageEvaluationContext getMessageEvaluationContext()
           
 SecurityContext getSecurityContext()
           
 edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean getStopping()
           
 Transaction getTransaction()
           
 edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap getTransactions()
           
 java.lang.String getUserName()
           
 WireFormatInfo getWireFormatInfo()
           
 int incrementReference()
           
 boolean isAllowedToConsume(MessageReference n)
           
 boolean isDontSendReponse()
           
 boolean isHaAware()
           
 boolean isInRecoveryMode()
           
 boolean isInTransaction()
           
 boolean isNetworkConnection()
           
 boolean isProducerFlowControl()
           
 void setBroker(Broker broker)
           
 void setClientId(java.lang.String clientId)
           
 void setConnection(Connection connection)
           
 void setConnectionId(ConnectionId connectionId)
           
 void setConnector(Connector connector)
           
 void setDontSendReponse(boolean dontSendReponse)
           
 void setHaAware(boolean haAware)
           
 void setInRecoveryMode(boolean inRecoveryMode)
           
 void setLongTermStoreContext(java.lang.Object longTermStoreContext)
           
 void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
          Sets the policy used to decide if the current connection is authorized to consume a given message
 void setNetworkConnection(boolean networkConnection)
           
 void setProducerFlowControl(boolean disableProducerFlowControl)
           
 void setSecurityContext(SecurityContext subject)
           
 void setTransaction(Transaction transaction)
           
 void setTransactions(edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap transactions)
           
protected  void setUserName(java.lang.String userName)
           
 void setWireFormatInfo(WireFormatInfo wireFormatInfo)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConnectionContext

public ConnectionContext()

ConnectionContext

public ConnectionContext(ConnectionInfo info)
Method Detail

getSecurityContext

public SecurityContext getSecurityContext()

setSecurityContext

public void setSecurityContext(SecurityContext subject)

getBroker

public Broker getBroker()
Returns:
the broker being used.

setBroker

public void setBroker(Broker broker)
Parameters:
broker - being used

getConnection

public Connection getConnection()
Returns:
the connection being used

setConnection

public void setConnection(Connection connection)
Parameters:
connection - being used

getTransaction

public Transaction getTransaction()
Returns:
the transaction being used.

setTransaction

public void setTransaction(Transaction transaction)
Parameters:
transaction - being used.

getConnector

public Connector getConnector()
Returns:
the connector being used.

setConnector

public void setConnector(Connector connector)
Parameters:
connector - being used.

getMessageAuthorizationPolicy

public MessageAuthorizationPolicy getMessageAuthorizationPolicy()

setMessageAuthorizationPolicy

public void setMessageAuthorizationPolicy(MessageAuthorizationPolicy messageAuthorizationPolicy)
Sets the policy used to decide if the current connection is authorized to consume a given message


isInRecoveryMode

public boolean isInRecoveryMode()
Returns:

setInRecoveryMode

public void setInRecoveryMode(boolean inRecoveryMode)

getTransactions

public edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap getTransactions()

setTransactions

public void setTransactions(edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap transactions)

isInTransaction

public boolean isInTransaction()

getClientId

public java.lang.String getClientId()

setClientId

public void setClientId(java.lang.String clientId)

isHaAware

public boolean isHaAware()

setHaAware

public void setHaAware(boolean haAware)

getWireFormatInfo

public WireFormatInfo getWireFormatInfo()

setWireFormatInfo

public void setWireFormatInfo(WireFormatInfo wireFormatInfo)

getConnectionId

public ConnectionId getConnectionId()

setConnectionId

public void setConnectionId(ConnectionId connectionId)

getUserName

public java.lang.String getUserName()

setUserName

protected void setUserName(java.lang.String userName)

getMessageEvaluationContext

public MessageEvaluationContext getMessageEvaluationContext()

getLongTermStoreContext

public java.lang.Object getLongTermStoreContext()

setLongTermStoreContext

public void setLongTermStoreContext(java.lang.Object longTermStoreContext)

isProducerFlowControl

public boolean isProducerFlowControl()

setProducerFlowControl

public void setProducerFlowControl(boolean disableProducerFlowControl)

isAllowedToConsume

public boolean isAllowedToConsume(MessageReference n)
                           throws java.io.IOException
Throws:
java.io.IOException

incrementReference

public int incrementReference()

decrementReference

public int decrementReference()

isDontSendReponse

public boolean isDontSendReponse()

setDontSendReponse

public void setDontSendReponse(boolean dontSendReponse)

isNetworkConnection

public boolean isNetworkConnection()

setNetworkConnection

public void setNetworkConnection(boolean networkConnection)

getStopping

public edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean getStopping()


Copyright © 2010 Apache Software Foundation. All Rights Reserved.