org.apache.activemq.broker
Class ConnectionContext
java.lang.Object
org.apache.activemq.broker.ConnectionContext
public class ConnectionContext
- extends 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(MessageEvaluationContext messageEvaluationContext)
ConnectionContext
public ConnectionContext(ConnectionInfo info)
copy
public ConnectionContext copy()
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 ConcurrentHashMap<TransactionId,Transaction> getTransactions()
setTransactions
public void setTransactions(ConcurrentHashMap<TransactionId,Transaction> transactions)
isInTransaction
public boolean isInTransaction()
getClientId
public String getClientId()
setClientId
public void setClientId(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 String getUserName()
setUserName
protected void setUserName(String userName)
getMessageEvaluationContext
public MessageEvaluationContext getMessageEvaluationContext()
getLongTermStoreContext
public Object getLongTermStoreContext()
setLongTermStoreContext
public void setLongTermStoreContext(Object longTermStoreContext)
isProducerFlowControl
public boolean isProducerFlowControl()
setProducerFlowControl
public void setProducerFlowControl(boolean disableProducerFlowControl)
isAllowedToConsume
public boolean isAllowedToConsume(MessageReference n)
throws IOException
- Throws:
IOException
isNetworkConnection
public boolean isNetworkConnection()
setNetworkConnection
public void setNetworkConnection(boolean networkConnection)
getStopping
public AtomicBoolean getStopping()
setDontSendReponse
public void setDontSendReponse(boolean b)
isDontSendReponse
public boolean isDontSendReponse()
isSlave
public boolean isSlave()
- Returns:
- the slave
isClientMaster
public boolean isClientMaster()
- Returns:
- the clientMaster
setClientMaster
public void setClientMaster(boolean clientMaster)
- Parameters:
clientMaster
- the clientMaster to set
isFaultTolerant
public boolean isFaultTolerant()
setFaultTolerant
public void setFaultTolerant(boolean faultTolerant)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.