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.
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 java.util.concurrent.ConcurrentHashMap<TransactionId,Transaction> getTransactions()
setTransactions
public void setTransactions(java.util.concurrent.ConcurrentHashMap<TransactionId,Transaction> transactions)
isInTransaction
public boolean isInTransaction()
getClientId
public java.lang.String getClientId()
setClientId
public void setClientId(java.lang.String clientId)
isReconnect
public boolean isReconnect()
setReconnect
public void setReconnect(boolean reconnect)
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
isNetworkConnection
public boolean isNetworkConnection()
setNetworkConnection
public void setNetworkConnection(boolean networkConnection)
getStopping
public java.util.concurrent.atomic.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)
setConnectionState
public void setConnectionState(ConnectionState connectionState)
getConnectionState
public ConnectionState getConnectionState()
Copyright © 2005-2012. All Rights Reserved.