org.apache.activemq.broker
Class ConnectionContext
java.lang.Object
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 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConnectionContext
public ConnectionContext()
ConnectionContext
public ConnectionContext(ConnectionInfo info)
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 © 2009 Apache Software Foundation. All Rights Reserved.